Package org.apache.calcite.adapter.arrow

Class ArrowTable

java.lang.Object

org.apache.calcite.schema.impl.AbstractTable

org.apache.calcite.adapter.arrow.ArrowTable

All Implemented Interfaces:

QueryableTable, Table, TranslatableTable, Wrapper

public class ArrowTable
extends AbstractTable
implements TranslatableTable, QueryableTable

Table backed by an Apache Arrow file.

Reads data from an Arrow IPC file on disk and supports projection and filter push-down via the Gandiva expression compiler.

Implements TranslatableTable so that it can be converted into an ArrowTableScan for query planning, and QueryableTable so that it can be used via the org.apache.calcite.linq4j API.

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method	Description
<T> Queryable<T>	asQueryable(QueryProvider queryProvider, SchemaPlus schema, String tableName)	Converts this table into a Queryable.
Type	getElementType()	Returns the element type of the collection that will implement this table.
Expression	getExpression(SchemaPlus schema, String tableName, Class clazz)	Generates an expression with which this table can be referenced in generated code.
RelDataType	getRowType(RelDataTypeFactory typeFactory)	Returns this table's row type.
Enumerable<Object>	query(DataContext root, ImmutableIntList fields, List<List<List<String>>> conditions)	Called via code generation; see uses of ArrowMethod.ARROW_QUERY.
RelNode	toRel(RelOptTable.ToRelContext context, RelOptTable relOptTable)	Converts this table into a relational expression.

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, toString, 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

Method Details

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

getExpression

public Expression getExpression(SchemaPlus schema,
 String tableName,
 Class clazz)

Description copied from interface: QueryableTable

Generates an expression with which this table can be referenced in generated code.

Specified by:

getExpression in interface QueryableTable

Parameters:

schema - Schema

tableName - Table name (unique within schema)

clazz - The desired collection class; for example Queryable.

query

public Enumerable<Object> query(DataContext root,
 ImmutableIntList fields,
 List<List<List<String>>> conditions)

Called via code generation; see uses of ArrowMethod.ARROW_QUERY.

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

getElementType

public Type getElementType()

Description copied from interface: QueryableTable

Returns the element type of the collection that will implement this table.

Specified by:

getElementType 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