Constructor and Description |
---|
CommonRangeBoundaries(TypeComparator<T> typeComparators,
Object[][] boundaries) |
Constructor and Description |
---|
SimpleListIterable(List<IN> values,
TypeComparator<IN> comparator,
TypeSerializer<IN> serializer) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<BT> |
JoinHashMap.getBuildComparator() |
Modifier and Type | Method and Description |
---|---|
<PT> JoinHashMap.Prober<PT> |
JoinHashMap.createProber(TypeComparator<PT> probeComparator,
TypePairComparator<PT,BT> pairComparator) |
Constructor and Description |
---|
JoinHashMap(TypeSerializer<BT> buildSerializer,
TypeComparator<BT> buildComparator) |
ListKeyGroupedIterator(List<E> input,
TypeSerializer<E> serializer,
TypeComparator<E> comparator)
Initializes the ListKeyGroupedIterator..
|
Prober(TypeComparator<PT> probeComparator,
TypePairComparator<PT,BT> pairComparator) |
TypeComparable(T elem,
TypeComparator<T> comparator) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
LocalTimeTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
SqlTimeTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
BasicTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
AtomicType.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig)
Creates a comparator for this type.
|
Constructor and Description |
---|
BasicTypeInfo(Class<T> clazz,
Class<?>[] possibleCastTargetTypes,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
FractionalTypeInfo(Class<T> clazz,
Class<?>[] possibleCastTargetTypes,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
IntegerTypeInfo(Class<T> clazz,
Class<?>[] possibleCastTargetTypes,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
LocalTimeTypeInfo(Class<T> clazz,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
NumericTypeInfo(Class<T> clazz,
Class<?>[] possibleCastTargetTypes,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
SqlTimeTypeInfo(Class<T> clazz,
TypeSerializer<T> serializer,
Class<? extends TypeComparator<T>> comparatorClass) |
Modifier and Type | Class and Description |
---|---|
class |
CompositeTypeComparator<T> |
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
TypeComparatorFactory.createComparator() |
TypeComparator<T> |
CompositeType.createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config)
Generic implementation of the comparator creation.
|
TypeComparator<T> |
CompositeType.TypeComparatorBuilder.createTypeComparator(ExecutionConfig config) |
abstract TypeComparator<T> |
TypeComparator.duplicate()
Creates a copy of this class.
|
TypeComparator[] |
CompositeTypeComparator.getFlatComparators() |
abstract TypeComparator[] |
TypeComparator.getFlatComparators()
Get the field comparators.
|
Modifier and Type | Method and Description |
---|---|
void |
CompositeType.TypeComparatorBuilder.addComparatorField(int fieldId,
TypeComparator<?> comparator) |
abstract int |
TypeComparator.compareToReference(TypeComparator<T> referencedComparator)
This method compares the element that has been set as reference in this type accessor, to the
element set as reference in the given type accessor.
|
TypePairComparator<T1,T2> |
TypePairComparatorFactory.createComparator12(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
TypePairComparator<T1,T2> |
TypePairComparatorFactory.createComparator12(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
TypePairComparator<T2,T1> |
TypePairComparatorFactory.createComparator21(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
TypePairComparator<T2,T1> |
TypePairComparatorFactory.createComparator21(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
Modifier and Type | Method and Description |
---|---|
abstract void |
CompositeTypeComparator.getFlatComparator(List<TypeComparator> flatComparators) |
Constructor and Description |
---|
GenericPairComparator(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
GenericPairComparator(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
SameTypePairComparator(TypeComparator<T> comp) |
Modifier and Type | Class and Description |
---|---|
class |
BasicTypeComparator<T extends Comparable<T>> |
class |
BigDecComparator
Comparator for comparing BigDecimal values.
|
class |
BigIntComparator
Comparator for comparing BigInteger values.
|
class |
BooleanComparator |
class |
BooleanValueComparator
Specialized comparator for BooleanValue based on CopyableValueComparator.
|
class |
ByteComparator |
class |
ByteValueComparator
Specialized comparator for ByteValue based on CopyableValueComparator.
|
class |
CharComparator |
class |
CharValueComparator
Specialized comparator for CharValue based on CopyableValueComparator.
|
class |
DateComparator |
class |
DoubleComparator |
class |
DoubleValueComparator
Specialized comparator for DoubleValue based on CopyableValueComparator.
|
class |
EnumComparator<T extends Enum<T>> |
class |
FloatComparator |
class |
FloatValueComparator
Specialized comparator for FloatValue based on CopyableValueComparator.
|
class |
InstantComparator
Comparator for comparing Java Instant.
|
class |
IntComparator |
class |
IntValueComparator
Specialized comparator for IntValue based on CopyableValueComparator.
|
class |
LocalDateComparator
This class can not extend
BasicTypeComparator , because LocalDate is a Comparable of
ChronoLocalDate instead of Comparable of LocalDate. |
class |
LocalDateTimeComparator
This class can not extend
BasicTypeComparator , because LocalDateTime is a Comparable of
ChronoLocalDateTime instead of Comparable of LocalDateTime. |
class |
LocalTimeComparator |
class |
LongComparator |
class |
LongValueComparator
Specialized comparator for LongValue based on CopyableValueComparator.
|
class |
NullValueComparator
Specialized comparator for NullValue based on CopyableValueComparator.
|
class |
ShortComparator |
class |
ShortValueComparator
Specialized comparator for ShortValue based on CopyableValueComparator.
|
class |
SqlTimestampComparator
Comparator for comparing Java SQL Timestamps.
|
class |
StringComparator |
class |
StringValueComparator
Specialized comparator for StringValue based on CopyableValueComparator.
|
Modifier and Type | Method and Description |
---|---|
int |
BooleanValueComparator.compareToReference(TypeComparator<BooleanValue> referencedComparator) |
int |
ByteValueComparator.compareToReference(TypeComparator<ByteValue> referencedComparator) |
int |
CharValueComparator.compareToReference(TypeComparator<CharValue> referencedComparator) |
int |
DoubleValueComparator.compareToReference(TypeComparator<DoubleValue> referencedComparator) |
int |
FloatValueComparator.compareToReference(TypeComparator<FloatValue> referencedComparator) |
int |
IntValueComparator.compareToReference(TypeComparator<IntValue> referencedComparator) |
int |
LocalDateComparator.compareToReference(TypeComparator<java.time.LocalDate> referencedComparator) |
int |
LocalDateTimeComparator.compareToReference(TypeComparator<java.time.LocalDateTime> referencedComparator) |
int |
LongValueComparator.compareToReference(TypeComparator<LongValue> referencedComparator) |
int |
NullValueComparator.compareToReference(TypeComparator<NullValue> referencedComparator) |
int |
ShortValueComparator.compareToReference(TypeComparator<ShortValue> referencedComparator) |
int |
StringValueComparator.compareToReference(TypeComparator<StringValue> referencedComparator) |
int |
BasicTypeComparator.compareToReference(TypeComparator<T> referencedComparator) |
Modifier and Type | Class and Description |
---|---|
class |
BooleanPrimitiveArrayComparator |
class |
BytePrimitiveArrayComparator |
class |
CharPrimitiveArrayComparator |
class |
DoublePrimitiveArrayComparator |
class |
FloatPrimitiveArrayComparator |
class |
IntPrimitiveArrayComparator |
class |
LongPrimitiveArrayComparator |
class |
PrimitiveArrayComparator<T,C extends BasicTypeComparator> |
class |
ShortPrimitiveArrayComparator |
Modifier and Type | Method and Description |
---|---|
TypeComparator<char[]> |
CharPrimitiveArrayComparator.duplicate() |
TypeComparator<double[]> |
DoublePrimitiveArrayComparator.duplicate() |
TypeComparator<long[]> |
LongPrimitiveArrayComparator.duplicate() |
TypeComparator<boolean[]> |
BooleanPrimitiveArrayComparator.duplicate() |
TypeComparator<int[]> |
IntPrimitiveArrayComparator.duplicate() |
TypeComparator<byte[]> |
BytePrimitiveArrayComparator.duplicate() |
TypeComparator<short[]> |
ShortPrimitiveArrayComparator.duplicate() |
TypeComparator<float[]> |
FloatPrimitiveArrayComparator.duplicate() |
TypeComparator[] |
PrimitiveArrayComparator.getFlatComparators() |
Modifier and Type | Method and Description |
---|---|
int |
PrimitiveArrayComparator.compareToReference(TypeComparator<T> referencedComparator) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
WritableTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
GenericTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
EnumTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<T> |
ValueTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
TypeComparator<Row> |
RowTypeInfo.createComparator(int[] logicalKeyFields,
boolean[] orders,
int logicalFieldOffset,
ExecutionConfig config) |
Modifier and Type | Class and Description |
---|---|
class |
CopyableValueComparator<T extends CopyableValue<T> & Comparable<T>>
Comparator for all Value types that extend Key
|
class |
GenericTypeComparator<T extends Comparable<T>>
TypeComparator for all types that extend Comparable.
|
class |
NullAwareComparator<T>
Null-aware comparator that wraps a comparator which does not support null references.
|
class |
PojoComparator<T> |
class |
RowComparator
Comparator for
Row . |
class |
TupleComparator<T extends Tuple> |
class |
TupleComparatorBase<T> |
class |
ValueComparator<T extends Value & Comparable<T>>
Comparator for all Value types that extend Key
|
class |
WritableComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>>
A
TypeComparator for Writable . |
Modifier and Type | Field and Description |
---|---|
protected TypeComparator[] |
TupleComparatorBase.comparators
comparators for the key fields, in the same order as the key fields
|
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
RuntimeComparatorFactory.createComparator() |
TypeComparator<T> |
WritableComparator.duplicate() |
TypeComparator<T> |
GenericTypeComparator.duplicate() |
TypeComparator<T> |
NullAwareComparator.duplicate() |
TypeComparator<T> |
TupleComparator.duplicate() |
TypeComparator<T> |
ValueComparator.duplicate() |
TypeComparator<Row> |
RowComparator.duplicate() |
TypeComparator<T> |
CopyableValueComparator.duplicate() |
TypeComparator[] |
WritableComparator.getFlatComparators() |
TypeComparator[] |
GenericTypeComparator.getFlatComparators() |
TypeComparator[] |
NullAwareComparator.getFlatComparators() |
TypeComparator[] |
ValueComparator.getFlatComparators() |
TypeComparator<?>[] |
CopyableValueComparator.getFlatComparators() |
Modifier and Type | Method and Description |
---|---|
int |
RowComparator.compareToReference(TypeComparator<Row> referencedComparator) |
int |
WritableComparator.compareToReference(TypeComparator<T> referencedComparator) |
int |
GenericTypeComparator.compareToReference(TypeComparator<T> referencedComparator) |
int |
NullAwareComparator.compareToReference(TypeComparator<T> referencedComparator) |
int |
TupleComparatorBase.compareToReference(TypeComparator<T> referencedComparator) |
int |
ValueComparator.compareToReference(TypeComparator<T> referencedComparator) |
int |
PojoComparator.compareToReference(TypeComparator<T> referencedComparator) |
int |
CopyableValueComparator.compareToReference(TypeComparator<T> referencedComparator) |
TypePairComparator<T1,T2> |
RuntimePairComparatorFactory.createComparator12(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
TypePairComparator<T1,T2> |
RuntimePairComparatorFactory.createComparator12(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
TypePairComparator<T2,T1> |
RuntimePairComparatorFactory.createComparator21(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
TypePairComparator<T2,T1> |
RuntimePairComparatorFactory.createComparator21(TypeComparator<T1> comparator1,
TypeComparator<T2> comparator2) |
Modifier and Type | Method and Description |
---|---|
void |
TupleComparatorBase.getFlatComparator(List<TypeComparator> flatComparators) |
void |
RowComparator.getFlatComparator(List<TypeComparator> flatComparators) |
void |
PojoComparator.getFlatComparator(List<TypeComparator> flatComparators) |
Constructor and Description |
---|
NullAwareComparator(TypeComparator<T> wrappedComparator,
boolean order) |
PojoComparator(Field[] keyFields,
TypeComparator<?>[] comparators,
TypeSerializer<T> serializer,
Class<T> type) |
RowComparator(int arity,
int[] keyPositions,
TypeComparator<Object>[] comparators,
TypeSerializer<Object>[] serializers,
boolean[] orders)
General constructor for RowComparator.
|
RuntimeComparatorFactory(TypeComparator<T> comparator) |
TupleComparator(int[] keyPositions,
TypeComparator<?>[] comparators,
TypeSerializer<?>[] serializers) |
TupleComparatorBase(int[] keyPositions,
TypeComparator<?>[] comparators,
TypeSerializer<?>[] serializers) |
Modifier and Type | Method and Description |
---|---|
TypeComparator<LongValueWithProperHashCode> |
LongValueWithProperHashCode.LongValueWithProperHashCodeTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig) |
Modifier and Type | Class and Description |
---|---|
class |
ByteValueArrayComparator
Specialized comparator for ByteValueArray based on CopyableValueComparator.
|
class |
CharValueArrayComparator
Specialized comparator for CharValueArray based on CopyableValueComparator.
|
class |
DoubleValueArrayComparator
Specialized comparator for DoubleValueArray based on CopyableValueComparator.
|
class |
FloatValueArrayComparator
Specialized comparator for FloatValueArray based on CopyableValueComparator.
|
class |
IntValueArrayComparator
Specialized comparator for IntValueArray based on CopyableValueComparator.
|
class |
LongValueArrayComparator
Specialized comparator for LongValueArray based on CopyableValueComparator.
|
class |
NullValueArrayComparator
Specialized comparator for NullValueArray based on CopyableValueComparator.
|
class |
ShortValueArrayComparator
Specialized comparator for ShortValueArray based on CopyableValueComparator.
|
class |
StringValueArrayComparator
Specialized comparator for StringValueArray based on CopyableValueComparator.
|
Modifier and Type | Method and Description |
---|---|
int |
ByteValueArrayComparator.compareToReference(TypeComparator<ByteValueArray> referencedComparator) |
int |
CharValueArrayComparator.compareToReference(TypeComparator<CharValueArray> referencedComparator) |
int |
DoubleValueArrayComparator.compareToReference(TypeComparator<DoubleValueArray> referencedComparator) |
int |
FloatValueArrayComparator.compareToReference(TypeComparator<FloatValueArray> referencedComparator) |
int |
IntValueArrayComparator.compareToReference(TypeComparator<IntValueArray> referencedComparator) |
int |
LongValueArrayComparator.compareToReference(TypeComparator<LongValueArray> referencedComparator) |
int |
NullValueArrayComparator.compareToReference(TypeComparator<NullValueArray> referencedComparator) |
int |
ShortValueArrayComparator.compareToReference(TypeComparator<ShortValueArray> referencedComparator) |
int |
StringValueArrayComparator.compareToReference(TypeComparator<StringValueArray> referencedComparator) |
Modifier and Type | Field and Description |
---|---|
protected TypeComparator<?>[] |
BatchTask.inputComparators
The comparators for the central driver.
|
Modifier and Type | Method and Description |
---|---|
<X> TypeComparator<X> |
TaskContext.getDriverComparator(int index) |
<X> TypeComparator<X> |
BatchTask.getDriverComparator(int index) |
Modifier and Type | Field and Description |
---|---|
protected TypeComparator<BT> |
MutableHashTable.buildSideComparator
The utilities to hash and compare the build side data types.
|
protected TypeComparator<T> |
AbstractMutableHashTable.buildSideComparator
The utilities to hash and compare the build side data types.
|
protected TypeComparator<PT> |
AbstractHashTableProber.probeTypeComparator |
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
AbstractMutableHashTable.getBuildSideComparator() |
TypeComparator<PT> |
MutableHashTable.getProbeSideComparator() |
Modifier and Type | Method and Description |
---|---|
<BT,PT> MutableHashTable<BT,PT> |
ReusingBuildFirstReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
ReusingBuildFirstReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
NonReusingBuildFirstReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
NonReusingBuildFirstReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
HashJoinIteratorBase.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBloomFilters) |
<BT,PT> MutableHashTable<BT,PT> |
HashJoinIteratorBase.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBloomFilters) |
<BT,PT> MutableHashTable<BT,PT> |
ReusingBuildSecondReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
ReusingBuildSecondReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
NonReusingBuildSecondReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<BT,PT> MutableHashTable<BT,PT> |
NonReusingBuildSecondReOpenableHashJoinIterator.getHashJoin(TypeSerializer<BT> buildSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean useBitmapFilters) |
<PT> CompactingHashTable.HashTableProber<PT> |
CompactingHashTable.getProber(TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,T> pairComparator) |
abstract <PT> AbstractHashTableProber<PT,T> |
AbstractMutableHashTable.getProber(TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,T> pairComparator) |
<PT> InPlaceMutableHashTable.HashTableProber<PT> |
InPlaceMutableHashTable.getProber(TypeComparator<PT> probeTypeComparator,
TypePairComparator<PT,T> pairComparator) |
Constructor and Description |
---|
AbstractHashTableProber(TypeComparator<PT> probeTypeComparator,
TypePairComparator<PT,BT> pairComparator) |
AbstractMutableHashTable(TypeSerializer<T> buildSideSerializer,
TypeComparator<T> buildSideComparator) |
CompactingHashTable(TypeSerializer<T> buildSideSerializer,
TypeComparator<T> buildSideComparator,
List<MemorySegment> memorySegments) |
CompactingHashTable(TypeSerializer<T> buildSideSerializer,
TypeComparator<T> buildSideComparator,
List<MemorySegment> memorySegments,
int avgRecordLen) |
HashTableProber(TypeComparator<PT> probeTypeComparator,
TypePairComparator<PT,T> pairComparator) |
InPlaceMutableHashTable(TypeSerializer<T> serializer,
TypeComparator<T> comparator,
List<MemorySegment> memory) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
boolean useBloomFilters) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
boolean useBloomFilters) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
int avgRecordLen,
boolean useBloomFilters) |
MutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
int avgRecordLen,
boolean useBloomFilters) |
NonReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
NonReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReOpenableMutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
boolean useBitmapFilters) |
ReOpenableMutableHashTable(TypeSerializer<BT> buildSideSerializer,
TypeSerializer<PT> probeSideSerializer,
TypeComparator<BT> buildSideComparator,
TypeComparator<PT> probeSideComparator,
TypePairComparator<PT,BT> comparator,
List<MemorySegment> memorySegments,
IOManager ioManager,
boolean useBitmapFilters) |
ReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildFirstHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildFirstReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V2,V1> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildSecondHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
ReusingBuildSecondReOpenableHashJoinIterator(MutableObjectIterator<V1> firstInput,
MutableObjectIterator<V2> secondInput,
TypeSerializer<V1> serializer1,
TypeComparator<V1> comparator1,
TypeSerializer<V2> serializer2,
TypeComparator<V2> comparator2,
TypePairComparator<V1,V2> pairComparator,
MemoryManager memManager,
IOManager ioManager,
AbstractInvokable ownerTask,
double memoryFraction,
boolean probeSideOuterJoin,
boolean buildSideOuterJoin,
boolean useBitmapFilters) |
Constructor and Description |
---|
OutputEmitter(ShipStrategyType strategy,
int indexInSubtaskGroup,
TypeComparator<T> comparator,
Partitioner<?> partitioner,
DataDistribution distribution) |
OutputEmitter(ShipStrategyType strategy,
TypeComparator<T> comparator)
Creates a new channel selector that uses the given strategy (broadcasting, partitioning, ...)
and uses the supplied comparator to hash / compare records for partitioning them
deterministically.
|
Modifier and Type | Method and Description |
---|---|
protected <T> KeyGroupedIterator<T> |
ReusingMergeOuterJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected abstract <T> KeyGroupedIterator<T> |
AbstractMergeIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected <T> KeyGroupedIterator<T> |
ReusingMergeInnerJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected <T> KeyGroupedIterator<T> |
NonReusingMergeInnerJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
protected <T> KeyGroupedIterator<T> |
NonReusingMergeOuterJoinIterator.createKeyGroupedIterator(MutableObjectIterator<T> input,
TypeSerializer<T> serializer,
TypeComparator<T> comparator) |
static <E> ExternalSorterBuilder<E> |
ExternalSorter.newBuilder(MemoryManager memoryManager,
AbstractInvokable parentTask,
TypeSerializer<E> serializer,
TypeComparator<E> comparator)
Creates a builder for the
ExternalSorter . |
Modifier and Type | Method and Description |
---|---|
TypeComparator<E> |
NonReusingKeyGroupedIterator.getComparatorWithCurrentReference() |
TypeComparator<E> |
ReusingKeyGroupedIterator.getComparatorWithCurrentReference() |
Constructor and Description |
---|
NonReusingKeyGroupedIterator(MutableObjectIterator<E> iterator,
TypeComparator<E> comparator)
Initializes the KeyGroupedIterator.
|
ReusingKeyGroupedIterator(MutableObjectIterator<E> iterator,
TypeSerializer<E> serializer,
TypeComparator<E> comparator)
Initializes the KeyGroupedIterator.
|
Modifier and Type | Method and Description |
---|---|
TypeComparator<T> |
TimeIntervalTypeInfo.createComparator(boolean sortOrderAscending,
ExecutionConfig executionConfig)
Deprecated.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.