org.apache.calcite.test.catalog

类 MockCatalogReader.MockTable

java.lang.Object

org.apache.calcite.prepare.Prepare.AbstractPreparingTable

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

所有已实现的接口:

org.apache.calcite.plan.RelOptTable, org.apache.calcite.prepare.Prepare.PreparingTable, org.apache.calcite.rel.metadata.BuiltInMetadata.MaxRowCount.Handler, org.apache.calcite.rel.metadata.MetadataHandler<org.apache.calcite.rel.metadata.BuiltInMetadata.MaxRowCount>, org.apache.calcite.schema.Wrapper, org.apache.calcite.sql.validate.SqlValidatorTable

直接已知子类:

MockCatalogReader.MockModifiableViewRelOptTable, MockCatalogReader.MockRelViewTable, MockCatalogReader.MockViewTable

封闭类:

MockCatalogReader

public static class MockCatalogReader.MockTable
extends org.apache.calcite.prepare.Prepare.AbstractPreparingTable
implements org.apache.calcite.rel.metadata.BuiltInMetadata.MaxRowCount.Handler

Mock implementation of Prepare.PreparingTable.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.calcite.plan.RelOptTable

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

字段概要

字段

限定符和类型	字段和说明
protected MockCatalogReader	catalogReader
protected List<org.apache.calcite.rel.RelCollation>	collationList
protected List<Map.Entry<String,org.apache.calcite.rel.type.RelDataType>>	columnList
protected org.apache.calcite.sql2rel.InitializerExpressionFactory	initializerFactory
protected List<Integer>	keyList
protected org.apache.calcite.rel.type.StructKind	kind
protected Double	maxRowCount
protected Set<String>	monotonicColumnSet
protected List<String>	names
protected List<org.apache.calcite.rel.RelReferentialConstraint>	referentialConstraints
protected MockCatalogReader.ColumnResolver	resolver
protected Set<String>	rolledUpColumns
protected double	rowCount
protected org.apache.calcite.rel.type.RelDataType	rowType
protected boolean	stream
protected List<Object>	wraps Wrapped objects that can be obtained by calling unwrap(Class).

构造器概要

构造器

限定符	构造器和说明
protected	MockTable(MockCatalogReader catalogReader, boolean stream, boolean temporal, double rowCount, List<Map.Entry<String,org.apache.calcite.rel.type.RelDataType>> columnList, List<Integer> keyList, org.apache.calcite.rel.type.RelDataType rowType, List<org.apache.calcite.rel.RelCollation> collationList, List<String> names, Set<String> monotonicColumnSet, org.apache.calcite.rel.type.StructKind kind, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory) Copy constructor.
	MockTable(MockCatalogReader catalogReader, String catalogName, String schemaName, String name, boolean stream, boolean temporal, double rowCount, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory)
	MockTable(MockCatalogReader catalogReader, String catalogName, String schemaName, String name, boolean stream, boolean temporal, double rowCount, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerFactory, Double maxRowCount)

方法概要

限定符和类型	方法和说明
void	addColumn(String name, org.apache.calcite.rel.type.RelDataType type)
void	addColumn(String name, org.apache.calcite.rel.type.RelDataType type, boolean isKey)
void	addMonotonic(String name)
void	addWrap(Object wrap)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, List<String> names, boolean stream, double rowCount)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, String name, boolean stream, double rowCount)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, String name, boolean stream, double rowCount, double maxRowCount)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, String name, boolean stream, double rowCount, MockCatalogReader.ColumnResolver resolver)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, String name, boolean stream, double rowCount, MockCatalogReader.ColumnResolver resolver, double maxRowCount)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, String name, boolean stream, double rowCount, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerExpressionFactory, boolean temporal)
static MockCatalogReader.MockTable	create(MockCatalogReader catalogReader, MockCatalogReader.MockSchema schema, String name, boolean stream, double rowCount, MockCatalogReader.ColumnResolver resolver, org.apache.calcite.sql2rel.InitializerExpressionFactory initializerExpressionFactory, boolean temporal, Double maxRowCount)
protected org.apache.calcite.plan.RelOptTable	extend(org.apache.calcite.schema.Table extendedTable)
org.apache.calcite.sql.SqlAccessType	getAllowedAccess()
List<org.apache.calcite.rel.RelCollation>	getCollationList()
org.apache.calcite.rel.metadata.MetadataDef<org.apache.calcite.rel.metadata.BuiltInMetadata.MaxRowCount>	getDef()
org.apache.calcite.rel.RelDistribution	getDistribution()
org.apache.calcite.linq4j.tree.Expression	getExpression(Class clazz)
List<org.apache.calcite.util.ImmutableBitSet>	getKeys()
org.apache.calcite.rel.type.StructKind	getKind()
@Nullable Double	getMaxRowCount(org.apache.calcite.rel.RelNode r, org.apache.calcite.rel.metadata.RelMetadataQuery mq)
org.apache.calcite.sql.validate.SqlMonotonicity	getMonotonicity(String columnName)
List<String>	getQualifiedName()
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)
boolean	isTemporal()
void	onRegister(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
void	registerRolledUpColumn(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(Class<T> clazz)

从类继承的方法 org.apache.calcite.prepare.Prepare.AbstractPreparingTable

columnHasDefaultValue, extend, getColumnStrategies

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.calcite.rel.metadata.MetadataHandler

handlerMethods

从接口继承的方法 org.apache.calcite.sql.validate.SqlValidatorTable

table

从接口继承的方法 org.apache.calcite.schema.Wrapper

maybeUnwrap, unwrapOrThrow

字段详细资料

catalogReader

protected final MockCatalogReader catalogReader

stream

protected final boolean stream

rowCount

protected final double rowCount

columnList

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

keyList

protected final List<Integer> keyList

referentialConstraints

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

rowType

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

collationList

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

names

protected final List<String> names

maxRowCount

protected final Double maxRowCount

monotonicColumnSet

protected final Set<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 Set<String> rolledUpColumns

wraps

protected List<Object> wraps

Wrapped objects that can be obtained by calling unwrap(Class). Initially an immutable list, but converted to a mutable array list on first assignment.

构造器详细资料

MockTable

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

MockTable

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

MockTable

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

Copy constructor.

方法详细资料

registerRolledUpColumn

public void registerRolledUpColumn(String columnName)

addWrap

public void addWrap(Object wrap)

getMaxRowCount

public @Nullable Double getMaxRowCount(org.apache.calcite.rel.RelNode r,
                                       org.apache.calcite.rel.metadata.RelMetadataQuery mq)

指定者:

getMaxRowCount 在接口中 org.apache.calcite.rel.metadata.BuiltInMetadata.MaxRowCount.Handler

getDef

public org.apache.calcite.rel.metadata.MetadataDef<org.apache.calcite.rel.metadata.BuiltInMetadata.MaxRowCount> getDef()

指定者:

getDef 在接口中 org.apache.calcite.rel.metadata.BuiltInMetadata.MaxRowCount.Handler

指定者:

getDef 在接口中 org.apache.calcite.rel.metadata.MetadataHandler<org.apache.calcite.rel.metadata.BuiltInMetadata.MaxRowCount>

extend

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

指定者:

extend 在类中 org.apache.calcite.prepare.Prepare.AbstractPreparingTable

create

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

create

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

create

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

create

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

create

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

create

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

create

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

unwrap

public <T> T unwrap(Class<T> clazz)

指定者:

unwrap 在接口中 org.apache.calcite.schema.Wrapper

getRowCount

public double getRowCount()

指定者:

getRowCount 在接口中 org.apache.calcite.plan.RelOptTable

getRelOptSchema

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

指定者:

getRelOptSchema 在接口中 org.apache.calcite.plan.RelOptTable

toRel

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

指定者:

toRel 在接口中 org.apache.calcite.plan.RelOptTable

getCollationList

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

指定者:

getCollationList 在接口中 org.apache.calcite.plan.RelOptTable

getDistribution

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

指定者:

getDistribution 在接口中 org.apache.calcite.plan.RelOptTable

isKey

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

指定者:

isKey 在接口中 org.apache.calcite.plan.RelOptTable

getKeys

public List<org.apache.calcite.util.ImmutableBitSet> getKeys()

指定者:

getKeys 在接口中 org.apache.calcite.plan.RelOptTable

getReferentialConstraints

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

指定者:

getReferentialConstraints 在接口中 org.apache.calcite.plan.RelOptTable

getRowType

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

指定者:

getRowType 在接口中 org.apache.calcite.plan.RelOptTable

指定者:

getRowType 在接口中 org.apache.calcite.sql.validate.SqlValidatorTable

supportsModality

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

指定者:

supportsModality 在接口中 org.apache.calcite.sql.validate.SqlValidatorTable

isTemporal

public boolean isTemporal()

指定者:

isTemporal 在接口中 org.apache.calcite.sql.validate.SqlValidatorTable

onRegister

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

getQualifiedName

public List<String> getQualifiedName()

指定者:

getQualifiedName 在接口中 org.apache.calcite.plan.RelOptTable

指定者:

getQualifiedName 在接口中 org.apache.calcite.sql.validate.SqlValidatorTable

getMonotonicity

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

指定者:

getMonotonicity 在接口中 org.apache.calcite.sql.validate.SqlValidatorTable

getAllowedAccess

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

指定者:

getAllowedAccess 在接口中 org.apache.calcite.sql.validate.SqlValidatorTable

getExpression

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

指定者:

getExpression 在接口中 org.apache.calcite.plan.RelOptTable

addColumn

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

addColumn

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

addMonotonic

public void addMonotonic(String name)

setKind

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

getKind

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