Page History

package org.apache.flink.streaming.api.operators;
 
/** The builder class for {@link OperatorAttributes}. */
@Experimental
public class OperatorAttributesBuilder {
    @Nullable private Boolean outputOnEOF = null;
 
    public OperatorAttributesBuilder() {...}        

  	
  	/**
     * Set whether to true if and only if the operator only emits records resultsafter whenall its inputinputs has ended. */have ended.
     * If it is not set, the default value false is used.
     */   
     public OperatorAttributesBuilder setOutputOnEOF(setOutputOnlyAfterEndOfStream(
            boolean outputOnEOFoutputOnlyAfterEndOfStream) {...}

     
    /**
     * If any operator attribute is null, we will log it at DEBUG level and useset theit following
     *to the default values.
     * - outputOnEOF defaults to falsevalue.
     */
      public OperatorAttributes build() {...}
}

package org.apache.flink.streaming.api.operators;
 
/**
 * OperatorAttributes element provides Job Manager with information that can be
 * used to optimize the job performance.
 */
@Experimental
public class OperatorAttributes {
  
    /**
     * Returns true iffif and only if the operator only emits records after all its inputs have reached EOFended.
       *
     * <p>Here are the implications when it is true:
     *
     * <ul>
     *   <li> The results of this operator as well as its chained operators have blocking partition type.
     *   <li> This operator as well as its chained operators will be executed in batch mode.
     * </ul>
     */
      
	public boolean isOutputOnEOFisOutputOnlyAfterEndOfStream() {...}
}