Package | Description |
---|---|
org.apache.flink.connectors.hive | |
org.apache.flink.table.factories |
Modifier and Type | Method and Description |
---|---|
TableSink |
HiveTableFactory.createTableSink(TableSinkFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
TableSinkFactoryContextImpl
Implementation of
TableSinkFactory.Context . |
Modifier and Type | Method and Description |
---|---|
default TableSink<T> |
TableSinkFactory.createTableSink(TableSinkFactory.Context context)
Creates and configures a
TableSink based on the given TableSinkFactory.Context . |
static Optional<TableSink> |
TableFactoryUtil.createTableSinkForCatalogTable(Catalog catalog,
TableSinkFactory.Context context)
Creates a table sink for a
CatalogTable using table factory associated with the
catalog. |
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(TableSinkFactory.Context context)
Returns a table sink matching the context.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.