Package org.apache.flink.examples.java.distcp

Class Summary

Class	Description
DistCp	A main class of the Flink distcp utility.
FileCopyTask	A Java POJO that represents a task for copying a single file.
FileCopyTaskInputFormat	An implementation of an input format that dynamically assigns FileCopyTask to the mappers that have finished previously assigned tasks.
FileCopyTaskInputSplit	Implementation of InputSplit for copying files.