Pull one line from {@link IStorage}, used by {@link IWriter}. @return one {@link ILine} of record.

Push one line into {@link IStorage}, used by {@link IReader} @param line One line of record, see {@link ILine} @return true for OK, false for

generate key to get {@link DataSource} NOTE: Client must make sure all connections to the same database should share the same value a suggestion: use

Decide whether the reader or writer thread is executed successfully if there is NO thread failed, it returns true; even if some of the thread is runni

Get writer plugin's configuration. The return value is a list, this is designed to suit multiple data destination. @return a list of {@link JobPlu

Get info of line number in {@link IStorage} space. @return Information of line number.

@param filename job configuration name @return a job configure instance with the specified job configuration file

Parse plugin configure file. @return a map mapping plugin name to plugin params

@param keyFilename @throws IOException

@param der column list from job configure @return comma split column string, can be empty string

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

Create the cipher object for encryption or decryption. We create a DES cipher with PKCS#5 padding @return Cipher @throws NoSuchAlgorithmException @th

create thread pool to run reader/writer threads @param concurrency @return ExecutorService

Decrypt a string using whatever is the default encryption technique for the system. @param cipherText @return The decrypted string @throws NoSuchPadd

Extract one line of record from the space which contains current data. @return line A line of data.

Flush data in buffer (if exists) to {@link Storage}.

Create a DES key and return a string version of the raw bits. @param seed @return A key for encryption @throws NoSuchAlgorithmException

get number of reader/writer threads running concurrently it's determined by parameter concurrency set in job.xml the valid value is between 1 to MAX_T

Create a key for encryption and decryption @return Key @throws NoSuchAlgorithmException @throws InvalidKeySpecException @throws InvalidKeyException

Get job id. @return job id.

Get average line speed @param lines Line amount @param seconds Costed time. @return Average line speed.

Get reader plugin's configuration. @return a {@link JobPluginConf}.