Package org.apache.thrift.transport
Class TFileProcessor
- java.lang.Object
-
- org.apache.thrift.transport.TFileProcessor
-
public class TFileProcessor extends java.lang.Object
FileProcessor: helps in processing files generated by TFileTransport. Port of original cpp implementation
-
-
Constructor Summary
Constructors Constructor Description TFileProcessor(TProcessor processor, TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory, TFileTransport inputTransport, TTransport outputTransport)
TFileProcessor(TProcessor processor, TProtocolFactory protocolFactory, TFileTransport inputTransport, TTransport outputTransport)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
processChunk()
Process a current chunkvoid
processChunk(int chunkNum)
Process a single chunkvoid
processChunk(int startChunkNum, int endChunkNum)
Process from start to last chunk both inclusive where chunks begin from 0
-
-
-
Constructor Detail
-
TFileProcessor
public TFileProcessor(TProcessor processor, TProtocolFactory protocolFactory, TFileTransport inputTransport, TTransport outputTransport)
-
TFileProcessor
public TFileProcessor(TProcessor processor, TProtocolFactory inputProtocolFactory, TProtocolFactory outputProtocolFactory, TFileTransport inputTransport, TTransport outputTransport)
-
-
Method Detail
-
processChunk
public void processChunk(int startChunkNum, int endChunkNum) throws TException
Process from start to last chunk both inclusive where chunks begin from 0- Parameters:
startChunkNum
- first chunk to be processedendChunkNum
- last chunk to be processed- Throws:
TException
-
processChunk
public void processChunk(int chunkNum) throws TException
Process a single chunk- Parameters:
chunkNum
- chunk to be processed- Throws:
TException
-
processChunk
public void processChunk() throws TException
Process a current chunk- Throws:
TException
-
-