org.apache.flink.table.connector

Interface ProviderContext

All Known Subinterfaces:

TransformationSinkProvider.Context

@PublicEvolving
public interface ProviderContext

Context provided by some ScanTableSource.ScanRuntimeProvider and DynamicTableSink.SinkRuntimeProvider with utilities for generating the runtime implementation.

Method Summary

Modifier and Type	Method and Description
Optional<String>	generateUid(String name) Generates a new unique identifier for a Transformation/DataStream operator.

Method Detail

generateUid

Optional<String> generateUid(String name)

Generates a new unique identifier for a Transformation/DataStream operator. The name must be unique within the provider implementation. The framework will make sure that the name is unique for the entire topology.

This method returns empty if an identifier cannot be generated, i.e., because the job is in batch mode, or UIDs cannot be guaranteed to be unique.