T
- The class type of the Stage implementation itself.@PublicEvolving public interface Stage<T extends Stage<T>> extends WithParams<T>, Serializable
Each stage is with parameters, and requires a public empty constructor for restoration.
NOTE: every Stage subclass should implement a static method with signature static T
load(StreamExecutionEnvironment env, String path)
, where T
refers to the concrete
subclass. This static method should instantiate a new stage instance based on the data read from
the given path.
Modifier and Type | Method and Description |
---|---|
void |
save(String path)
Saves this stage to the given path.
|
get, getParam, getParamMap, set
void save(String path) throws IOException
IOException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.