This closes #3676.

This closes #3677.

This closes #3605.

- implements Runnable instead of extending Thread
- use AtomicRefence<String> instead of StringBuilder
- remove redundant wrapInException argument

This closes #3662.

This closes #3572.

This closes #3612.

This closes #3628.

Adds the reference to the maven dependecy for flink-avro
in the "Avro support in Flink" section.

This closes #3638.

This closes #3665.

This closes #3671.

this closes #3667

This closes #3593.

This closes #3613.

The Gelly drivers started as simple wrappers around library algorithms
but have grown to handle a matrix of input sources while often running
multiple algorithms and analytics with custom parameterization.

The monolithic drivers are replaced with separate inputs and algorithms.
Command-line parameter parsers are shared and reusable across inputs and
algorithms. Algorithm results now implement a common AlgorithmResult
interface. Drivers are now tested with integration tests.

This closes #3294

This closes #3641.
This closes #3590.
This closes #3550.

Replace existing and create new algorithm Driver implementations for
each of the library methods.

This closes #3635

Create Input classes for reading graphs from CSV as well as for each of
the graph generators.

This closes #3626

Provide compact and efficiently serializable and comparable array
implementations for Flink mutable Value types and Java primitives.

This cloeses #3382

WorksetIterationNode#instantiate loops over all solution and work set
candidates. Since the solution set reference is modified in place when
the predecessor node can be used in its place, swith this variable to
the inner loop.

This closes #3563

This closes #3408.

This closes #3647.

With this, the CEP library assumes correctness of the watermark
and considers as late, events that arrive having a timestamp
smaller than that of the last seen watermark. Late events are not
silently dropped, but the user can specify to send them to a side
output.

This closes #3458.

[FLINK-5625] [kinesis] Configurable date format for timestamp-based start position in FlinkKinesisConsumer

This closes #3651.

This closes #3653.
This closes #3574.

This closes #3649.

Allows looping states (oneOrMore, zeroOrMore, times) to specify
if they want their elements to be consecutive or allow non-matching
elements in-between.

This closes #3629.