org.apache.flink.streaming.api.operators

类 OperatorAttributesBuilder

java.lang.Object

org.apache.flink.streaming.api.operators.OperatorAttributesBuilder

@Experimental
public class OperatorAttributesBuilder
extends Object

The builder class for OperatorAttributes.

构造器概要

构造器

构造器和说明
OperatorAttributesBuilder()

方法概要

限定符和类型	方法和说明
OperatorAttributes	build()
OperatorAttributesBuilder	setInternalSorterSupported(boolean internalSorterSupported)
OperatorAttributesBuilder	setOutputOnlyAfterEndOfStream(boolean outputOnlyAfterEndOfStream) Set to true if and only if the operator only emits records after all its inputs have ended.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

OperatorAttributesBuilder

public OperatorAttributesBuilder()

方法详细资料

setOutputOnlyAfterEndOfStream

public OperatorAttributesBuilder setOutputOnlyAfterEndOfStream(boolean outputOnlyAfterEndOfStream)

Set to true if and only if the operator only emits records after all its inputs have ended. If it is not set, the default value false is used.

setInternalSorterSupported

public OperatorAttributesBuilder setInternalSorterSupported(boolean internalSorterSupported)

build

public OperatorAttributes build()