org.apache.pig.impl.streaming
Class StreamingUDFOutputHandler

java.lang.Object
  org.apache.pig.impl.streaming.OutputHandler
      org.apache.pig.impl.streaming.DefaultOutputHandler
          org.apache.pig.impl.streaming.StreamingUDFOutputHandler

public class StreamingUDFOutputHandler
extends DefaultOutputHandler

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.impl.streaming.OutputHandler

OutputHandler.OutputType

Field Summary

Fields inherited from class org.apache.pig.impl.streaming.OutputHandler

alreadyClosed, deserializer, END_OF_OUTPUT, in

Constructor Summary

StreamingUDFOutputHandler(PigStreamingUDF deserializer)

Method Summary

protected byte[]

getRecordDelimiter()

Methods inherited from class org.apache.pig.impl.streaming.DefaultOutputHandler

getOutputType

Methods inherited from class org.apache.pig.impl.streaming.OutputHandler

bindTo, close, getNext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StreamingUDFOutputHandler

public StreamingUDFOutputHandler(PigStreamingUDF deserializer)

Method Detail

getRecordDelimiter

protected byte[] getRecordDelimiter()

Overrides:

getRecordDelimiter in class OutputHandler