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

Interface SinkFunctionProvider

  • All Superinterfaces:
    org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider, org.apache.flink.table.connector.ParallelismProvider
    @PublicEvolving
public interface SinkFunctionProvider
extends org.apache.flink.table.connector.sink.DynamicTableSink.SinkRuntimeProvider, org.apache.flink.table.connector.ParallelismProvider
    Provider of a SinkFunction instance as a runtime implementation for DynamicTableSink.

    • Method Summary

      All Methods Static Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      org.apache.flink.streaming.api.functions.sink.SinkFunction<org.apache.flink.table.data.RowData> createSinkFunction()
      Creates a SinkFunction instance.
      static SinkFunctionProvider of​(org.apache.flink.streaming.api.functions.sink.SinkFunction<org.apache.flink.table.data.RowData> sinkFunction)
      Helper method for creating a static provider.
      static SinkFunctionProvider of​(org.apache.flink.streaming.api.functions.sink.SinkFunction<org.apache.flink.table.data.RowData> sinkFunction, Integer sinkParallelism)
      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.SinkFunction<org.apache.flink.table.data.RowData> sinkFunction)
        Helper method for creating a static provider.

      • of

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

      • createSinkFunction

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