org.apache.tez.runtime.library.output

Class UnorderedKVOutput

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalOutput

org.apache.tez.runtime.library.output.UnorderedKVOutput

All Implemented Interfaces:

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

@InterfaceAudience.Public
public class UnorderedKVOutput
extends org.apache.tez.runtime.api.AbstractLogicalOutput

UnorderedKVOutput is a LogicalOutput that writes key value data without applying any ordering or grouping constraints. This can be used to write raw key value data as is.

Constructor Summary

Constructors

Constructor and Description
UnorderedKVOutput(org.apache.tez.runtime.api.OutputContext outputContext, int numPhysicalOutputs)

Method Summary

Modifier and Type	Method and Description
List<org.apache.tez.runtime.api.Event>	close()
KeyValuesWriter	getWriter()
void	handleEvents(List<org.apache.tez.runtime.api.Event> outputEvents)
List<org.apache.tez.runtime.api.Event>	initialize()
void	start()

Methods inherited from class org.apache.tez.runtime.api.AbstractLogicalOutput

getContext, getNumPhysicalOutputs

Methods inherited from class java.lang.Object

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

Constructor Detail

UnorderedKVOutput

public UnorderedKVOutput(org.apache.tez.runtime.api.OutputContext outputContext,
                         int numPhysicalOutputs)

Method Detail

initialize

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

Specified by:

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

Specified by:

initialize in class org.apache.tez.runtime.api.AbstractLogicalOutput

Throws:

Exception

start

public void start()
           throws Exception

Throws:

Exception

getWriter

public KeyValuesWriter getWriter()
                          throws Exception

Throws:

Exception

handleEvents

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

close

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

Throws:

Exception