Package org.apache.flink.table.connector.source

Interface SourceFunctionProvider

  • All Superinterfaces:
    org.apache.flink.table.connector.ParallelismProvider, org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider
    @Deprecated
@PublicEvolving
public interface SourceFunctionProvider
extends org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider, org.apache.flink.table.connector.ParallelismProvider
    Deprecated.
    This interface is based on the SourceFunction API, which is due to be removed. Use SourceProvider instead.
    Provider of a SourceFunction instance as a runtime implementation for ScanTableSource.

    • Method Summary

      All Methods Static Methods Instance Methods Abstract Methods Deprecated Methods 
      Modifier and Type Method Description
      org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> createSourceFunction()
      Deprecated.
      Creates a SourceFunction instance.
      static SourceFunctionProvider of​(org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> sourceFunction, boolean isBounded)
      Deprecated.
      Helper method for creating a static provider.
      static SourceFunctionProvider of​(org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> sourceFunction, boolean isBounded, Integer sourceParallelism)
      Deprecated.
      Helper method for creating a Source provider with a provided source parallelism.

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

        getParallelism

      • Methods inherited from interface org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

        isBounded

    • Method Detail

      • of

        static SourceFunctionProvider of​(org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> sourceFunction,
                                 boolean isBounded)
        Deprecated.
        Helper method for creating a static provider.

      • of

        static SourceFunctionProvider of​(org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> sourceFunction,
                                 boolean isBounded,
                                 @Nullable
                                 Integer sourceParallelism)
        Deprecated.
        Helper method for creating a Source provider with a provided source parallelism.

      • createSourceFunction

        org.apache.flink.streaming.api.functions.source.SourceFunction<org.apache.flink.table.data.RowData> createSourceFunction()
        Deprecated.
        Creates a SourceFunction instance.