michal-harish/spark-on-hbase
Generic spark module for scanning, joining and mutating HBase tables to and from RDDs.
Discovered public repositories for michal-harish in the GitHub catalog.
Generic spark module for scanning, joining and mutating HBase tables to and from RDDs.
Simple Yarn Executor
Fast sequential processing of keyed data windows - a conceptual child of Cassandra, Spark and Kafka
Template maven project for mixing scala and java using maven dependency management. Each branch is for different versions of Scala and contains README.md for Eclipse IDE setup with all the update sites and m2e connectors.
LZ4 compression for Java
A simple web application scans zookeeper for topics and which consumer groups consum them and tries to detect also whether they are "active" by looking how far behind the latest offsets of the respective kafka partitions they are. It could also be an interface to create and delete topics.
Hadoop Job for schemaless incremental loading of messages from Kafka topics onto hdfs with configurable output partitioning. :no_entry_sign:
Simple and high level consumer and producer client for Kafka Broker (0.7.x)
Configurable Kafka Mirror with Partitioner support