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

Class extractData<TypeXPivot extends Comparable<TypeXPivot>,TypeXRef extends Comparable<TypeXRef>,Input>

java.lang.Object

org.apache.wayang.iejoin.operators.spark_helpers.extractData<TypeXPivot,TypeXRef,Input>

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.Function<scala.Tuple2<Long,Input>,Data<TypeXPivot,TypeXRef>>

public class extractData<TypeXPivot extends Comparable<TypeXPivot>,TypeXRef extends Comparable<TypeXRef>,Input>
extends Object
implements org.apache.spark.api.java.function.Function<scala.Tuple2<Long,Input>,Data<TypeXPivot,TypeXRef>>

Created by khayyzy on 5/28/16.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
extractData(org.apache.spark.api.java.function.Function<Input,TypeXPivot> getXPivot, org.apache.spark.api.java.function.Function<Input,TypeXRef> getXRef)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

extractData

public extractData(org.apache.spark.api.java.function.Function<Input,TypeXPivot> getXPivot,
 org.apache.spark.api.java.function.Function<Input,TypeXRef> getXRef)

Method Details

call

public Data call(scala.Tuple2<Long,Input> in)
          throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.Function<TypeXPivot extends Comparable<TypeXPivot>,TypeXRef extends Comparable<TypeXRef>>

Throws:

Exception