Class GeodeSchema
- java.lang.Object
-
- org.apache.calcite.schema.impl.AbstractSchema
-
- org.apache.calcite.adapter.geode.rel.GeodeSchema
-
- All Implemented Interfaces:
Schema
public class GeodeSchema extends AbstractSchema
Schema mapped onto a Geode Region.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.calcite.schema.impl.AbstractSchema
AbstractSchema.Factory
-
Nested classes/interfaces inherited from interface org.apache.calcite.schema.Schema
Schema.TableType
-
-
Field Summary
Fields Modifier and Type Field Description (package private) org.apache.geode.cache.GemFireCache
cache
private java.util.List<java.lang.String>
regionNames
private com.google.common.collect.ImmutableMap<java.lang.String,Table>
tableMap
-
Constructor Summary
Constructors Constructor Description GeodeSchema(java.lang.String locatorHost, int locatorPort, java.lang.Iterable<java.lang.String> regionNames, java.lang.String pdxAutoSerializerPackageExp)
GeodeSchema(org.apache.geode.cache.GemFireCache cache, java.lang.Iterable<java.lang.String> regionNames)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected java.util.Map<java.lang.String,Table>
getTableMap()
Returns a map of tables in this schema by name.-
Methods inherited from class org.apache.calcite.schema.impl.AbstractSchema
getExpression, getFunctionMultimap, getFunctionNames, getFunctions, getSubSchema, getSubSchemaMap, getSubSchemaNames, getTable, getTableNames, getType, getTypeMap, getTypeNames, isMutable, snapshot
-
-
-
-
Field Detail
-
cache
final org.apache.geode.cache.GemFireCache cache
-
regionNames
private final java.util.List<java.lang.String> regionNames
-
tableMap
private com.google.common.collect.ImmutableMap<java.lang.String,Table> tableMap
-
-
Constructor Detail
-
GeodeSchema
GeodeSchema(java.lang.String locatorHost, int locatorPort, java.lang.Iterable<java.lang.String> regionNames, java.lang.String pdxAutoSerializerPackageExp)
-
GeodeSchema
GeodeSchema(org.apache.geode.cache.GemFireCache cache, java.lang.Iterable<java.lang.String> regionNames)
-
-
Method Detail
-
getTableMap
protected java.util.Map<java.lang.String,Table> getTableMap()
Description copied from class:AbstractSchema
Returns a map of tables in this schema by name.The implementations of
AbstractSchema.getTableNames()
andAbstractSchema.getTable(String)
depend on this map. The default implementation of this method returns the empty map. Override this method to change their behavior.- Overrides:
getTableMap
in classAbstractSchema
- Returns:
- Map of tables in this schema by name
-
-