THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
/**
* Base interface for all kinds of formats.
*/
public interface FormatFactory extends Factory {
/**
* Determines the changelog mode for this format.
*/
ChangelogMode createChangelogModederiveChangelogMode(DynamicTableFactory.Context tableContext);
}
/**
* Factory for creating a {@link DeserializationSchema} that returns internal data structures.
*/
public interface DeserializationFormatFactory extends FormatFactory {
/**
* Creates {@link DeserializationSchema} for the given produced {@link DataType} considering all
* contextual information.
*/
DeserializationSchema<RowData> createDeserializationFormatcreateDeserializationSchema(
DynamicTableFactory.Context tableContext,
ScanTableSource.Context runtimeContext,
DataType producedDataType);
}
...