Aljoscha Krettek created FLINK-947:
--------------------------------------
Summary: Add support for "Named Datasets"
Key: FLINK-947
URL:
https://issues.apache.org/jira/browse/FLINK-947 Project: Flink
Issue Type: New Feature
Components: Java API
Reporter: Aljoscha Krettek
Assignee: Aljoscha Krettek
Priority: Minor
This would create an API that is a mix between SQL like declarativity and the power of user defined functions. Example user code could look like this:
{code:Java}
NamedDataSet one = ...
NamedDataSet two = ...
NamedDataSet result = one.join(two).where("key").equalTo("otherKey")
.project("a", "b", "c")
.map( (UserTypeIn in) -> return new UserTypeOut(...) )
.print();
{code}
--
This message was sent by Atlassian JIRA
(v6.2#6252)