Insert one line of record to a apace which buffers the swap data. @param line The inserted line.

List the statuses of the files/directories in the given path if the path is a directory. @param srcpath Path in {@link FileSystem} @param

switch condition: read queue is empty && write queue is not empty. Notice:This function can only be invoked after readLock is grabbed,or may cause dea

this method is response for doing some prepare work, and then create reader threads, and submit them to the thread pool @param jobPluginConf @param p

Put one {@link ILine} into {@link Storage}. @param line {@link ILine} of data pushed into {@link Storage}. @return true for OK, false for fail

Convert text to bytes @param text @return bytes for the input text

Write buffered data(in a line array) to all storages which offer data to {@link IWriter}. This method is the base of double write(data dumped to multi

Check file type in hdfs. @param fs handle of {@link FileSystem} @param path hdfs {@link Path} @param conf {@link C

@param readerManager @param writerManager @param monitorManager @param storageManager @return

Delete file specified by path or files in directory specified by path. @param path {@link Path} in hadoop @param flag need to

Encrypt a string using whatever is the default encryption technique for the system. @param clearText @return The encrypted string @throws GeneralSecu