Modifier and Type | Class and Description |
---|---|
class |
JdbcUpsertTableSink
An upsert
UpsertStreamTableSink for JDBC. |
Modifier and Type | Method and Description |
---|---|
TableSink<Tuple2<Boolean,Row>> |
JdbcUpsertTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes) |
Modifier and Type | Method and Description |
---|---|
TableSink |
HiveTableFactory.createTableSink(TableSinkFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
CassandraAppendTableSink
An
AppendStreamTableSink to write an append stream Table to a Cassandra table. |
Modifier and Type | Method and Description |
---|---|
void |
TableEnvironmentImpl.registerTableSinkInternal(String name,
TableSink<?> tableSink) |
void |
TableEnvironmentInternal.registerTableSinkInternal(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 |
---|---|
Optional<TableSink<T2>> |
ConnectorCatalogTable.getTableSink() |
Modifier and Type | Method and Description |
---|---|
static <T2> ConnectorCatalogTable<?,T2> |
ConnectorCatalogTable.sink(TableSink<T2> sink,
boolean isBatch) |
static <T1,T2> ConnectorCatalogTable<T1,T2> |
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 | Method and Description |
---|---|
default TableSink<T> |
StreamTableSinkFactory.createTableSink(Map<String,String> properties)
Deprecated.
Only create stream table sink.
|
default TableSink<T> |
TableSinkFactory.createTableSink(Map<String,String> properties)
Deprecated.
TableSinkFactory.Context contains more information, and already contains table schema too.
Please use TableSinkFactory.createTableSink(Context) instead. |
default TableSink<T> |
TableSinkFactory.createTableSink(ObjectPath tablePath,
CatalogTable table)
Deprecated.
TableSinkFactory.Context contains more information, and already contains table schema too.
Please use TableSinkFactory.createTableSink(Context) instead. |
default TableSink<T> |
TableSinkFactory.createTableSink(TableSinkFactory.Context context)
Creates and configures a
TableSink based on the given TableSinkFactory.Context . |
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(Catalog catalog,
ObjectIdentifier objectIdentifier,
CatalogTable catalogTable,
ReadableConfig configuration,
boolean isStreamingMode,
boolean isTemporary)
Creates a
TableSink from a CatalogTable . |
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(TableSinkFactory.Context context)
Returns a table sink matching the context.
|
Modifier and Type | Method and Description |
---|---|
static Optional<TableSink> |
TableFactoryUtil.createTableSinkForCatalogTable(Catalog catalog,
TableSinkFactory.Context context)
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) |
Constructor and Description |
---|
BatchExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
InputProperty inputProperty,
LogicalType outputType,
String description) |
Modifier and Type | Field and Description |
---|---|
protected TableSink<T> |
CommonExecLegacySink.tableSink |
Constructor and Description |
---|
CommonExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
boolean isStreaming,
InputProperty inputProperty,
LogicalType outputType,
String description) |
Constructor and Description |
---|
StreamExecLegacySink(TableSink<T> tableSink,
String[] upsertKeys,
boolean needRetraction,
InputProperty inputProperty,
LogicalType outputType,
String description) |
Modifier and Type | Interface and Description |
---|---|
interface |
AppendStreamTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures. See FLIP-95 for more information. |
interface |
RetractStreamTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures. See FLIP-95 for more information. |
interface |
StreamTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures. See FLIP-95 for more information. |
interface |
UpsertStreamTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures. See FLIP-95 for more information. |
Modifier and Type | Class and Description |
---|---|
class |
CsvTableSink
Deprecated.
The legacy CSV connector has been replaced by
FileSink . It is kept only to
support tests for the legacy connector stack. |
class |
OutputFormatTableSink<T>
Deprecated.
This interface has been replaced by
DynamicTableSink . The new interface
consumes internal data structures. See FLIP-95 for more information. |
class |
TableSinkBase<T>
Base class for
TableSink . |
Modifier and Type | Method and Description |
---|---|
TableSink<Row> |
CsvTableSink.configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Deprecated.
|
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–2023 The Apache Software Foundation. All rights reserved.