hansmire/summingbird
Streaming MapReduce with Scalding and Storm
An Apache Hadoop input format for Omniture daily data files (hit_data.tsv). Works identically to TextInputFormat except for the fact that it uses a EscapedLineReader which gets around Omniture's pesky escaped tabs and newlines.
This repository is cataloged as part of our automated global GitHub synchronization. Full telemetry, velocity snapshots, and code summaries are scheduled for continuous enrichment.
Streaming MapReduce with Scalding and Storm
Dead-simple vertical partitioning, compression, appends, and consolidation of data on a distributed filesystem.
Abstract Algebra for Scala
A fault tolerant, protocol-agnostic RPC system