tranquility

Improvements:

• Add Second Granularity to DruidBeamMaker. (#178)
• Flink: Added option to throw an exception on dropped messages. (#180)
• Build against Druid 0.9.1. (#182)

Bug fixes:

• Flink: tranquility-flink supports only one sink operation. (#181)

New features:

• Server: Support for request compression. (#175)
• Add config for sending data to Druid using Smile. (#173)

Bug fixes:

• DruidBeams.fromConfig: Respect task.warmingPeriod. (#174)

Major changes this release include support for Druid 0.9.0 input formats and extensions, performance improvements due to timestamp caching, and an adjustment to the Beam trait that enables more fine grained error reporting.

Upgrading from earlier releases:

• The Beam trait changed in #140. The change is source-compatible for users of Beams and BeamFactories (all existing methods still work), but...

New features:

• Flink: Add Flink accumulators (#124)
• Optionally locate Druid tasks through "runningTasks" endpoint on the overlord. (#126)
• Samza: Include property for setting lingerMillis. (#127)
• Support full tuningConfig by handling it in a more loosely typed way. (#129)
• Server: Asynchronous API option. (#130)

Improvements:

• Disable Finagle fail-fast behavior by default. (#123)
• Cache...

New features:

• Flink module (#92)
• Add buildV9Directly to tuning object, defaults to false (#99)
• Tranquilizer.flush() to make batch / micro-batch oriented workflows easier (#110)
• Standardize on configuration files and use of Tranquilizer (#112)
• Console sender (#117)

Improvements:

• Adjust spark/flink examples to use event-time-based Timestamper (#100)
• Changes to make configuration files...