THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
@Public
public abstract class TypeInformation<T> implements Serializable {
/**
* Creates a serializer for the type.
* The serializer may use the ReadableExecutionConfig for parameterization.
*
* @param config The config used to parameterize the serializer.
* @return A serializer for this type.
*/
@PublicEvolving
public abstract TypeSerializer<T> createSerializer(ReadableExecutionConfig config);
} |
| 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
...