Package org.apache.flink.api.connector.source.lib

Class InputFormatSource<OUT>

  • All Implemented Interfaces:
    Serializable, org.apache.flink.api.connector.source.Source<OUT,​org.apache.flink.api.connector.source.SourceSplit,​Void>, org.apache.flink.api.connector.source.SourceReaderFactory<OUT,​org.apache.flink.api.connector.source.SourceSplit>
    @Internal
public class InputFormatSource<OUT>
extends Object
implements org.apache.flink.api.connector.source.Source<OUT,​org.apache.flink.api.connector.source.SourceSplit,​Void>
    A Source that reads data using an InputFormat.
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Constructor Description
      InputFormatSource​(org.apache.flink.api.connector.source.Boundedness boundedness, org.apache.flink.api.common.io.InputFormat<OUT,​?> format)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.flink.api.connector.source.SplitEnumerator<org.apache.flink.api.connector.source.SourceSplit,​Void> createEnumerator​(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.flink.api.connector.source.SourceSplit> context)  
      org.apache.flink.api.connector.source.SourceReader<OUT,​org.apache.flink.api.connector.source.SourceSplit> createReader​(org.apache.flink.api.connector.source.SourceReaderContext readerContext)  
      org.apache.flink.api.connector.source.Boundedness getBoundedness()  
      org.apache.flink.core.io.SimpleVersionedSerializer<Void> getEnumeratorCheckpointSerializer()  
      org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.api.connector.source.SourceSplit> getSplitSerializer()  
      org.apache.flink.api.connector.source.SplitEnumerator<org.apache.flink.api.connector.source.SourceSplit,​Void> restoreEnumerator​(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.flink.api.connector.source.SourceSplit> context, Void checkpoint)  

      • Methods inherited from interface org.apache.flink.api.connector.source.Source

        declareWatermarks

    • Constructor Detail

      • InputFormatSource

        public InputFormatSource​(org.apache.flink.api.connector.source.Boundedness boundedness,
                         org.apache.flink.api.common.io.InputFormat<OUT,​?> format)

    • Method Detail

      • getBoundedness

        public org.apache.flink.api.connector.source.Boundedness getBoundedness()
        Specified by:
        getBoundedness in interface org.apache.flink.api.connector.source.Source<OUT,​org.apache.flink.api.connector.source.SourceSplit,​Void>

      • createEnumerator

        public org.apache.flink.api.connector.source.SplitEnumerator<org.apache.flink.api.connector.source.SourceSplit,​Void> createEnumerator​(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.flink.api.connector.source.SourceSplit> context)
                                                                                                                                     throws Exception
        Specified by:
        createEnumerator in interface org.apache.flink.api.connector.source.Source<OUT,​org.apache.flink.api.connector.source.SourceSplit,​Void>
        Throws:
        Exception

      • restoreEnumerator

        public org.apache.flink.api.connector.source.SplitEnumerator<org.apache.flink.api.connector.source.SourceSplit,​Void> restoreEnumerator​(org.apache.flink.api.connector.source.SplitEnumeratorContext<org.apache.flink.api.connector.source.SourceSplit> context,
                                                                                                                                             Void checkpoint)
                                                                                                                                      throws Exception
        Specified by:
        restoreEnumerator in interface org.apache.flink.api.connector.source.Source<OUT,​org.apache.flink.api.connector.source.SourceSplit,​Void>
        Throws:
        Exception

      • getSplitSerializer

        public org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.flink.api.connector.source.SourceSplit> getSplitSerializer()
        Specified by:
        getSplitSerializer in interface org.apache.flink.api.connector.source.Source<OUT,​org.apache.flink.api.connector.source.SourceSplit,​Void>

      • getEnumeratorCheckpointSerializer

        public org.apache.flink.core.io.SimpleVersionedSerializer<Void> getEnumeratorCheckpointSerializer()
        Specified by:
        getEnumeratorCheckpointSerializer in interface org.apache.flink.api.connector.source.Source<OUT,​org.apache.flink.api.connector.source.SourceSplit,​Void>

      • createReader

        public org.apache.flink.api.connector.source.SourceReader<OUT,​org.apache.flink.api.connector.source.SourceSplit> createReader​(org.apache.flink.api.connector.source.SourceReaderContext readerContext)
                                                                                                                             throws Exception
        Specified by:
        createReader in interface org.apache.flink.api.connector.source.SourceReaderFactory<OUT,​org.apache.flink.api.connector.source.SourceSplit>
        Throws:
        Exception