[FLINK-12985] Move & rename StreamTransformation to org.apache.flink.api.dag.Transformation

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.9.0
• Fix Version/s: 1.9.0
• Component/s: API / DataStream
• Labels: pull-request-available
• Assignee: Dawid Wysakowicz
• Reporter: Dawid Wysakowicz
• Created: 25/Jun/19 13:22
• Updated: 28/Jun/19 10:09
• Resolved: 28/Jun/19 10:09

Description

It is quite strange to have a streaming package in flink-core. Moreover right now the StreamTransformation#setChainingStrategy throws Exception in half of the transformations.
I suggest to:

1. rename the StreamTransformation to org.apache.flink.api.dag.Transformation
2. extract #setChainingMethod to a separate class PhysicalTransformation & move the ChainingStrategy back to the flink-streaming-java module

Issue Links

• links to: GitHub Pull Request #8876