Bulk Operation

FLINK-3957 Drop ".returns()" for TypeInformation in the DataStream API

FLINK-3957 Use Java's Duration instead of Flink's Time

FLINK-3957 `ProcessingTimeSessionWindows` and `EventTimeSessionWindows` should be generic

FLINK-3957 Drop canEqual() from TypeInformation, TypeSerializer, etc.

FLINK-3957 Do not expose keyed operations on ProcessFunction.Context

FLINK-3957 Remove ClassTag in Scala DataSet API

FLINK-3957 Consider changing the RichFunction#open method signature to take no arguments.

FLINK-3957 Fix LongValue hashCode

FLINK-3957 Use TypeComparator.hash() instead of Object.hashCode() for keying in DataStream API

FLINK-3957 Remove all ad-hoc config loading via GlobalConfiguration

FLINK-3957 Introduce backwards compatible state to task assignment

FLINK-3957 Make Path immutable

FLINK-3957 Remove Deprecated Methods from WindowedStream

FLINK-3957 Remove Checked Exceptions from State Interfaces

FLINK-3957 Unify Stream Sinks and OutputFormats

FLINK-3957 Remove IOReadableWritable from classes where not needed

FLINK-3957 Unify "GlobalJobParameters" and "Configuration"

FLINK-3957 Remove Parameter from WindowAssigner.getDefaultTrigger()

FLINK-3957 Move RocksDB backend to proper package

FLINK-3957 Remove with method from CoGroupedStream and JoinedStream, and change apply method return type

FLINK-3957 Offer separate API for watermark generation and timestamp extraction

FLINK-3957 Consider removing min()/minBy()/max()/maxBy()/sum() utility methods from the DataStream API

FLINK-3957 Consider moving the file sources from the StreamExecutionEnvironment to the flink-connector-filesystem

FLINK-3957 Remove Key interface

FLINK-3957 Remove deprecated configuration keys from ConfigConstants

FLINK-3957 Rename readFileStream from the StreamExecutionEnvironment

FLINK-3957 Remove implicit sinks

FLINK-3957 Scala DataStream#addSink returns Java DataStreamSink