- Fixes a bug in the LTuple2 class. Add a test for it: twitter#632
- Removing internal config setup from scalding platform: twitter#629
- Remove store that no one seems to use and has no tests: twitter#630
- Ianoc/optimization changes: twitter#628
- Fixes tests: twitter#626
- resilient to all stores being complete: twitter#627
- Resilient to a store being ahead: twitter#625
- move to scala test: twitter#621
- Killing off Summingbird Java: twitter#624
- Kill summingbird spark: twitter#622
- Bumping sbt versions: twitter#623
- Fixed erroneous comment in ClientStore's merge description: twitter#620
- bumping Scalding to 0.15.0, algebird to 0.10.1
- Registering summingbird counters with tormenta spouts #553
- Add counters to default summers #571
- Fixes the types off the summingbird java storm api #601
- Adding explicit hadoop deps; dfs-datastores to 1.3.6 #592
- Replace deprecated ClassManifest and erasure #608
- Spark monad #607
- replace deprecated erasure by runtimeClass #609
- Revert "Remove StripNameNodes" #610
- refactored core-tests into separate sub-project #593
- Fix checking delta batch in readDeltaTimestamps in batched store when merging #612
- ensure at least one batch before merging #613
- MergeableStoreFactory extends java.io.Serializable #616
- Spout storm metrics foreach #617
- upgrade scalacheck #615
- Use latest bijection, algebird, scalding, storehaus, chill, and tormenta
- Use latest bijection, algebird, scalding, storehaus, chill, and tormenta twitter#565
- Remove scala 2.9 support twitter#565
- Add counters to default summers twitter#571
- Registering summingbird counters with tormenta spouts twitter#553
- Remove StripNameNodes: twitter#587
- Revert unneeded wrapper in DagOptimizer: twitter#584
- Make some classes public so we can make custom platforms: twitter#564
- IdentityKeyedProducer in ValueFlatMapToFlatMap Dag Optimizer rule: twitter#580
- Lazy store init for CombinedServiceStoreFactory: twitter#582
- Pass the reducers option down to leftJoin: twitter#578
- Rename readBatched to readAfterLastBatch: twitter#577
- Fixes BatchedStore interval calculation: twitter#573
- Support for creating a store-service for Storm platform: twitter#563
- Support leftJoin against a store in offline platform: twitter#557
- Counters for ConcurrentMemory platform: twitter#550
- Summingbird Storm/Online refactor: twitter#544
- Memory platform counters: twitter#548
- Example of using DagOptimizer: twitter#538
- Change the javac options for doc generation in java to be successful. (Blocks maven publishing)
- Bumps version of other projects. Changes to compile with latest scalding...: twitter#533
- Safely checking for the internal storm Implementation detail: twitter#528
- add implicit Successible and Predecessible for Timestamp: twitter#530
- Removes redundant Future.unit call: twitter#526
- Optimize CalendarBatcher a bit: twitter#527
- Fixes java publishing to not error in the doc generation/publishing -- i...: twitter#519
- Fix online plan bug with multiple serial summers and certain no-ops: twitter#524
- Fixing tormentaSpout.registerMetric call in scheduleSpout: twitter#521
- Use scalariform: twitter#520
- Adds a test for a bug if a flatMap immediately before a leftJoin produce...: twitter#518
- Fixed Storm stats bug with Promise: twitter#514
- Platform-independent stats storm scalding: twitter#503
- Experimental Java API and example: twitter#499
- First pass at a spark platform for summingbird: twitter#502
- Add summingbird logo: twitter#504
- expose flow object to mutate function: twitter#501
- Support java6 with our one java file: twitter#498
- New async summers from algebird: twitter#497
- Feature/stat store: twitter#495
- Add some option documentation: twitter#491
- Yet another cache: twitter#470
- Monoid to semigroup: twitter#487
- Use scalding version 0.9.0rc17 which has some bug fixes
- Add fully satisfiable flag to UniqueKeyedService: twitter#489
- Mark the scalding platform as serializable, but also don't grab the platform in the scalding env: twitter#485
- smoketest displaying error running example: twitter#483
- Release tool failure fix from 0.4.0 release.
- Add/use the multiplier option: twitter#481
- add variations on pipeFactory to allow a map function before time extrac...: twitter#482
- Make HDFSState public: twitter#478
- Feature/ianoc frozen keys: twitter#477
- Piping prune function through the VersionedStore factory method: twitter#476
- Remove deprecation indirections: twitter#472
- fix unidoc target: twitter#469
- Add hadoop2 compression options: twitter#466
- Few more profiler noticed changes, mostly Future.collect indexedSeq's. O...: twitter#465
- Add deprecation: twitter#463
- Vagrant folder added to .gitignore: twitter#464
- Manually block up sections of output from caches into lists to avoid flo...: twitter#453
- Fixes bug that meant storm tests weren't running: twitter#460
- Factor batch from online: twitter#455
- This moves from using the completeTopology approach to running it normal...: twitter#458
- Code is called heavily, and in tests where we do it 100's of times it wa...: twitter#457
- Clean up a little bit of this code. Uses seq/traversable once in some ap...: twitter#456
- This refactors time out of several places inside the online code. Allows...: twitter#454
- Move the hadoop defaults into scalding platform: twitter#452
- Feature/add option to tune output sizes online: twitter#451
- Move to using Mergable from storehaus instead of mergable store.: twitter#450
- Feature/state deprecated ptrs: twitter#449
- Adds BatchID interval to TS interval: twitter#443
- Adds a scalding-test project: twitter#447
- Make Commutativity settings a case object: twitter#448
- Splits the storm test code out into its own package to help end users be...: twitter#442
- Add toString to InitialBatchedStore: twitter#444
- Feature/long to timestamp offline: twitter#439
- Feature/add pruning support: twitter#435
- Split the scalding platform out into packages: twitter#434
- Add mima command support: twitter#427
- Add PipeFactoryOps, with mapElements, flatMapElements and mapPipe: twitter#432
- Feature/move code from scalding: twitter#424
- Depend on proper Tormenta version (fix semver hiccup)
- We don't want to hit runningState.fail twice: twitter#425
- also tail producer support: twitter#423
- fix merge planner bug: twitter#417
- shard fm: twitter#416
- Add sinking to stores: twitter#408
- Add NormalScaldingStore which contains only (K, V) pairs: twitter#407
- Bump the chill version - makes storm provided: twitter#406
- sort by batch if monoid is commutative: twitter#411
- Fix README to properly run Storm locally: twitter#412
- Feature/async summer store: twitter#400
- Add serializers for BatchID, Timestamp: twitter#350
- ADd a means to set defaults outside the planner: twitter#351
- fix bugs hdfs: twitter#353
- add default option setting: twitter#356
- Add options tests: twitter#335
- Add some hadoop defaults to the builder API: twitter#359
- Cleanup the Storm API a bit: twitter#360
- Put all Collector actions in one execute: twitter#365
- Producer API executors for storm and scalding: twitter#367
- standardize get or else scalding: twitter#363
- Fixes ticks: twitter#368
- spout metrics: twitter#344
- Add the summingbird prefix to the graphs: twitter#370
- add localOrShuffle: twitter#371
- Make the StormMetric Covariant: twitter#373
- Fix depreciation to be from sink: twitter#375
- add options to cfg: twitter#376
- Null out Tuple.values for GC: twitter#374
- Add timestamps to hadoop configs: https://github.com/twitter/summingbird/pull/377/files
- add Options.toString: twitter#378
- Fix out of sync versions to keep: twitter#379
- Feature fix ffm: twitter#381
- Add an await timeout: twitter#380
- Add local or shuffle option: twitter#384
- Add dequeueAll to Queue: twitter#386
- Add in log4j and slf4j to the example: twitter#392
- Fixes naming in bolts for options to work right after plan: twitter#391
- Add error checking to the cache size: twitter#393
- Add more storm tests, add some new test graphs: twitter#394
- Proxy the select correctly on initialbatch: twitter#389
- Refactors the bolts from storm to be independent workers in online: twitter#395
- Pluggable caches in FinalFlatMap: twitter#396
- Uses multimerge: twitter#399
- ack on entry option: twitter#398
- Fix issue with externalizer: twitter#316
- Initial implementation of checkpoint state: twitter#315
- Move to sbt 0.13: twitter#322
- Move Dependants common code to graph: twitter#321
- CheckpointState -> HDFSState: twitter#318
- Change depthFirstOf to use List instead of Vector: twitter#323
- Add an optional parameter to set default parallelism for a storm source: twitter#319
- Add a method to prepare for optimizing FlatMapKeys: twitter#305
- fix the increased output issue: twitter#327
- Optimize iterator sums: twitter#326
- Make sure to register BatchID and Timespan: twitter#324
- Sum by key test: twitter#330
- Add slf4j logging to scalding: twitter#331
- Move the versioned store to scalding package: twitter#332
- storm logging: twitter#333
- Adds/extends some storm option tests: twitter#334
- Make VersionedState fail-safe: twitter#337
- Throw on Storm Submission w/ no online store: twitter#338
- General graph support online: twitter#340
- Summingbird config: twitter#339
- Fix off-by-one bug in scalding batched store: twitter#311
- Add convenience methods to Producer: twitter#307
- Massively optimize Scalding merge/sumByKey: twitter#303
- Improve the WaitingState state machine: twitter#302
- Move code for common realtime planners (storm + akka): twitter#299
- Fix an issue with source minify in scalding: twitter#298
- Improve scalding tests: twitter#296
- Improve storm tests: twitter#292
- Use an AnyVal-like class rather than java.util.Date: twitter#295
- improve Batcher documentation: twitter#293
- Use pipes instead of parentheses when naming online physical nodes: twitter#273
- Add Alsos in Producer2, OptProd2: twitter#275
- Multiple disjoint summers: twitter#274
- Make Tail sealed: twitter#276
- Scalding Laws not to use scalacheck: twitter#278
- Pull Online planner common code into core: twitter#281
- Use externalizer instead of meatlocker: twitter#282
- Standardize SourceBuilder Naming: twitter#285
- Add TailProducer, for graph ending point: twitter#286
- MemoryLaws not use scalacheck: twitter#287
- Added flatMapKeys to all platforms: twitter#288
- Added flatMapKeys to Builder API: twitter#290
- Add better type safety to Storm Spouts: twitter#289
- Add a streaming left join: twitter#291
- Add support for map only jobs in producer api twitter#269
- Fixes naming of nodes, options are picked up correctly twitter#267
- Fix missing elements in case statements for applying online graph to storm twitter#272
- Bump the version numbers of the dependencies twitter#260
- Upgrade to Tormenta 0.5.2, Scalding 0.9.0, Bijection 0.5.3 betas: twitter#191
- Feature/storm new planner: twitter#250
- Feature/move dag to core: twitter#255
- Control how futures are collected in Client Store: twitter#254
- Producer[Platform, T] is covariant on T: twitter#251
- Improve testing generators: twitter#249
- Remove manifests from the core API: twitter#247
- Dot graphs of our storm plan (what SB nodes go to physical nodes): twitter#236
- Fix Storm Tests: twitter#227
- Custom --name flag for job name in builder api: twitter#226
- Remove SINK_ID reference from SourceBuilder: twitter#225
- Add Dot Graph Generation from SB Producer: twitter#223
- Push filters down to storm spout: twitter#224
- Revert StoreIntermediate to old approach: twitter#219
- Add in old SummingJoin: twitter#218
- Fix bug in storm planner's forking: twitter#217
- Don't send empty multiGets to online service: twitter#209
- UTC Calendar Batcher: twitter#195
- Register injections in StormEnv: twitter#198
- Fix Forking bug in Storm planner: twitter#197
- Tidying of StormPlatform: twitter#199
- Add AnchorTuples option to Storm: twitter#200
- Allow NamedProducer after Summer in storm: twitter#202
- Optimization when using BijectedMonoid in a Scalding job: twitter#203
- Remove need for --initial-run (--start-time suffices): twitter#204
- Add --scalding.nothrowplan to not rethrow/exit with error on a flow plan error
- new, producer-based API
- Split Storm and Scalding platforms
- Added in-memory platform
- Complete DSL rebuild in anticipation of release.
- fix compiler-induced bug in BatchAggregatorJob.
- Ability to tee out data.
- PresentingStore
- Ability to join a Summingbird job against another SB job.
- Initial code push.