public class LocalToRemoteHdfsMover
This class is used by LocalWriter.java.
The only role of this class is to move dataSink files
from the local file system to the remote HDFS.
Those 2 classes are using a blockingQueue to exchange
This class will also take care of moving all existing
done dataSink files (.done) and any dataSink file that
has not been changed for at least (rotatePeriod+2min).
Nested Class Summary
Nested classes/interfaces inherited from class java.lang.Thread