[
https://issues.apache.org/jira/browse/HUDI-608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
vinoyang closed HUDI-608.
-------------------------
Resolution: Won't Do
> Implement a flink datastream execution context
> ----------------------------------------------
>
> Key: HUDI-608
> URL: https://issues.apache.org/jira/browse/HUDI-608
> Project: Apache Hudi
> Issue Type: Sub-task
> Reporter: vinoyang
> Assignee: vinoyang
> Priority: Major
>
> Currently {{HoodieWriteClient}} does something like
> `hoodieRecordRDD.map().sort()` internally.. if we want to support Flink
> DataStream as the object, then we need to somehow define an abstraction like
> {{HoodieExecutionContext<T>}} which will have a common set of map(T) -> T,
> filter(), repartition() methods. There will be subclass like
> {{HoodieFlinkDataStreamExecutionContext<DataStream>}} which will implement it
> in Flink specific ways and hand back the transformed T object.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
