Uses of Interface
org.apache.flink.api.common.typeutils.TypePairComparatorFactory

Packages that use TypePairComparatorFactory

Package	Description
org.apache.flink.api.java.typeutils.runtime
org.apache.flink.optimizer.plan
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.util

Uses of TypePairComparatorFactory in org.apache.flink.api.java.typeutils.runtime

Classes in org.apache.flink.api.java.typeutils.runtime that implement TypePairComparatorFactory

Modifier and Type	Class and Description
class	RuntimePairComparatorFactory<T1,T2>

Uses of TypePairComparatorFactory in org.apache.flink.optimizer.plan

Methods in org.apache.flink.optimizer.plan that return TypePairComparatorFactory

Modifier and Type	Method and Description
TypePairComparatorFactory<?,?>	DualInputPlanNode.getPairComparator()

Methods in org.apache.flink.optimizer.plan with parameters of type TypePairComparatorFactory

Modifier and Type	Method and Description
void	DualInputPlanNode.setPairComparator(TypePairComparatorFactory<?,?> comparator)

Uses of TypePairComparatorFactory in org.apache.flink.runtime.operators

Methods in org.apache.flink.runtime.operators with parameters of type TypePairComparatorFactory

Modifier and Type	Method and Description
protected JoinTaskIterator<IT1,IT2,OT>	FullOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	LeftOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected abstract JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	RightOuterJoinDriver.getNonReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	FullOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	LeftOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected abstract JoinTaskIterator<IT1,IT2,OT>	AbstractOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)
protected JoinTaskIterator<IT1,IT2,OT>	RightOuterJoinDriver.getReusingOuterJoinIterator(DriverStrategy driverStrategy, MutableObjectIterator<IT1> in1, MutableObjectIterator<IT2> in2, TypeSerializer<IT1> serializer1, TypeComparator<IT1> comparator1, TypeSerializer<IT2> serializer2, TypeComparator<IT2> comparator2, TypePairComparatorFactory<IT1,IT2> pairComparatorFactory, MemoryManager memoryManager, IOManager ioManager, double driverMemFraction)

Uses of TypePairComparatorFactory in org.apache.flink.runtime.operators.util

Methods in org.apache.flink.runtime.operators.util that return TypePairComparatorFactory

Modifier and Type	Method and Description
<T1,T2> TypePairComparatorFactory<T1,T2>	TaskConfig.getPairComparatorFactory(ClassLoader cl)

Methods in org.apache.flink.runtime.operators.util with parameters of type TypePairComparatorFactory

Modifier and Type	Method and Description
void	TaskConfig.setDriverPairComparator(TypePairComparatorFactory<?,?> factory)