Constructor and Description |
---|
TableStoreSink(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
FileStoreTable table,
org.apache.flink.table.factories.DynamicTableFactory.Context context,
LogStoreTableFactory logStoreTableFactory) |
Constructor and Description |
---|
TableStoreSource(org.apache.flink.table.catalog.ObjectIdentifier tableIdentifier,
FileStoreTable table,
boolean streaming,
org.apache.flink.table.factories.DynamicTableFactory.Context context,
LogStoreTableFactory logStoreTableFactory) |
Modifier and Type | Class and Description |
---|---|
class |
KafkaLogStoreFactory
The Kafka
LogStoreTableFactory implementation. |
Modifier and Type | Method and Description |
---|---|
static LogStoreTableFactory |
LogStoreTableFactory.discoverLogStoreFactory(ClassLoader cl,
String identifier) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.