THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
@PublicEvolving public interface Sink<InputT> extends Serializable { ... current methods @PublicEvolving public interface InitContext { ... current methods /** * Returns the {@link ReadableExecutionConfig} for the currently executing job. */ ReadableExecutionConfig getReadableExecutionConfig(); /** * The ID of the current job. Note that Job ID can change in particular upon manual restart. * The returned ID should NOT be used for any job management tasks. */ JobID getJobId(); } } |
Compatibility, Deprecation, and Migration Plan
...