Class and Description |
---|
StreamTableSource
Defines an external stream table and provides read access to its data.
|
Class and Description |
---|
BatchTableSource
Deprecated.
use
InputFormatTableSource instead. |
LookupableTableSource
A
TableSource which supports for lookup accessing via key column(s). |
ProjectableTableSource
Adds support for projection push-down to a
TableSource . |
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
LookupableTableSource
A
TableSource which supports for lookup accessing via key column(s). |
ProjectableTableSource
Adds support for projection push-down to a
TableSource . |
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
LimitableTableSource
Adds support for limiting push-down to a
TableSource . |
LookupableTableSource
A
TableSource which supports for lookup accessing via key column(s). |
PartitionableTableSource
An interface for partitionable
TableSource . |
ProjectableTableSource
Adds support for projection push-down to a
TableSource . |
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
BatchTableSource
Deprecated.
use
InputFormatTableSource instead. |
FilterableTableSource
Adds support for filtering push-down to a
TableSource . |
ProjectableTableSource
Adds support for projection push-down to a
TableSource . |
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
BatchTableSource
Deprecated.
use
InputFormatTableSource instead. |
FilterableTableSource
Adds support for filtering push-down to a
TableSource . |
ProjectableTableSource
Adds support for projection push-down to a
TableSource . |
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
DefinedFieldMapping
The
DefinedFieldMapping interface provides a mapping for the fields of the table schema
(TableSource.getTableSchema() to fields of the physical produced data type TableSource.getProducedDataType() of a TableSource . |
DefinedRowtimeAttributes
Extends a
TableSource to specify rowtime attributes via a RowtimeAttributeDescriptor . |
InputFormatTableSource
Defines an external bounded table and provides access to its data.
|
RowtimeAttributeDescriptor
Describes a rowtime attribute of a
TableSource . |
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
DefinedFieldMapping
The
DefinedFieldMapping interface provides a mapping for the fields of the table schema
(TableSource.getTableSchema() to fields of the physical produced data type TableSource.getProducedDataType() of a TableSource . |
DefinedProctimeAttribute
Extends a
TableSource to specify a processing time attribute. |
DefinedRowtimeAttributes
Extends a
TableSource to specify rowtime attributes via a RowtimeAttributeDescriptor . |
RowtimeAttributeDescriptor
Describes a rowtime attribute of a
TableSource . |
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
RowtimeAttributeDescriptor
Describes a rowtime attribute of a
TableSource . |
Class and Description |
---|
BatchTableSource
Deprecated.
use
InputFormatTableSource instead. |
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
FilterableTableSource
Adds support for filtering push-down to a
TableSource . |
LimitableTableSource
Adds support for limiting push-down to a
TableSource . |
PartitionableTableSource
An interface for partitionable
TableSource . |
ProjectableTableSource
Adds support for projection push-down to a
TableSource . |
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
BatchTableSource
Deprecated.
use
InputFormatTableSource instead. |
CsvTableSource
A
StreamTableSource and BatchTableSource for simple CSV files with a (logically)
unlimited number of fields. |
CsvTableSource.Builder
A builder for creating CsvTableSource instances.
|
CsvTableSourceFactoryBase
Factory base for creating configured instances of
CsvTableSource . |
LookupableTableSource
A
TableSource which supports for lookup accessing via key column(s). |
ProjectableTableSource
Adds support for projection push-down to a
TableSource . |
RowtimeAttributeDescriptor
Describes a rowtime attribute of a
TableSource . |
StreamTableSource
Defines an external stream table and provides read access to its data.
|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Class and Description |
---|
FieldComputer
The
FieldComputer interface returns an expression to compute the field of the table
schema of a TableSource from one or more fields of the TableSource 's return type. |
Class and Description |
---|
TableSource
Defines an external table with the schema that is provided by
TableSource.getTableSchema() . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.