THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Discussion thread | https://lists.apache.org/thread/qq39rmg3f23ysx5m094s4c4cq0m4tdj5 | ||||||||
|---|---|---|---|---|---|---|---|---|---|
| Vote thread | -https://lists.apache.org/thread/oy9mdmh6gk8pc0wjdk5kg8dz3jllz9ow | ||||||||
| JIRA |
| ||||||||
| Release | - |
...
| Code Block | ||
|---|---|---|
| ||
package org.apache.flink.streaming.api.operators;
/** The builder class for {@link OperatorAttributes}. */
@Experimental
public class OperatorAttributesBuilder {
public OperatorAttributesBuilder() {...}
/**
* 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.
*/
public OperatorAttributesBuilder setOutputOnlyAfterEndOfStream(
boolean outputOnlyAfterEndOfStream) {...}
/**
* If any operator attribute is not set nullexplicitly, we will log it at DEBUG level and set it to the default
* value.
*/
public OperatorAttributes build() {...}
} |
| Code Block | ||
|---|---|---|
| ||
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 if and only if the operator only emits records after all its inputs have ended.
*
* <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 isOutputOnlyAfterEndOfStream() {...}
} |
...