Class GeodeSimpleScannableTable
java.lang.Object
org.apache.calcite.schema.impl.AbstractTable
org.apache.calcite.adapter.geode.simple.GeodeSimpleScannableTable
- All Implemented Interfaces:
ScannableTable
,Table
,Wrapper
Geode Simple Scannable Table abstraction.
-
Constructor Summary
ConstructorDescriptionGeodeSimpleScannableTable
(String regionName, RelDataType relDataType, org.apache.geode.cache.client.ClientCache clientCache) -
Method Summary
Modifier and TypeMethodDescriptiongetRowType
(RelDataTypeFactory typeFactory) Returns this table's row type.Enumerable<@Nullable Object[]>
scan
(DataContext root) Returns an enumerator over the rows in this Table.toString()
Methods inherited from class org.apache.calcite.schema.impl.AbstractTable
getJdbcTableType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg, unwrap
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface org.apache.calcite.schema.Table
getJdbcTableType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg
Methods inherited from interface org.apache.calcite.schema.Wrapper
maybeUnwrap, unwrapOrThrow
-
Constructor Details
-
GeodeSimpleScannableTable
public GeodeSimpleScannableTable(String regionName, RelDataType relDataType, org.apache.geode.cache.client.ClientCache clientCache)
-
-
Method Details
-
toString
-
getRowType
Description copied from interface:Table
Returns this table's row type.This is a struct type whose fields describe the names and types of the columns in this table.
The implementer must use the type factory provided. This ensures that the type is converted into a canonical form; other equal types in the same query will use the same object.
- Specified by:
getRowType
in interfaceTable
- Parameters:
typeFactory
- Type factory with which to create the type- Returns:
- Row type
-
scan
Description copied from interface:ScannableTable
Returns an enumerator over the rows in this Table. Each row is represented as an array of its column values.- Specified by:
scan
in interfaceScannableTable
-