Modifier and Type | Class and Description |
---|---|
class |
JDBCAppendTableSink
An at-least-once Table sink for JDBC.
|
Modifier and Type | Method and Description |
---|---|
TableSink<Row> |
JDBCAppendTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
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 | 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 |
---|---|
TableSink<Row> |
CollectBatchTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
TableSink<Tuple2<Boolean,Row>> |
CollectStreamTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
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 | Class and Description |
---|---|
class |
TableSinkBase<T>
Base class for
TableSink . |
Modifier and Type | Method and Description |
---|---|
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)
Returns a copy of this
TableSink configured with the field names and types of the
table to emit. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.