Package org.apache.calcite.adapter.cassandra

Class CassandraSchema

java.lang.Object

org.apache.calcite.schema.impl.AbstractSchema

org.apache.calcite.adapter.cassandra.CassandraSchema

All Implemented Interfaces:

Schema

public class CassandraSchema
extends AbstractSchema

Schema mapped onto a Cassandra column family.

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
protected static final org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Constructor	Description
CassandraSchema(com.datastax.oss.driver.api.core.CqlSession session, SchemaPlus parentSchema, String name)	Creates a Cassandra schema.
CassandraSchema(com.datastax.oss.driver.api.core.CqlSession session, SchemaPlus parentSchema, String keyspace, String name)	Creates a Cassandra schema.

Method Summary

Modifier and Type	Method	Description
List<RelFieldCollation>	getClusteringOrder(String columnFamily, boolean isView)	Get the collation of all clustering key columns.
protected Map<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, subSchemas, tables

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Details

CassandraSchema

public CassandraSchema(com.datastax.oss.driver.api.core.CqlSession session,
 SchemaPlus parentSchema,
 String name)

Creates a Cassandra schema.

Parameters:

session - a Cassandra session

parentSchema - the parent schema

name - the schema name

CassandraSchema

public CassandraSchema(com.datastax.oss.driver.api.core.CqlSession session,
 SchemaPlus parentSchema,
 String keyspace,
 String name)

Creates a Cassandra schema.

Parameters:

session - a Cassandra session

parentSchema - the parent schema

keyspace - the keyspace name

name - the schema name

Method Details

getClusteringOrder

public List<RelFieldCollation> getClusteringOrder(String columnFamily,
 boolean isView)

Get the collation of all clustering key columns.

Returns:

A RelCollations representing the collation of all clustering keys

getTableMap

protected Map<String,Table> getTableMap()

Description copied from class: AbstractSchema

Returns a map of tables in this schema by name.

The implementations of AbstractSchema.getTableNames() and AbstractSchema.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 class AbstractSchema

Returns:

Map of tables in this schema by name