Package org.apache.wayang.iejoin.operators.spark_helpers

Class addUniqueID<Input extends Copyable<Input>>

java.lang.Object

org.apache.wayang.iejoin.operators.spark_helpers.addUniqueID<Input>

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.Function2<Integer,Iterator<Input>,Iterator<scala.Tuple2<Long,Input>>>

public class addUniqueID<Input extends Copyable<Input>>
extends Object
implements org.apache.spark.api.java.function.Function2<Integer,Iterator<Input>,Iterator<scala.Tuple2<Long,Input>>>

Created by khayyzy on 5/28/16.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
addUniqueID()
addUniqueID(int block, int start)

Method Summary

Modifier and Type	Method	Description
Iterator<scala.Tuple2<Long,Input>>	call(Integer in, Iterator<Input> arg0)

Methods inherited from class java.lang.Object

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

Constructor Details

addUniqueID

public addUniqueID()

addUniqueID

public addUniqueID(int block,
 int start)

Method Details

call

public Iterator<scala.Tuple2<Long,Input>> call(Integer in,
 Iterator<Input> arg0)
                                        throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function2<Integer,Iterator<Input extends Copyable<Input>>,Iterator<scala.Tuple2<Long,Input extends Copyable<Input>>>>

Throws:

Exception