public class PigStreaming extends PigStreamingBase
PigStreamingBase.
It converts tuples into fieldDel separated lines
and fieldDel separated lines into tuples.| Constructor and Description |
|---|
PigStreaming()
The constructor that uses the default field delimiter.
|
PigStreaming(String delimiter)
The constructor that accepts a user-specified field
delimiter.
|
| Modifier and Type | Method and Description |
|---|---|
Tuple |
deserialize(byte[] bytes,
int offset,
int length)
Given a byte array from a streaming executable, produce a tuple.
|
LoadCaster |
getLoadCaster()
This will be called on the front end during planning and not on the back
end during execution.
|
WritableByteArray |
serializeToBytes(Tuple t)
Given a tuple, produce an array of bytes to be passed to the streaming
executable.
|
deserialize, serializepublic PigStreaming()
public PigStreaming(String delimiter)
delimiter - a String specifying the field
delimiter.public WritableByteArray serializeToBytes(Tuple t) throws IOException
PigStreamingBaseserializeToBytes in class PigStreamingBaset - Tuple to serializeIOExceptionpublic Tuple deserialize(byte[] bytes, int offset, int length) throws IOException
PigStreamingBasedeserialize in class PigStreamingBasebytes - bytes to deserialize.offset - the offset in the byte array from which to deserialize.length - the number of bytes from the offset of the byte array to deserialize.IOExceptionpublic LoadCaster getLoadCaster() throws IOException
PigStreamingBasegetLoadCaster in interface StreamToPiggetLoadCaster in class PigStreamingBaseLoadCaster associated with this object, or null if
there is no such LoadCaster.IOException - if there is an exception during LoadCasterCopyright © 2007-2012 The Apache Software Foundation