Package | Description |
---|---|
org.apache.flink.runtime.iterative.io | |
org.apache.flink.runtime.operators.hash |
Class and Description |
---|
CompactingHashTable
A hash table that uses Flink's managed memory and supports replacement of records or
updates to records.
|
HashPartition |
Class and Description |
---|
AbstractHashTableProber |
AbstractMutableHashTable |
CompactingHashTable.HashTableProber |
HashJoinIteratorBase
Common methods for all Hash Join Iterators.
|
HashPartition |
InPlaceMutableHashTable.EntryIterator
WARNING: Doing any other operation on the table invalidates the iterator! (Even
using getMatchFor of a prober!)
|
InPlaceMutableHashTable.HashTableProber
A prober for accessing the table.
|
MutableHashTable
An implementation of a Hybrid Hash Join.
|
MutableHashTable.HashBucketIterator |
MutableHashTable.ProbeIterator |
NonReusingBuildFirstHashJoinIterator
An implementation of the
JoinTaskIterator that uses a hybrid-hash-join
internally to match the records with equal key. |
NonReusingBuildSecondHashJoinIterator
An implementation of the
JoinTaskIterator that uses a hybrid-hash-join
internally to match the records with equal key. |
ReusingBuildFirstHashJoinIterator
An implementation of the
JoinTaskIterator that uses a hybrid-hash-join
internally to match the records with equal key. |
ReusingBuildSecondHashJoinIterator
An implementation of the
JoinTaskIterator that uses a hybrid-hash-join
internally to match the records with equal key. |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.