Page History

package org.apache.flink.streaming.api.operators;
 
/** The builder class for {@link OperatorAttributes}. */
@PublicEvolving
public class OperatorAttributesBuilder {     

	@Nullable private Boolean outputStreamRecordValueStored = null;
    @Nullable private Boolean inputStreamRecordStored = null;  

    public OperatorAttributesBuilder() {
    	...
    }

    /**
     * Set to truefalse if it is guaranteed that the operator will not store and access reference to the
     * StreamRecord#value that it has already emitted.
     */
    public OperatorAttributesBuilder setOutputStreamRecordValueStored(boolean outputStreamRecordValueStored) {...}

    /**
     * Set to false if it is guaranteed that the operator will not store and access reference to the
     * input StreamRecord instance.
     */
    public OperatorAttributesBuilder setInputStreamRecordStored(boolean inputStreamRecordStored) {...}
    
    /**
     * If any operator attribute is null, we will log it at DEBUG level and use the following
     * default values.
     * - outputStreamRecordValueStored defaults to true
     * - inputStreamRecordStored defaults to true
     */
	public OperatorAttributes build() {...}
}