@Internal public class TestFileSystemTableFactory extends FileSystemTableFactory
Factory
.DynamicTableFactory.Context
Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
Constructor and Description |
---|
TestFileSystemTableFactory() |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
createDynamicTableSink(DynamicTableFactory.Context context)
Creates a
DynamicTableSink instance from a CatalogTable and additional
context information. |
DynamicTableSource |
createDynamicTableSource(DynamicTableFactory.Context context)
Creates a
DynamicTableSource instance from a CatalogTable and additional
context information. |
String |
factoryIdentifier()
Returns a unique identifier among same factory interfaces.
|
discoverDecodingFormat, forwardOptions, optionalOptions, requiredOptions, validate
public static final String IDENTIFIER
public String factoryIdentifier()
Factory
For consistency, an identifier should be declared as one lower case word (e.g. kafka
). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. elasticsearch-7
).
factoryIdentifier
in interface Factory
factoryIdentifier
in class FileSystemTableFactory
public DynamicTableSource createDynamicTableSource(DynamicTableFactory.Context context)
DynamicTableSourceFactory
DynamicTableSource
instance from a CatalogTable
and additional
context information.
An implementation should perform validation and the discovery of further (nested) factories in this method.
createDynamicTableSource
in interface DynamicTableSourceFactory
createDynamicTableSource
in class FileSystemTableFactory
public DynamicTableSink createDynamicTableSink(DynamicTableFactory.Context context)
DynamicTableSinkFactory
DynamicTableSink
instance from a CatalogTable
and additional
context information.
An implementation should perform validation and the discovery of further (nested) factories in this method.
createDynamicTableSink
in interface DynamicTableSinkFactory
createDynamicTableSink
in class FileSystemTableFactory
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.