Class FileCopyTaskInputSplit

  • All Implemented Interfaces:
    Serializable, org.apache.flink.core.io.InputSplit

    public class FileCopyTaskInputSplit
    extends Object
    implements org.apache.flink.core.io.InputSplit
    Implementation of InputSplit for copying files.
    See Also:
    Serialized Form
    • Constructor Detail

      • FileCopyTaskInputSplit

        public FileCopyTaskInputSplit​(FileCopyTask task,
                                      int splitNumber)
    • Method Detail

      • getSplitNumber

        public int getSplitNumber()
        Specified by:
        getSplitNumber in interface org.apache.flink.core.io.InputSplit