public class UpdatedDataFieldsProcessFunction extends UpdatedDataFieldsProcessFunctionBase<List<DataField>,Void>
ProcessFunction
to handle schema changes. New schema is represented by a list of DataField
s.
NOTE: To avoid concurrent schema changes, the parallelism of this ProcessFunction
must
be 1.
UpdatedDataFieldsProcessFunctionBase.ConvertAction
catalog, catalogLoader
Constructor and Description |
---|
UpdatedDataFieldsProcessFunction(SchemaManager schemaManager,
Identifier identifier,
Catalog.Loader catalogLoader) |
Modifier and Type | Method and Description |
---|---|
void |
processElement(List<DataField> updatedDataFields,
org.apache.flink.streaming.api.functions.ProcessFunction.Context context,
org.apache.flink.util.Collector<Void> collector) |
applySchemaChange, canConvert, close, extractSchemaChanges, open
getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public UpdatedDataFieldsProcessFunction(SchemaManager schemaManager, Identifier identifier, Catalog.Loader catalogLoader)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.