Xu Yang created FLINK-13339:
-------------------------------
Summary: Add an implementation of pipeline's api
Key: FLINK-13339
URL: https://issues.apache.org/jira/browse/FLINK-13339
Project: Flink
Issue Type: Sub-task
Reporter: Xu Yang
* 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
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
