Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Implemented
-
None
Description
- Add an implement PipelineStage, Estimator, Transformer, Model.
- Add MLSession to hold the execution environment and others session shared variable.
- Add AlgoOperator for the implementation of algorithms.
- Add BatchOperator and StreamOperator based on AlgoOperator
- Add TableSourceBatchOp and TableSourceStreamOp
Attachments
Issue Links
- Dependent
-
FLINK-13596 Add two utils for Table transformations.
- Closed
- links to