Package org.apache.flink.table.connector.sink.legacy

Interface SinkFunctionProvider

  • All Superinterfaces:
    org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider, org.apache.flink.table.connector.ParallelismProvider
    @Internal
public interface SinkFunctionProvider
extends org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider, org.apache.flink.table.connector.ParallelismProvider
    Deprecated.
    This interface is based on the SinkFunction API, which is due to be removed. Use SinkV2Provider instead.
    Provider of a SinkFunction instance as a runtime implementation for DynamicTableSink.

    • Method Summary

      All Methods Static Methods Instance Methods Abstract Methods Deprecated Methods 
      Modifier and Type Method Description
      org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<org.apache.flink.table.data.RowData> createSinkFunction()
      Deprecated.
      Creates a SinkFunction instance.
      static SinkFunctionProvider of​(org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<org.apache.flink.table.data.RowData> sinkFunction)
      Deprecated.
      Helper method for creating a static provider.
      static SinkFunctionProvider of​(org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<org.apache.flink.table.data.RowData> sinkFunction, Integer sinkParallelism)
      Deprecated.
      Helper method for creating a SinkFunction provider with a provided sink parallelism.

      • Methods inherited from interface org.apache.flink.table.connector.ParallelismProvider

        getParallelism

    • Method Detail

      • of

        static SinkFunctionProvider of​(org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<org.apache.flink.table.data.RowData> sinkFunction)
        Deprecated.
        Helper method for creating a static provider.

      • of

        static SinkFunctionProvider of​(org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<org.apache.flink.table.data.RowData> sinkFunction,
                               @Nullable
                               Integer sinkParallelism)
        Deprecated.
        Helper method for creating a SinkFunction provider with a provided sink parallelism.

      • createSinkFunction

        org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction<org.apache.flink.table.data.RowData> createSinkFunction()
        Deprecated.
        Creates a SinkFunction instance.