tmalaska/SparkOnALog
Examples of Integrating Spark Streaming, Flume, and HBase to solve Streaming problems
A simple MR job where you can declare the number of mappers and reducer and a sleep time that they will sleep for.
This repository is cataloged as part of our automated global GitHub synchronization. Full telemetry, velocity snapshots, and code summaries are scheduled for continuous enrichment.
Examples of Integrating Spark Streaming, Flume, and HBase to solve Streaming problems
This is a tool for testing and managing many repeatedly and large bulk loads on HBase
This is a layer on top of the Flume NettyAvroRpcClient that allows for multiple connects to a server.
This is a simple example to show how a single HBase "get" can retrieve the top N {items,amount} in the order of amount decresing