Package org.apache.calcite.adapter.cassandra

Class CassandraTable

java.lang.Object

org.apache.calcite.schema.impl.AbstractTable

org.apache.calcite.adapter.java.AbstractQueryableTable

org.apache.calcite.adapter.cassandra.CassandraTable

All Implemented Interfaces:

QueryableTable, Table, TranslatableTable, Wrapper

public class CassandraTable
extends AbstractQueryableTable
implements TranslatableTable

Table based on a Cassandra column family.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CassandraTable.CassandraQueryable<T>	Implementation of Queryable based on a CassandraTable.

Field Summary

Fields inherited from class org.apache.calcite.adapter.java.AbstractQueryableTable

elementType

Constructor Summary

Constructors

Constructor	Description
CassandraTable(CassandraSchema schema, String columnFamily)	Deprecated.
CassandraTable(CassandraSchema schema, String columnFamily, boolean isView)	Deprecated.
CassandraTable(CassandraSchema schema, String keyspace, String columnFamily)
CassandraTable(CassandraSchema schema, String keyspace, String columnFamily, boolean isView)

Method Summary

Modifier and Type	Method	Description
<T> Queryable<T>	asQueryable(QueryProvider queryProvider, SchemaPlus schema, String tableName)	Converts this table into a Queryable.
List<String>	getClusteringKeys()
List<RelFieldCollation>	getClusteringOrder()
List<String>	getPartitionKeys()
RelDataType	getRowType(RelDataTypeFactory typeFactory)	Returns this table's row type.
Enumerable<Object>	query(com.datastax.oss.driver.api.core.CqlSession session)
Enumerable<Object>	query(com.datastax.oss.driver.api.core.CqlSession session, List<Map.Entry<String,Class>> fields, List<Map.Entry<String,String>> selectFields, List<String> predicates, List<String> order, Integer offset, Integer fetch)	Executes a CQL query on the underlying table.
RelNode	toRel(RelOptTable.ToRelContext context, RelOptTable relOptTable)	Converts this table into a relational expression.
String	toString()

Methods inherited from class org.apache.calcite.adapter.java.AbstractQueryableTable

getElementType, getExpression

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

CassandraTable

@Deprecated
public CassandraTable(CassandraSchema schema,
 String columnFamily,
 boolean isView)

Deprecated.

CassandraTable

public CassandraTable(CassandraSchema schema,
 String keyspace,
 String columnFamily,
 boolean isView)

CassandraTable

@Deprecated
public CassandraTable(CassandraSchema schema,
 String columnFamily)

Deprecated.

CassandraTable

public CassandraTable(CassandraSchema schema,
 String keyspace,
 String columnFamily)

Method Details

toString

public String toString()

Overrides:

toString in class Object

getRowType

public RelDataType getRowType(RelDataTypeFactory typeFactory)

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 interface Table

Parameters:

typeFactory - Type factory with which to create the type

Returns:

Row type

getPartitionKeys

public List<String> getPartitionKeys()

getClusteringKeys

public List<String> getClusteringKeys()

getClusteringOrder

public List<RelFieldCollation> getClusteringOrder()

query

public Enumerable<Object> query(com.datastax.oss.driver.api.core.CqlSession session)

query

public Enumerable<Object> query(com.datastax.oss.driver.api.core.CqlSession session,
 List<Map.Entry<String,Class>> fields,
 List<Map.Entry<String,String>> selectFields,
 List<String> predicates,
 List<String> order,
 Integer offset,
 Integer fetch)

Executes a CQL query on the underlying table.

Parameters:

session - Cassandra session

fields - List of fields to project

predicates - A list of predicates which should be used in the query

Returns:

Enumerator of results

asQueryable

public <T> Queryable<T> asQueryable(QueryProvider queryProvider,
 SchemaPlus schema,
 String tableName)

Description copied from interface: QueryableTable

Converts this table into a Queryable.

Specified by:

asQueryable in interface QueryableTable

toRel

public RelNode toRel(RelOptTable.ToRelContext context,
 RelOptTable relOptTable)

Description copied from interface: TranslatableTable

Converts this table into a relational expression.

Specified by:

toRel in interface TranslatableTable