Package org.apache.calcite.test.catalog

Class MockCatalogReader.MockTable

java.lang.Object

org.apache.calcite.prepare.Prepare.AbstractPreparingTable

org.apache.calcite.test.catalog.MockCatalogReader.MockTable

All Implemented Interfaces:

org.apache.calcite.plan.RelOptTable, org.apache.calcite.prepare.Prepare.PreparingTable, org.apache.calcite.schema.Wrapper, org.apache.calcite.sql.validate.SqlValidatorTable

Direct Known Subclasses:

MockCatalogReader.MockDynamicTable, MockCatalogReader.MockModifiableViewRelOptTable, MockCatalogReader.MockViewTable

Enclosing class:

MockCatalogReader

public static class MockCatalogReader.MockTable
extends org.apache.calcite.prepare.Prepare.AbstractPreparingTable

Mock implementation of Prepare.PreparingTable.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	MockCatalogReader.MockTable.ModifiableTable	Implementation of AbstractModifiableTable.
private class	MockCatalogReader.MockTable.ModifiableTableWithCustomColumnResolving	Subclass of MockCatalogReader.MockTable.ModifiableTable that also implements CustomColumnResolvingTable.

Nested classes/interfaces inherited from interface org.apache.calcite.plan.RelOptTable

org.apache.calcite.plan.RelOptTable.ToRelContext, org.apache.calcite.plan.RelOptTable.ViewExpander

Field Summary

Fields

Modifier and Type	Field	Description
protected MockCatalogReader	catalogReader
protected java.util.List<org.apache.calcite.rel.RelCollation>	collationList
protected java.util.List<java.util.Map.Entry<java.lang.String,org.apache.calcite.rel.type.RelDataType>>	columnList
protected org.apache.calcite.sql2rel.InitializerExpressionFactory	initializerFactory
protected java.util.List<java.lang.Integer>	keyList
protected org.apache.calcite.rel.type.StructKind	kind
protected java.util.Set<java.lang.String>	monotonicColumnSet
protected java.util.List<java.lang.String>	names
protected java.util.List<org.apache.calcite.rel.RelReferentialConstraint>	referentialConstraints
protected MockCatalogReader.ColumnResolver	resolver
protected java.util.Set<java.lang.String>	rolledUpColumns
protected double	rowCount
protected org.apache.calcite.rel.type.RelDataType	rowType
protected boolean	stream

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MockTable(MockCatalogReader catalogReader, boolean stream, double rowCount, java.util.List<java.util.Map.Entry<java.lang.String,org.apache.calcite.rel.type.RelDataType>> columnList, java.util.List<java.lang.Integer> keyList, org.apache.calcite.rel.type.RelDataType rowType, java.util.List<org.apache.calcite.rel.RelCollation> collationList, java.util.List<java.lang.String> names, java.util.Set<java.lang.String> monotonicColumnSet, org.apache.calcite.rel.type.StructKind kind, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory)	Copy constructor.
	MockTable(MockCatalogReader catalogReader, java.lang.String catalogName, java.lang.String schemaName, java.lang.String name, boolean stream, double rowCount, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory)
private	MockTable(MockCatalogReader catalogReader, java.util.List<java.lang.String> names, boolean stream, double rowCount, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory)

Method Summary

Modifier and Type	Method	Description
void	addColumn(java.lang.String name, org.apache.calcite.rel.type.RelDataType type)
void	addColumn(java.lang.String name, org.apache.calcite.rel.type.RelDataType type, boolean isKey)
void	addMonotonic(java.lang.String name)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, java.util.List<java.lang.String> names, boolean stream, double rowCount)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, java.lang.String name, boolean stream, double rowCount)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, java.lang.String name, boolean stream, double rowCount, MockCatalogReader.ColumnResolver resolver)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, java.lang.String name, boolean stream, double rowCount, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerExpressionFactory)
protected org.apache.calcite.plan.RelOptTable	extend(org.apache.calcite.schema.Table extendedTable)
org.apache.calcite.sql.SqlAccessType	getAllowedAccess()
java.util.List<org.apache.calcite.rel.RelCollation>	getCollationList()
org.apache.calcite.rel.RelDistribution	getDistribution()
org.apache.calcite.linq4j.tree.Expression	getExpression(java.lang.Class clazz)
org.apache.calcite.rel.type.StructKind	getKind()
org.apache.calcite.sql.validate.SqlMonotonicity	getMonotonicity(java.lang.String columnName)
java.util.List<java.lang.String>	getQualifiedName()
java.util.List<org.apache.calcite.rel.RelReferentialConstraint>	getReferentialConstraints()
org.apache.calcite.plan.RelOptSchema	getRelOptSchema()
double	getRowCount()
org.apache.calcite.rel.type.RelDataType	getRowType()
boolean	isKey(org.apache.calcite.util.ImmutableBitSet columns)
void	onRegister(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
void	registerRolledUpColumn(java.lang.String columnName)
void	setKind(org.apache.calcite.rel.type.StructKind kind)
boolean	supportsModality(org.apache.calcite.sql.validate.SqlModality modality)
org.apache.calcite.rel.RelNode	toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context)
<T> T	unwrap(java.lang.Class<T> clazz)

Methods inherited from class org.apache.calcite.prepare.Prepare.AbstractPreparingTable

columnHasDefaultValue, extend, getColumnStrategies

Methods inherited from class java.lang.Object

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

Field Detail

catalogReader

protected final MockCatalogReader catalogReader

stream

protected final boolean stream

rowCount

protected final double rowCount

columnList

protected final java.util.List<java.util.Map.Entry<java.lang.String,org.apache.calcite.rel.type.RelDataType>> columnList

keyList

protected final java.util.List<java.lang.Integer> keyList

referentialConstraints

protected final java.util.List<org.apache.calcite.rel.RelReferentialConstraint> referentialConstraints

rowType

protected org.apache.calcite.rel.type.RelDataType rowType

collationList

protected java.util.List<org.apache.calcite.rel.RelCollation> collationList

names

protected final java.util.List<java.lang.String> names

monotonicColumnSet

protected final java.util.Set<java.lang.String> monotonicColumnSet

kind

protected org.apache.calcite.rel.type.StructKind kind

resolver

protected final MockCatalogReader.ColumnResolver resolver

initializerFactory

protected final org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory

rolledUpColumns

protected final java.util.Set<java.lang.String> rolledUpColumns

Constructor Detail

MockTable

public MockTable(MockCatalogReader catalogReader,
                 java.lang.String catalogName,
                 java.lang.String schemaName,
                 java.lang.String name,
                 boolean stream,
                 double rowCount,
                 MockCatalogReader.ColumnResolver resolver,
                 org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory)

MockTable

private MockTable(MockCatalogReader catalogReader,
                  java.util.List<java.lang.String> names,
                  boolean stream,
                  double rowCount,
                  MockCatalogReader.ColumnResolver resolver,
                  org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory)

MockTable

protected MockTable(MockCatalogReader catalogReader,
                    boolean stream,
                    double rowCount,
                    java.util.List<java.util.Map.Entry<java.lang.String,org.apache.calcite.rel.type.RelDataType>> columnList,
                    java.util.List<java.lang.Integer> keyList,
                    org.apache.calcite.rel.type.RelDataType rowType,
                    java.util.List<org.apache.calcite.rel.RelCollation> collationList,
                    java.util.List<java.lang.String> names,
                    java.util.Set<java.lang.String> monotonicColumnSet,
                    org.apache.calcite.rel.type.StructKind kind,
                    MockCatalogReader.ColumnResolver resolver,
                    org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory)

Copy constructor.

Method Detail

registerRolledUpColumn

public void registerRolledUpColumn(java.lang.String columnName)

extend

protected org.apache.calcite.plan.RelOptTable extend(org.apache.calcite.schema.Table extendedTable)

Specified by:

extend in class org.apache.calcite.prepare.Prepare.AbstractPreparingTable

create

public static MockCatalogReader.MockTable create(MockCatalogReader catalogReader,
                                                 MockCatalogReader.MockSchema schema,
                                                 java.lang.String name,
                                                 boolean stream,
                                                 double rowCount)

create

public static MockCatalogReader.MockTable create(MockCatalogReader catalogReader,
                                                 java.util.List<java.lang.String> names,
                                                 boolean stream,
                                                 double rowCount)

create

public static MockCatalogReader.MockTable create(MockCatalogReader catalogReader,
                                                 MockCatalogReader.MockSchema schema,
                                                 java.lang.String name,
                                                 boolean stream,
                                                 double rowCount,
                                                 MockCatalogReader.ColumnResolver resolver)

create

public static MockCatalogReader.MockTable create(MockCatalogReader catalogReader,
                                                 MockCatalogReader.MockSchema schema,
                                                 java.lang.String name,
                                                 boolean stream,
                                                 double rowCount,
                                                 MockCatalogReader.ColumnResolver resolver,
                                                 org.apache.calcite.sql2rel.InitializerExpressionFactory initializerExpressionFactory)

unwrap

public <T> T unwrap(java.lang.Class<T> clazz)

getRowCount

public double getRowCount()

getRelOptSchema

public org.apache.calcite.plan.RelOptSchema getRelOptSchema()

toRel

public org.apache.calcite.rel.RelNode toRel(org.apache.calcite.plan.RelOptTable.ToRelContext context)

getCollationList

public java.util.List<org.apache.calcite.rel.RelCollation> getCollationList()

getDistribution

public org.apache.calcite.rel.RelDistribution getDistribution()

isKey

public boolean isKey(org.apache.calcite.util.ImmutableBitSet columns)

getReferentialConstraints

public java.util.List<org.apache.calcite.rel.RelReferentialConstraint> getReferentialConstraints()

getRowType

public org.apache.calcite.rel.type.RelDataType getRowType()

supportsModality

public boolean supportsModality(org.apache.calcite.sql.validate.SqlModality modality)

onRegister

public void onRegister(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)

getQualifiedName

public java.util.List<java.lang.String> getQualifiedName()

getMonotonicity

public org.apache.calcite.sql.validate.SqlMonotonicity getMonotonicity(java.lang.String columnName)

getAllowedAccess

public org.apache.calcite.sql.SqlAccessType getAllowedAccess()

getExpression

public org.apache.calcite.linq4j.tree.Expression getExpression(java.lang.Class clazz)

addColumn

public void addColumn(java.lang.String name,
                      org.apache.calcite.rel.type.RelDataType type)

addColumn

public void addColumn(java.lang.String name,
                      org.apache.calcite.rel.type.RelDataType type,
                      boolean isKey)

addMonotonic

public void addMonotonic(java.lang.String name)

setKind

public void setKind(org.apache.calcite.rel.type.StructKind kind)

getKind

public org.apache.calcite.rel.type.StructKind getKind()