Modifier and Type | Class and Description |
---|---|
class |
AsyncDynamicTableSinkFactory
Abstract Implementation of
DynamicTableSinkFactory having AsyncSinkBase fields as
optional table options defined in AsyncSinkConnectorOptions . |
Modifier and Type | Class and Description |
---|---|
class |
BlackHoleTableSinkFactory
Black hole table sink factory swallowing all input records.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSystemTableFactory
File system
TableFactory . |
Modifier and Type | Class and Description |
---|---|
class |
PrintTableSinkFactory
Print table sink factory writing every row to the standard output or standard error stream.
|
Modifier and Type | Class and Description |
---|---|
class |
UpsertTestDynamicTableSinkFactory
A
DynamicTableSinkFactory for discovering UpsertTestDynamicTableSink . |
Modifier and Type | Class and Description |
---|---|
class |
HiveDynamicTableFactory
A dynamic table factory implementation for Hive catalog.
|
Modifier and Type | Method and Description |
---|---|
static DynamicTableSink |
FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory preferredFactory,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
Map<String,String> enrichmentOptions,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
static DynamicTableSink |
FactoryUtil.createDynamicTableSink(DynamicTableSinkFactory preferredFactory,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
|
Modifier and Type | Class and Description |
---|---|
class |
TestFileSystemTableFactory
Test filesystem
Factory . |
Modifier and Type | Method and Description |
---|---|
default Optional<DynamicTableSinkFactory> |
Module.getTableSinkFactory()
Returns a
DynamicTableSinkFactory for creating sink tables. |
Modifier and Type | Method and Description |
---|---|
static DynamicTableSink |
ExecutableOperationUtils.createDynamicTableSink(Catalog catalog,
Supplier<Optional<DynamicTableSinkFactory>> sinkFactorySupplier,
ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
Map<String,String> enrichmentOptions,
ReadableConfig configuration,
ClassLoader classLoader,
boolean isTemporary)
Creates a
DynamicTableSink from a CatalogTable . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.