package org.apache.flink.streaming.api.operators;

/** The builder class for {@link OperatorAttributes}. */
@PublicEvolving
public class OperatorAttributesBuilder {
    @Nullable private Boolean isOutputOnEOF = null;
    @Nullable private Boolean isOutputOnCheckpoint = null; 
    @Nullable private Boolean hasInternalSorterisInternalSorterSupported = null; 

    public OperatorAttributesBuilder() {...}

    public OperatorAttributesBuilder setIsOutputOnEOF(boolean isOutputOnEOF) {...}

    public OperatorAttributesBuilder setIsOutputOnCheckpoint(boolean isOutputOnCheckpoint) {...}

    public OperatorAttributesBuilder setHasInternalSortersetIsInternalSorterSupported(boolean hasInternalSorterisInternalSorterSupported) {...}

    /**
     * If any operator attribute is null, we will log it at DEBUG level and use the following
     * default values.
     * - isOutputOnEOF defaults to false
     * - isOutputOnCheckpoint defaults to false
     * - hasInternalSorterisInternalSorterSupported defaults to false
     */ 
     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.
 */
@PublicEvolving
public class OperatorAttributes {     
   /**
     * Returns true iff the operator can only emit records after inputs have reached EOF.
     *
     * <p>Here are the implications when it is true:
     *
     * <ul>
     *   <li>Its output edges are blocking.
     *   <li>It does not support checkpoint.
     * </ul>
     */
    public boolean getIsOutputOnEOF() {...}

    /**
     * Returns true iff the operator can only emit records when checkpoint is triggered.
     *
     * <p>If true, the job should trigger checkpoint in order to flush data to sinks.
     */
    public boolean getIsOutputOnCheckpoint() {...}

    /**
     * Returns true iff the operator sorts data internally when checkpoint can be disabled.
     * 
     * <p>Here are the implications when it is true Checkpoint can be disabled disabled in any of the following cases:
     *
 - execution.runtime-mode == BATCH *execution <ul>mode.
     *   <li>Its - execution.checkpointing.interval-during-backlog == 0.
	 * - isOutputOnEOF == true.
     *
     * <p>Here are the implications when it is true AND checkpoint is disabled:
     *
     * <ul>
     *   <li>Its input records do not need to be sorted externally.
     *   <li>Its managed memory should be set according to execution.sorted-inputs.memory.
     *   <li>It does not support checkpoint when any input has isBacklog=true.
     * </ul>
     */
    public boolean getHasInternalSortergetIsInternalSorterSupported() {...}
}

@Internal
public abstract class Transformation<T> {
    public boolean getIsOutputOnEOF() {
        return false;
    }

    public boolean getIsOutputOnCheckpoint() {
        return false;
    }

    public boolean getHasInternalSortergetIsInternalSorterSupported() {
        return false;
    }
}