Package org.apache.beam.sdk.extensions.sql.zetasql

Class TableResolution

java.lang.Object
org.apache.beam.sdk.extensions.sql.zetasql.TableResolution
public class TableResolution extends Object
Utility methods to resolve a table, given a top-level Calcite schema and a table path.

  • Constructor Summary

    Constructors
    Constructor
    Description
    TableResolution()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static void
    registerTables(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.SchemaPlus schemaPlus, List<List<String>> tables)
    Registers tables that will be resolved during query analysis, so table providers can eagerly pre-load metadata.
    static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Table
    resolveCalciteTable(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.SchemaPlus schemaPlus, List<String> tablePath)
    Resolves tablePath according to the given schemaPlus.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • TableResolution

      public TableResolution()

  • Method Details

    • resolveCalciteTable

      public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Table resolveCalciteTable(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.SchemaPlus schemaPlus, List<String> tablePath)
      Resolves tablePath according to the given schemaPlus.

      tablePath represents a structured table name where the last component is the name of the table and all the preceding components are sub-schemas / namespaces within schemaPlus.

    • registerTables

      public static void registerTables(org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.SchemaPlus schemaPlus, List<List<String>> tables)
      Registers tables that will be resolved during query analysis, so table providers can eagerly pre-load metadata.