org.apache.tez.runtime.library.output
Class OnFileUnorderedKVOutput

java.lang.Object
  org.apache.tez.runtime.library.output.OnFileUnorderedKVOutput

All Implemented Interfaces:

org.apache.tez.runtime.api.LogicalOutput, org.apache.tez.runtime.api.Output

public class OnFileUnorderedKVOutput
extends Object
implements org.apache.tez.runtime.api.LogicalOutput

Constructor Summary

OnFileUnorderedKVOutput()

Method Summary

List<org.apache.tez.runtime.api.Event>	close()
KeyValueWriter	getWriter()
void	handleEvents(List<org.apache.tez.runtime.api.Event> outputEvents)
List<org.apache.tez.runtime.api.Event>	initialize(org.apache.tez.runtime.api.TezOutputContext outputContext)
void	setNumPhysicalOutputs(int numOutputs)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

OnFileUnorderedKVOutput

public OnFileUnorderedKVOutput()

Method Detail

initialize

public List<org.apache.tez.runtime.api.Event> initialize(org.apache.tez.runtime.api.TezOutputContext outputContext)
                                                  throws Exception

Specified by:

initialize in interface org.apache.tez.runtime.api.Output

Throws:

Exception

start

public void start()

Specified by:

start in interface org.apache.tez.runtime.api.Output

getWriter

public KeyValueWriter getWriter()
                         throws Exception

Specified by:

getWriter in interface org.apache.tez.runtime.api.Output

Throws:

Exception

handleEvents

public void handleEvents(List<org.apache.tez.runtime.api.Event> outputEvents)

Specified by:

handleEvents in interface org.apache.tez.runtime.api.Output

close

public List<org.apache.tez.runtime.api.Event> close()
                                             throws Exception

Specified by:

close in interface org.apache.tez.runtime.api.Output

Throws:

Exception

setNumPhysicalOutputs

public void setNumPhysicalOutputs(int numOutputs)

Specified by:

setNumPhysicalOutputs in interface org.apache.tez.runtime.api.LogicalOutput