Package | Description |
---|---|
org.apache.flink.runtime.operators | |
org.apache.flink.runtime.operators.sort | |
org.apache.flink.runtime.operators.util |
Modifier and Type | Class and Description |
---|---|
class |
TempBarrier<T> |
Modifier and Type | Field and Description |
---|---|
protected CloseableInputProvider<?>[] |
BatchTask.localStrategies
The local strategies that are applied on the inputs.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Sorter<E>
The SortMerger interface representing the public interface to all specific Sort-Merge implementations.
|
Modifier and Type | Class and Description |
---|---|
class |
CombiningUnilateralSortMerger<E>
The CombiningUnilateralSortMerger is part of a merge-sort implementation.
|
class |
UnilateralSortMerger<E>
The
UnilateralSortMerger is a full fledged sorter. |
Modifier and Type | Class and Description |
---|---|
class |
SimpleCloseableInputProvider<E>
A simple iterator provider that returns a supplied iterator and does nothing when closed.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.