Pinned Repositories
beam
Mirror of Apache Beam
drift
Fast sequential processing of keyed data windows - a conceptual child of Cassandra, Spark and Kafka
kafka-hadoop-loader
Hadoop Job for schemaless incremental loading of messages from Kafka topics onto hdfs with configurable output partitioning. :no_entry_sign:
kafka-mirror
Configurable Kafka Mirror with Partitioner support
kafka-php
Simple and high level consumer and producer client for Kafka Broker (0.7.x)
kafka-topology
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.
scala-java-maven-template
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.
spark-on-hbase
Generic spark module for scanning, joining and mutating HBase tables to and from RDDs.
yarn1
Simple Yarn Executor
michal-harish's Repositories
michal-harish/kafka-hadoop-loader
Hadoop Job for schemaless incremental loading of messages from Kafka topics onto hdfs with configurable output partitioning. :no_entry_sign:
michal-harish/kafka-php
Simple and high level consumer and producer client for Kafka Broker (0.7.x)
michal-harish/spark-on-hbase
Generic spark module for scanning, joining and mutating HBase tables to and from RDDs.
michal-harish/kafka-topology
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.
michal-harish/drift
Fast sequential processing of keyed data windows - a conceptual child of Cassandra, Spark and Kafka
michal-harish/kafka-mirror
Configurable Kafka Mirror with Partitioner support
michal-harish/scala-java-maven-template
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.
michal-harish/yarn1
Simple Yarn Executor
michal-harish/beam
Mirror of Apache Beam
michal-harish/citrus
Framework for automated integration tests with focus on messaging integration
michal-harish/enrondata
michal-harish/flink
Mirror of Apache Flink
michal-harish/go-from-scratch
Golang from Makefile to Kuberentes using static binary images
michal-harish/graphstream
Example application of the Recursive Stream Processor
michal-harish/hellocpp11
C++11 and C++14 learning repo
michal-harish/java-ascii-render
ASCII renderer in pure java with no external dependencies
michal-harish/kafka
Mirror of Apache Kafka
michal-harish/kafka-cep
Scalable complex event processor built around kafka - it uses kafka consumers as a source of primary events as well as for producting intermediate and higher-order events
michal-harish/kalliope_neuron_gmail
A Kalliope Neuron to manage GMAIL
michal-harish/lz4-java
LZ4 compression for Java
michal-harish/pulsar-java-tutorial
Tutorial for getting started with Apache Pulsar (incubating)
michal-harish/scalavro
A reflection-based Avro library in Scala.
michal-harish/spark-xml
XML data source for Spark SQL and DataFrames