org.apache.tez.runtime.library.output

Class UnorderedPartitionedKVOutput

java.lang.Object

org.apache.tez.runtime.api.AbstractLogicalOutput

org.apache.tez.runtime.library.output.UnorderedPartitionedKVOutput

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 UnorderedPartitionedKVOutput
extends org.apache.tez.runtime.api.AbstractLogicalOutput

UnorderedPartitionedKVOutput is a LogicalOutput which can be used to write Key-Value pairs. The key-value pairs are written to the correct partition based on the configured Partitioner.

Constructor Summary

Constructors

Constructor and Description
UnorderedPartitionedKVOutput(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()
org.apache.tez.runtime.api.Writer	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

UnorderedPartitionedKVOutput

public UnorderedPartitionedKVOutput(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 org.apache.tez.runtime.api.Writer 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