org.apache.pig
Interface StreamToPig

All Known Implementing Classes:
PigStreaming, PigStreamingBase, PigStreamingUDF

Deprecated. Use PigStreamingBase

@Deprecated
@InterfaceAudience.Public
@InterfaceStability.Stable
public interface StreamToPig


Method Summary
 Tuple deserialize(byte[] bytes)
          Deprecated. Given a byte array from a streaming executable, produce a tuple.
 LoadCaster getLoadCaster()
          Deprecated. This will be called on the front end during planning and not on the back end during execution.
 

Method Detail

deserialize

Tuple deserialize(byte[] bytes)
                  throws IOException
Deprecated. 
Given a byte array from a streaming executable, produce a tuple.

Parameters:
bytes - to deserialize.
Returns:
Data as a Pig Tuple.
Throws:
IOException

getLoadCaster

LoadCaster getLoadCaster()
                         throws IOException
Deprecated. 
This will be called on the front end during planning and not on the back end during execution.

Returns:
the LoadCaster associated with this object, or null if there is no such LoadCaster.
Throws:
IOException - if there is an exception during LoadCaster


Copyright © 2007-2012 The Apache Software Foundation