v0.8.0

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 requires adjustments for implementers of custom Beams (there is a new sendAll method to implement). See http://static.druid.io/tranquility/api/v0.8.0/#com.metamx.tranquility.beam.Beam for the updated trait.

New features:

• Support for flattenSpec. (#113)
• Support for formats other than JSON. (#119)
• Support all Druid formats by using InputRows internally. (#140)
• Allow setting lingerMillis to -1 to always wait for complete batches. (#147)

Improvements:

• DruidBeamMaker: Use availabilityGroup no longer tied to baseFirehoseId. (#152)
• Update to druid-0.9.0. (#155)
• Remove dimension sorting workaround. (#156)
• Add some additional hourly cycling to minutely cycleBuckets. (#171)

Bug fixes:

• Respect druid.discovery.curator.path in fromConfig. (#151)
• Spark: Share Tranquilizers using registry in BeamRDD. (#168)

Other:

• .gitignore derby metadata created by tests. (#149)
• Benchmarks: Remove unused dimensions, use somewhat more iterations. (#167)
• Add tests for JSON with flattenSpec. (#170)