public class TFileProcessor
extends java.lang.Object
Constructor and Description |
---|
TFileProcessor(TProcessor processor,
TProtocolFactory protocolFactory,
TFileTransport inputTransport,
TTransport outputTransport) |
TFileProcessor(TProcessor processor,
TProtocolFactory inputProtocolFactory,
TProtocolFactory outputProtocolFactory,
TFileTransport inputTransport,
TTransport outputTransport) |
Modifier and Type | Method and Description |
---|---|
void |
processChunk()
Process a current chunk
|
void |
processChunk(int chunkNum)
Process a single chunk
|
void |
processChunk(int startChunkNum,
int endChunkNum)
Process from start to last chunk both inclusive where chunks begin from 0
|
public TFileProcessor(TProcessor processor, TProtocolFactory protocolFactory, TFileTransport inputTransport, TTransport outputTransport)
public TFileProcessor(TProcessor processor, TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory, TFileTransport inputTransport, TTransport outputTransport)
public void processChunk(int startChunkNum, int endChunkNum) throws TException
startChunkNum
- first chunk to be processedendChunkNum
- last chunk to be processedTException
public void processChunk(int chunkNum) throws TException
chunkNum
- chunk to be processedTException
public void processChunk() throws TException
TException