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

Class QueryTrait

java.lang.Object
org.apache.beam.sdk.extensions.sql.zetasql.QueryTrait
public class QueryTrait extends Object
QueryTrait.

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    Map<com.google.zetasql.resolvedast.ResolvedColumn,String>
    outputColumnMap
     
    Map<Long,org.apache.beam.sdk.extensions.sql.zetasql.TableResolution.SimpleTableWithPath>
    resolvedTables
     
    Map<String,com.google.zetasql.resolvedast.ResolvedNodes.ResolvedWithEntry>
    withEntries
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    QueryTrait()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addOutputColumnList(List<com.google.zetasql.resolvedast.ResolvedNodes.ResolvedOutputColumn> outputColumnList)
     
    void
    addResolvedTable(org.apache.beam.sdk.extensions.sql.zetasql.TableResolution.SimpleTableWithPath tableWithPath)
    Store a table together with its full path for repeated resolutions.
    List<String>
    getTablePath(com.google.zetasql.Table table)
    Returns a full table path (exlucding top-level schema) for a given ZetaSQL Table.
    boolean
    isTableResolved(com.google.zetasql.Table table)
    True if the table was resolved using the Calcite schema.
    String
    resolveAlias(com.google.zetasql.resolvedast.ResolvedColumn resolvedColumn)
     
    List<String>
    retrieveFieldNames(List<com.google.zetasql.resolvedast.ResolvedColumn> resolvedColumnList)
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • withEntries

      public Map<String,com.google.zetasql.resolvedast.ResolvedNodes.ResolvedWithEntry> withEntries

    • outputColumnMap

      public Map<com.google.zetasql.resolvedast.ResolvedColumn,String> outputColumnMap

    • resolvedTables

      public Map<Long,org.apache.beam.sdk.extensions.sql.zetasql.TableResolution.SimpleTableWithPath> resolvedTables

  • Constructor Details

    • QueryTrait

      public QueryTrait()

  • Method Details

    • addOutputColumnList

      public void addOutputColumnList(List<com.google.zetasql.resolvedast.ResolvedNodes.ResolvedOutputColumn> outputColumnList)

    • addResolvedTable

      public void addResolvedTable(org.apache.beam.sdk.extensions.sql.zetasql.TableResolution.SimpleTableWithPath tableWithPath)
      Store a table together with its full path for repeated resolutions.

    • isTableResolved

      public boolean isTableResolved(com.google.zetasql.Table table)
      True if the table was resolved using the Calcite schema.

    • getTablePath

      public List<String> getTablePath(com.google.zetasql.Table table)
      Returns a full table path (exlucding top-level schema) for a given ZetaSQL Table.

    • retrieveFieldNames

      public List<String> retrieveFieldNames(List<com.google.zetasql.resolvedast.ResolvedColumn> resolvedColumnList)

    • resolveAlias

      public String resolveAlias(com.google.zetasql.resolvedast.ResolvedColumn resolvedColumn)