Package org.apache.calcite.adapter.csv

Class CsvFilterableTable

java.lang.Object

org.apache.calcite.schema.impl.AbstractTable

org.apache.calcite.adapter.csv.CsvTable

org.apache.calcite.adapter.csv.CsvFilterableTable

All Implemented Interfaces:

FilterableTable, Table, Wrapper

public class CsvFilterableTable
extends CsvTable
implements FilterableTable

Table based on a CSV file that can implement simple filtering.

It implements the FilterableTable interface, so Calcite gets data by calling the scan(DataContext, List) method.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.calcite.adapter.csv.CsvTable

CsvTable.Flavor

Field Summary

Fields inherited from class org.apache.calcite.adapter.csv.CsvTable

protoRowType, source

Constructor Summary

Constructors

Constructor	Description
CsvFilterableTable(Source source, RelProtoDataType protoRowType)	Creates a CsvFilterableTable.

Method Summary

Modifier and Type	Method	Description
Enumerable<@Nullable Object[]>	scan(DataContext root, List<RexNode> filters)	Returns an enumerator over the rows in this Table.
String	toString()

Methods inherited from class org.apache.calcite.adapter.csv.CsvTable

getFieldTypes, getRowType, isStream

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, getRowType, getStatistic, isRolledUp, rolledUpColumnValidInsideAgg

Methods inherited from interface org.apache.calcite.schema.Wrapper

maybeUnwrap, unwrapOrThrow

Constructor Details

CsvFilterableTable

public CsvFilterableTable(Source source,
 RelProtoDataType protoRowType)

Creates a CsvFilterableTable.

Method Details

toString

public String toString()

Overrides:

toString in class Object

scan

public Enumerable<@Nullable Object[]> scan(DataContext root,
 List<RexNode> filters)

Description copied from interface: FilterableTable

Returns an enumerator over the rows in this Table. Each row is represented as an array of its column values.

The list of filters is mutable. If the table can implement a particular filter, it should remove that filter from the list. If it cannot implement a filter, it should leave it in the list. Any filters remaining will be implemented by the consuming Calcite operator.

Specified by:

scan in interface FilterableTable