org.apache.pig.impl.streaming

Class StreamingCommand.HandleSpec

java.lang.Object

org.apache.pig.impl.streaming.StreamingCommand.HandleSpec

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.lang.Comparable<StreamingCommand.HandleSpec>

Enclosing class:

StreamingCommand

public static class StreamingCommand.HandleSpec
extends java.lang.Object
implements java.lang.Comparable<StreamingCommand.HandleSpec>, java.io.Serializable, java.lang.Cloneable

Specification about the usage of the StreamingCommand.Handle to communicate with the external process. It specifies the stream-handle which can be one of stdin/ stdout/stderr or a named file and also the serializer/deserializer specification to be used to read/write data to/from the stream.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HandleSpec(java.lang.String handleName) Create a new StreamingCommand.HandleSpec with a given name using the default PigStorage serializer/deserializer.
HandleSpec(java.lang.String handleName, java.lang.String spec) Create a new StreamingCommand.HandleSpec with a given name using the default PigStorage serializer/deserializer.

Method Summary

Modifier and Type	Method and Description
java.lang.Object	clone()
int	compareTo(StreamingCommand.HandleSpec o)
boolean	equals(java.lang.Object obj)
java.lang.String	getName() Get the name of the HandleSpec.
java.lang.String	getSpec() Get the serializer/deserializer spec of the HandleSpec.
int	hashCode()
void	setName(java.lang.String name) Set the name of the HandleSpec.
void	setSpec(java.lang.String spec) Set the serializer/deserializer spec of the HandleSpec.
java.lang.String	toString()

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HandleSpec

public HandleSpec(java.lang.String handleName)

Create a new StreamingCommand.HandleSpec with a given name using the default PigStorage serializer/deserializer.

Parameters:

handleName - name of the handle (one of stdin, stdout or a file-path)

HandleSpec

public HandleSpec(java.lang.String handleName,
                  java.lang.String spec)

Create a new StreamingCommand.HandleSpec with a given name using the default PigStorage serializer/deserializer.

Parameters:

handleName - name of the handle (one of stdin, stdout or a file-path)

spec - serializer/deserializer spec

Method Detail

compareTo

public int compareTo(StreamingCommand.HandleSpec o)

Specified by:

compareTo in interface java.lang.Comparable<StreamingCommand.HandleSpec>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getName

public java.lang.String getName()

Get the name of the HandleSpec.

Returns:

the name of the HandleSpec (one of stdin, stdout or a file-path)

setName

public void setName(java.lang.String name)

Set the name of the HandleSpec.

Parameters:

name - name of the HandleSpec (one of stdin, stdout or a file-path)

getSpec

public java.lang.String getSpec()

Get the serializer/deserializer spec of the HandleSpec.

Returns:

the serializer/deserializer spec of the HandleSpec

setSpec

public void setSpec(java.lang.String spec)

Set the serializer/deserializer spec of the HandleSpec.

Parameters:

spec - the serializer/deserializer spec of the HandleSpec

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

clone

public java.lang.Object clone()

Overrides:

clone in class java.lang.Object