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

Class BitSetJoin<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>

java.lang.Object

org.apache.wayang.iejoin.operators.spark_helpers.BitSetJoin<Type0,Type1>

All Implemented Interfaces:

Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<List2AttributesObjectSkinny<Type0,Type1>,List2AttributesObjectSkinny<Type0,Type1>>,Long,Long>

public class BitSetJoin<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>
extends Object
implements org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<List2AttributesObjectSkinny<Type0,Type1>,List2AttributesObjectSkinny<Type0,Type1>>,Long,Long>

Created by khayyzy on 5/28/16.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
BitSetJoin(boolean list1ASC, boolean list2ASC, boolean list1ASCSec, boolean list2ASCSec, boolean equalReverse, boolean sameRDD, IEJoinMasterOperator.JoinCondition c1)

Method Summary

Modifier and Type	Method	Description
Iterator<scala.Tuple2<Long,Long>>	call(scala.Tuple2<List2AttributesObjectSkinny<Type0,Type1>,List2AttributesObjectSkinny<Type0,Type1>> arg0)
Data[]	merge(Data[] lst1, Data[] lst2, boolean asc1, boolean asc2)

Methods inherited from class java.lang.Object

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

Constructor Details

BitSetJoin

public BitSetJoin(boolean list1ASC,
 boolean list2ASC,
 boolean list1ASCSec,
 boolean list2ASCSec,
 boolean equalReverse,
 boolean sameRDD,
 IEJoinMasterOperator.JoinCondition c1)

Method Details

merge

public Data[] merge(Data[] lst1,
 Data[] lst2,
 boolean asc1,
 boolean asc2)

call

public Iterator<scala.Tuple2<Long,Long>> call(scala.Tuple2<List2AttributesObjectSkinny<Type0,Type1>,List2AttributesObjectSkinny<Type0,Type1>> arg0)
                                       throws Exception

Specified by:

call in interface org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<List2AttributesObjectSkinny<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>,List2AttributesObjectSkinny<Type0 extends Comparable<Type0>,Type1 extends Comparable<Type1>>>,Long,Long>

Throws:

Exception