Package | Description |
---|---|
org.apache.flink.table.client.gateway.local | |
org.apache.flink.table.factories | |
org.apache.flink.table.sinks |
Modifier and Type | Class and Description |
---|---|
class |
CollectBatchTableSink
Table sink for collecting the results locally all at once using accumulators.
|
Modifier and Type | Method and Description |
---|---|
BatchTableSink<T> |
BatchTableSinkFactory.createBatchTableSink(Map<String,String> properties)
Creates and configures a
BatchTableSink using the given properties. |
Modifier and Type | Class and Description |
---|---|
class |
BatchSelectTableSink
A
SelectTableSink for batch select job. |
class |
CsvTableSink
A simple
TableSink to emit data as CSV files. |
Modifier and Type | Method and Description |
---|---|
BatchTableSink<Row> |
CsvBatchTableSinkFactory.createBatchTableSink(Map<String,String> properties) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.