Uses of Interface
org.apache.flink.table.runtime.generated.Projection

Packages that use Projection

Package	Description
org.apache.flink.table.runtime.hashtable
org.apache.flink.table.runtime.operators.join

Uses of Projection in org.apache.flink.table.runtime.hashtable

Constructors in org.apache.flink.table.runtime.hashtable with parameters of type Projection

Constructor and Description
BinaryHashTable(Configuration conf, Object owner, AbstractRowSerializer buildSideSerializer, AbstractRowSerializer probeSideSerializer, Projection<BaseRow,BinaryRow> buildSideProjection, Projection<BaseRow,BinaryRow> probeSideProjection, MemoryManager memManager, long reservedMemorySize, IOManager ioManager, int avgRecordLen, int buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)
BinaryHashTable(Configuration conf, Object owner, AbstractRowSerializer buildSideSerializer, AbstractRowSerializer probeSideSerializer, Projection<BaseRow,BinaryRow> buildSideProjection, Projection<BaseRow,BinaryRow> probeSideProjection, MemoryManager memManager, long reservedMemorySize, IOManager ioManager, int avgRecordLen, int buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)
BinaryHashTable(Configuration conf, Object owner, AbstractRowSerializer buildSideSerializer, AbstractRowSerializer probeSideSerializer, Projection<BaseRow,BinaryRow> buildSideProjection, Projection<BaseRow,BinaryRow> probeSideProjection, MemoryManager memManager, long reservedMemorySize, long preferredMemorySize, long perRequestMemorySize, IOManager ioManager, int avgRecordLen, long buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)
BinaryHashTable(Configuration conf, Object owner, AbstractRowSerializer buildSideSerializer, AbstractRowSerializer probeSideSerializer, Projection<BaseRow,BinaryRow> buildSideProjection, Projection<BaseRow,BinaryRow> probeSideProjection, MemoryManager memManager, long reservedMemorySize, long preferredMemorySize, long perRequestMemorySize, IOManager ioManager, int avgRecordLen, long buildRowCount, boolean useBloomFilters, HashJoinType type, JoinCondition condFunc, boolean reverseJoin, boolean[] filterNulls, boolean tryDistinctBuildRow)

Uses of Projection in org.apache.flink.table.runtime.operators.join

Constructors in org.apache.flink.table.runtime.operators.join with parameters of type Projection

Constructor and Description
SortMergeFullOuterJoinIterator(BinaryRowSerializer serializer1, BinaryRowSerializer serializer2, Projection<BaseRow,BinaryRow> projection1, Projection<BaseRow,BinaryRow> projection2, RecordComparator keyComparator, MutableObjectIterator<BinaryRow> iterator1, MutableObjectIterator<BinaryRow> iterator2, ResettableExternalBuffer buffer1, ResettableExternalBuffer buffer2, boolean[] filterNulls)
SortMergeFullOuterJoinIterator(BinaryRowSerializer serializer1, BinaryRowSerializer serializer2, Projection<BaseRow,BinaryRow> projection1, Projection<BaseRow,BinaryRow> projection2, RecordComparator keyComparator, MutableObjectIterator<BinaryRow> iterator1, MutableObjectIterator<BinaryRow> iterator2, ResettableExternalBuffer buffer1, ResettableExternalBuffer buffer2, boolean[] filterNulls)
SortMergeInnerJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection probeProjection, Projection bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeInnerJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection probeProjection, Projection bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNulls)
SortMergeJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNulls)
SortMergeOneSideOuterJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)
SortMergeOneSideOuterJoinIterator(BinaryRowSerializer probeSerializer, BinaryRowSerializer bufferedSerializer, Projection<BaseRow,BinaryRow> probeProjection, Projection<BaseRow,BinaryRow> bufferedProjection, RecordComparator keyComparator, MutableObjectIterator<BaseRow> probeIterator, MutableObjectIterator<BinaryRow> bufferedIterator, ResettableExternalBuffer buffer, boolean[] filterNullKeys)