public class TableStoreConnectorFactory extends AbstractTableStoreFactory
DynamicTableFactory
to create source and sink.Constructor and Description |
---|
TableStoreConnectorFactory() |
TableStoreConnectorFactory(CatalogLock.Factory lockFactory) |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.table.connector.sink.DynamicTableSink |
createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context) |
org.apache.flink.table.connector.source.DynamicTableSource |
createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context) |
String |
factoryIdentifier() |
optionalOptions, requiredOptions
public TableStoreConnectorFactory()
public TableStoreConnectorFactory(@Nullable CatalogLock.Factory lockFactory)
public String factoryIdentifier()
public org.apache.flink.table.connector.source.DynamicTableSource createDynamicTableSource(org.apache.flink.table.factories.DynamicTableFactory.Context context)
createDynamicTableSource
in interface org.apache.flink.table.factories.DynamicTableSourceFactory
createDynamicTableSource
in class AbstractTableStoreFactory
public org.apache.flink.table.connector.sink.DynamicTableSink createDynamicTableSink(org.apache.flink.table.factories.DynamicTableFactory.Context context)
createDynamicTableSink
in interface org.apache.flink.table.factories.DynamicTableSinkFactory
createDynamicTableSink
in class AbstractTableStoreFactory
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.