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

Class BitSetJoin<Type0 extends java.lang.Comparable<Type0>,Type1 extends java.lang.Comparable<Type1>>

java.lang.Object

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

All Implemented Interfaces:

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

public class BitSetJoin<Type0 extends java.lang.Comparable<Type0>,Type1 extends java.lang.Comparable<Type1>>
extends java.lang.Object
implements org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<List2AttributesObjectSkinny<Type0,Type1>,List2AttributesObjectSkinny<Type0,Type1>>,java.lang.Long,java.lang.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
java.util.Iterator<scala.Tuple2<java.lang.Long,java.lang.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 Detail

BitSetJoin

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

Method Detail

merge

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

call

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

Specified by:

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

Throws:

java.lang.Exception