Interface TransformationSinkProvider

    • Method Detail

      • createTransformation

        Transformation<?> createTransformation​(TransformationSinkProvider.Context context)
        Creates a transformation for transforming the input provided in the context.

        Note: If the CompiledPlan feature should be supported, this method MUST set a unique identifier for each transformation/operator in the data stream. This enables stateful Flink version upgrades for streaming jobs. The identifier is used to map state back from a savepoint to an actual operator in the topology. The framework can generate topology-wide unique identifiers with ProviderContext.generateUid(String).

        See Also:
        Transformation.setUid(String)