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

Methods

Modifier and Type	Method and Description
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 java.io.IOException

Deprecated.

Given a byte array from a streaming executable, produce a tuple.

Parameters:

bytes - to deserialize.

Returns:

Data as a Pig Tuple.

Throws:

java.io.IOException

getLoadCaster

LoadCaster getLoadCaster()
                         throws java.io.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:

java.io.IOException - if there is an exception during LoadCaster