Renaming: org.apache.flink.streaming.util.extractor (new package); contains all extractors.; Extractors are used in delta functions to extract the part of the data from the input on which the delta gets calculated.; Extractors are beside this more general applicable. They can also be used to extract fields for the punctuation based windowing.
org.apache.flink.streaming.util.deltafunction (new package); contains distance measures which can be used in delta functions.; So far there are euclidean distance and cosine distance.
org.apache.flink.streaming.util.extractor.Extractor (rename/move); old name: NextGenExtractor; old position: org.apache.flink.streaming.api.invokable.operator; After we have a package for extractors in util I moved the interface to this position as well. The old position does not fit.
org.apache.flink.streaming.api.windowing... (new packages); This package holds as parent for all the new windowing classes.; Classes will be structured in sub packages.; I also moved .util.deltafunction and .util.extractor respectively.
Moved all remaining files and removed NextGen prefix from file names.; old names: NextGen[X]; new names: [X]; old positions: various - mostly ...invokable.operator; new positions: org.apache.flink.streaming.api.windowing...
moved the tests CountPolicy and DeltaPolicy and suppressed warnings