[FLINK-947] Add support for "Named Datasets"

• Type: New Feature
• Status: Resolved
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 0.9
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 18/Jun/14 12:12
• Updated: 28/Feb/19 14:29
• Resolved: 20/Mar/15 10:17

Description

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:

NamedDataSet one = ...
NamedDataSet two = ...
NamedDataSet result = one.join(two).where("key").equalTo("otherKey")
  .project("a", "b", "c")
  .map( (UserTypeIn in) -> return new UserTypeOut(...) )
  .print();

Issue Links

• duplicates: FLINK-668 API Proposal - NamedDataSets