Package org.apache.calcite.adapter.csv

Class CsvStreamScannableTable

java.lang.Object

org.apache.calcite.schema.impl.AbstractTable

org.apache.calcite.adapter.csv.CsvTable

org.apache.calcite.adapter.csv.CsvScannableTable

org.apache.calcite.adapter.csv.CsvStreamScannableTable

All Implemented Interfaces:

ScannableTable, StreamableTable, Table, Wrapper

public class CsvStreamScannableTable
extends CsvScannableTable
implements StreamableTable

Table based on a CSV file.

It implements the ScannableTable interface, so Calcite gets data by calling the scan(DataContext) 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

fieldTypes, protoRowType, source

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
RelDataType	getRowType(RelDataTypeFactory typeFactory)	Returns this table's row type.
Enumerable<java.lang.Object[]>	scan(DataContext root)	Returns an enumerator over the rows in this Table.
Table	stream()	Returns an enumerator over the rows in this Table.
java.lang.String	toString()

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

Constructor Detail

CsvStreamScannableTable

CsvStreamScannableTable(Source source,
                        RelProtoDataType protoRowType)

Creates a CsvScannableTable.

Method Detail

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

Overrides:

getRowType in class CsvTable

Parameters:

typeFactory - Type factory with which to create the type

Returns:

Row type

toString

public java.lang.String toString()

Overrides:

toString in class CsvScannableTable

scan

public Enumerable<java.lang.Object[]> scan(DataContext root)

Description copied from interface: ScannableTable

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

Specified by:

scan in interface ScannableTable

Overrides:

scan in class CsvScannableTable

stream

public Table stream()

Description copied from interface: StreamableTable

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

Specified by:

stream in interface StreamableTable