public class QueryTrait
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
java.util.Map<com.google.zetasql.resolvedast.ResolvedColumn,java.lang.String> |
outputColumnMap |
java.util.Map<java.lang.Long,org.apache.beam.sdk.extensions.sql.zetasql.TableResolution.SimpleTableWithPath> |
resolvedTables |
java.util.Map<java.lang.String,com.google.zetasql.resolvedast.ResolvedNodes.ResolvedWithEntry> |
withEntries |
Constructor and Description |
---|
QueryTrait() |
Modifier and Type | Method and Description |
---|---|
void |
addOutputColumnList(java.util.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.
|
java.util.List<java.lang.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.
|
java.lang.String |
resolveAlias(com.google.zetasql.resolvedast.ResolvedColumn resolvedColumn) |
java.util.List<java.lang.String> |
retrieveFieldNames(java.util.List<com.google.zetasql.resolvedast.ResolvedColumn> resolvedColumnList) |
public java.util.Map<java.lang.String,com.google.zetasql.resolvedast.ResolvedNodes.ResolvedWithEntry> withEntries
public java.util.Map<com.google.zetasql.resolvedast.ResolvedColumn,java.lang.String> outputColumnMap
public java.util.Map<java.lang.Long,org.apache.beam.sdk.extensions.sql.zetasql.TableResolution.SimpleTableWithPath> resolvedTables
public void addOutputColumnList(java.util.List<com.google.zetasql.resolvedast.ResolvedNodes.ResolvedOutputColumn> outputColumnList)
public void addResolvedTable(org.apache.beam.sdk.extensions.sql.zetasql.TableResolution.SimpleTableWithPath tableWithPath)
public boolean isTableResolved(com.google.zetasql.Table table)
public java.util.List<java.lang.String> getTablePath(com.google.zetasql.Table table)
public java.util.List<java.lang.String> retrieveFieldNames(java.util.List<com.google.zetasql.resolvedast.ResolvedColumn> resolvedColumnList)
public java.lang.String resolveAlias(com.google.zetasql.resolvedast.ResolvedColumn resolvedColumn)