Modifier and Type | Class and Description |
---|---|
class |
HBaseUpsertTableSink
An upsert
UpsertStreamTableSink for HBase. |
Modifier and Type | Method and Description |
---|---|
TableSink<Tuple2<Boolean,Row>> |
HBaseUpsertTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
Modifier and Type | Class and Description |
---|---|
class |
JDBCAppendTableSink
An at-least-once Table sink for JDBC.
|
class |
JDBCUpsertTableSink
An upsert
UpsertStreamTableSink for JDBC. |
Modifier and Type | Method and Description |
---|---|
TableSink<Tuple2<Boolean,Row>> |
JDBCUpsertTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
TableSink<Row> |
JDBCAppendTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
Modifier and Type | Class and Description |
---|---|
class |
HiveTableSink
Table sink to write to Hive tables.
|
Modifier and Type | Method and Description |
---|---|
TableSink<Row> |
HiveTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
TableSink<Row> |
HiveTableFactory.createTableSink(Map<String,String> properties) |
TableSink<Row> |
HiveTableFactory.createTableSink(ObjectPath tablePath,
CatalogTable table) |
Modifier and Type | Class and Description |
---|---|
class |
CassandraAppendTableSink
An
AppendStreamTableSink to write an append stream Table to a Cassandra table. |
Modifier and Type | Class and Description |
---|---|
class |
ElasticsearchUpsertTableSinkBase
A version-agnostic Elasticsearch
UpsertStreamTableSink . |
Modifier and Type | Method and Description |
---|---|
TableSink<Tuple2<Boolean,Row>> |
ElasticsearchUpsertTableSinkBase.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
Modifier and Type | Class and Description |
---|---|
class |
Elasticsearch6UpsertTableSink
Version-specific upsert table sink for Elasticsearch 6.
|
Modifier and Type | Class and Description |
---|---|
class |
Kafka010TableSink
Kafka 0.10 table sink for writing data into Kafka.
|
class |
Kafka011TableSink
Kafka 0.11 table sink for writing data into Kafka.
|
class |
Kafka08TableSink
Kafka 0.8 table sink for writing data into Kafka.
|
class |
Kafka09TableSink
Kafka 0.9 table sink for writing data into Kafka.
|
class |
KafkaTableSink
Kafka table sink for writing data into Kafka.
|
class |
KafkaTableSinkBase
A version-agnostic Kafka
AppendStreamTableSink . |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironment.registerTableSink(String name,
String[] fieldNames,
TypeInformation<?>[] fieldTypes,
TableSink<?> tableSink)
Deprecated.
|
void |
TableEnvironment.registerTableSink(String name,
TableSink<?> configuredSink)
Registers an external
TableSink with already configured field names and field types in
this TableEnvironment 's catalog. |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironmentImpl.registerTableSink(String name,
String[] fieldNames,
TypeInformation<?>[] fieldTypes,
TableSink<?> tableSink) |
void |
TableEnvironmentImpl.registerTableSink(String name,
TableSink<?> configuredSink) |
Modifier and Type | Method and Description |
---|---|
Optional<TableSink<T2>> |
ConnectorCatalogTable.getTableSink() |
Modifier and Type | Method and Description |
---|---|
static <T2> ConnectorCatalogTable |
ConnectorCatalogTable.sink(TableSink<T2> sink,
boolean isBatch) |
static <T1,T2> ConnectorCatalogTable |
ConnectorCatalogTable.sourceAndSink(TableSource<T1> source,
TableSink<T2> sink,
boolean isBatch) |
Constructor and Description |
---|
ConnectorCatalogTable(TableSource<T1> tableSource,
TableSink<T2> tableSink,
TableSchema tableSchema,
boolean isBatch) |
Modifier and Type | Class and Description |
---|---|
class |
CollectBatchTableSink
Table sink for collecting the results locally all at once using accumulators.
|
class |
CollectStreamTableSink
Table sink for collecting the results locally using sockets.
|
Modifier and Type | Method and Description |
---|---|
Map<String,TableSink<?>> |
ExecutionContext.getTableSinks() |
Modifier and Type | Method and Description |
---|---|
TableSink<?> |
CollectStreamResult.getTableSink() |
TableSink<?> |
DynamicResult.getTableSink()
Returns the table sink required by this result type.
|
TableSink<?> |
MaterializedCollectBatchResult.getTableSink() |
Modifier and Type | Method and Description |
---|---|
default TableSink<T> |
StreamTableSinkFactory.createTableSink(Map<String,String> properties)
Only create stream table sink.
|
default TableSink<T> |
BatchTableSinkFactory.createTableSink(Map<String,String> properties)
Only create batch table sink.
|
TableSink<T> |
TableSinkFactory.createTableSink(Map<String,String> properties)
Creates and configures a
TableSink using the given properties. |
default TableSink<T> |
TableSinkFactory.createTableSink(ObjectPath tablePath,
CatalogTable table)
Creates and configures a
TableSink based on the given CatalogTable instance. |
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(CatalogTable table)
Returns a table sink matching the
CatalogTable . |
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(Descriptor descriptor)
Returns a table sink matching the descriptor.
|
Modifier and Type | Method and Description |
---|---|
static Optional<TableSink> |
TableFactoryUtil.createTableSinkForCatalogTable(Catalog catalog,
CatalogTable catalogTable,
ObjectPath tablePath)
Creates a table sink for a
CatalogTable using table factory associated with the catalog. |
Modifier and Type | Method and Description |
---|---|
TableSink<T> |
UnregisteredSinkModifyOperation.getSink() |
Constructor and Description |
---|
UnregisteredSinkModifyOperation(TableSink<T> sink,
QueryOperation child) |
Modifier and Type | Interface and Description |
---|---|
interface |
AppendStreamTableSink<T>
|
interface |
BatchTableSink<T>
Deprecated.
use
OutputFormatTableSink instead. |
interface |
RetractStreamTableSink<T>
|
interface |
StreamTableSink<T>
Defines an external stream table and provides write access to its data.
|
interface |
UpsertStreamTableSink<T>
|
Modifier and Type | Class and Description |
---|---|
class |
CsvTableSink
A simple
TableSink to emit data as CSV files. |
class |
OutputFormatTableSink<T>
|
class |
TableSinkBase<T>
Base class for
TableSink . |
Modifier and Type | Method and Description |
---|---|
TableSink<Row> |
CsvTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
TableSink<T> |
TableSinkBase.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Returns a copy of this
TableSink configured with the field names and types of the
table to emit. |
TableSink<T> |
TableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Deprecated.
This method will be dropped in future versions. It is recommended to pass a
static schema when instantiating the sink instead.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.