Class OperatorAttributes
- java.lang.Object
-
- org.apache.flink.streaming.api.operators.OperatorAttributes
-
- All Implemented Interfaces:
Serializable
@Experimental public class OperatorAttributes extends Object implements Serializable
OperatorAttributes element provides Job Manager with information that can be used to optimize job performance.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
isInternalSorterSupported()
Returns true iff the operator uses an internal sorter to sort inputs by key.boolean
isOutputOnlyAfterEndOfStream()
Returns true if and only if the operator only emits records after all its inputs have ended.
-
-
-
Method Detail
-
isOutputOnlyAfterEndOfStream
public boolean isOutputOnlyAfterEndOfStream()
Returns true if and only if the operator only emits records after all its inputs have ended.Here are the implications when it is true:
- The results of this operator as well as its chained operators have blocking partition type.
- This operator as well as its chained operators will be executed in batch mode.
-
isInternalSorterSupported
public boolean isInternalSorterSupported()
Returns true iff the operator uses an internal sorter to sort inputs by key. When it is true, the input records will not to be sorted externally before being fed into this operator.
-
-