org.apache.pig.backend.hadoop.executionengine.spark.converter

Class SkewedJoinConverter

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.spark.converter.SkewedJoinConverter

All Implemented Interfaces:

java.io.Serializable, RDDConverter<Tuple,Tuple,POSkewedJoin>

public class SkewedJoinConverter
extends java.lang.Object
implements RDDConverter<Tuple,Tuple,POSkewedJoin>, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SkewedJoinConverter()

Method Summary

Modifier and Type	Method and Description
<any>	convert(java.util.List<<any>> predecessors, POSkewedJoin poSkewedJoin)
void	setSkewedJoinPartitionFile(java.lang.String partitionFile)

Methods inherited from class java.lang.Object

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

Constructor Detail

SkewedJoinConverter

public SkewedJoinConverter()

Method Detail

setSkewedJoinPartitionFile

public void setSkewedJoinPartitionFile(java.lang.String partitionFile)

convert

public <any> convert(java.util.List<<any>> predecessors,
                     POSkewedJoin poSkewedJoin)
              throws java.io.IOException

Specified by:

convert in interface RDDConverter<Tuple,Tuple,POSkewedJoin>

Throws:

java.io.IOException