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.calcite.schema.Schema

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

Adapter from TableProvider to Schema.

Nested Class Summary

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

org.apache.calcite.schema.Schema.TableType

Constructor Summary

Constructors

Constructor and Description
BeamCalciteSchema(TableProvider tableProvider)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BeamCalciteSchema

public BeamCalciteSchema(TableProvider tableProvider)

Method Detail

getTableProvider

public TableProvider getTableProvider()

getPipelineOptions

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

isMutable

public boolean isMutable()

Specified by:

isMutable in interface org.apache.calcite.schema.Schema

snapshot

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

Specified by:

snapshot in interface org.apache.calcite.schema.Schema

getExpression

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

Specified by:

getExpression in interface org.apache.calcite.schema.Schema

getTableNames

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

Specified by:

getTableNames in interface org.apache.calcite.schema.Schema

getType

public org.apache.calcite.rel.type.RelProtoDataType getType(java.lang.String name)

Specified by:

getType in interface org.apache.calcite.schema.Schema

getTypeNames

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

Specified by:

getTypeNames in interface org.apache.calcite.schema.Schema

getTable

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

Specified by:

getTable in interface org.apache.calcite.schema.Schema

getFunctionNames

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

Specified by:

getFunctionNames in interface org.apache.calcite.schema.Schema

getFunctions

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

Specified by:

getFunctions in interface org.apache.calcite.schema.Schema

getSubSchemaNames

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

Specified by:

getSubSchemaNames in interface org.apache.calcite.schema.Schema

getSubSchema

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

Specified by:

getSubSchema in interface org.apache.calcite.schema.Schema