org.apache.beam.sdk.extensions.sql.impl

Class BeamCalciteSchema

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.BeamCalciteSchema

All Implemented Interfaces:

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

public class BeamCalciteSchema
extends java.lang.Object
implements org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

Adapter from TableProvider to Schema.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema.TableType

Method Summary

Modifier and Type	Method and Description
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.linq4j.tree.Expression	getExpression(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.SchemaPlus parentSchema, java.lang.String name)
java.util.Set<java.lang.String>	getFunctionNames()
java.util.Collection<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function>	getFunctions(java.lang.String name)
java.util.Map<java.lang.String,java.lang.String>	getPipelineOptions()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema	getSubSchema(java.lang.String name)
java.util.Set<java.lang.String>	getSubSchemaNames()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Table	getTable(java.lang.String name)
java.util.Set<java.lang.String>	getTableNames()
TableProvider	getTableProvider()
@Nullable org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelProtoDataType	getType(java.lang.String name)
java.util.Set<java.lang.String>	getTypeNames()
boolean	isMutable()
void	removeAllPipelineOptions()
void	removePipelineOption(java.lang.String key)
void	setPipelineOption(java.lang.String key, java.lang.String value)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema	snapshot(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.SchemaVersion version)

Methods inherited from class java.lang.Object

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

Method Detail

getTableProvider

public TableProvider getTableProvider()

getPipelineOptions

public java.util.Map<java.lang.String,java.lang.String> getPipelineOptions()

setPipelineOption

public void setPipelineOption(java.lang.String key,
                              java.lang.String value)

removePipelineOption

public void removePipelineOption(java.lang.String key)

removeAllPipelineOptions

public void removeAllPipelineOptions()

isMutable

public boolean isMutable()

Specified by:

isMutable in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

snapshot

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema snapshot(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.SchemaVersion version)

Specified by:

snapshot in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getExpression

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.linq4j.tree.Expression getExpression(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.SchemaPlus parentSchema,
                                                                                                      java.lang.String name)

Specified by:

getExpression in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getTableNames

public java.util.Set<java.lang.String> getTableNames()

Specified by:

getTableNames in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getType

public @Nullable org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelProtoDataType getType(java.lang.String name)

Specified by:

getType in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getTypeNames

public java.util.Set<java.lang.String> getTypeNames()

Specified by:

getTypeNames in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getTable

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Table getTable(java.lang.String name)

Specified by:

getTable in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getFunctionNames

public java.util.Set<java.lang.String> getFunctionNames()

Specified by:

getFunctionNames in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getFunctions

public java.util.Collection<org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function> getFunctions(java.lang.String name)

Specified by:

getFunctions in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getSubSchemaNames

public java.util.Set<java.lang.String> getSubSchemaNames()

Specified by:

getSubSchemaNames in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema

getSubSchema

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema getSubSchema(java.lang.String name)

Specified by:

getSubSchema in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Schema