Discover keedio/Storm-filterkey-bolt Open Source project by @keedio

FTP network server is source of events for Apache-flume

264

flume-ftp-source

Hadoop Ecosystem Builder: Build, package, test and deploy your Hadoop ecosystem project.

buildoop

Groovy

kafka-hue

Hue application for Apache Kafka

Mako

flume-taildirectory-source

avro-schema-repo

openshift-cassandra

bigdecimal-math

A Java Math.BigDecimal Implementation of Core Mathematical Functions

Apache Flume sink to produce Avro messages to Apache Kafka

flume-ng-kafka-avro-sink

Sample project development of a custom apache nifi Processor in Scala language

Nifi-JsonProcessor

Quick-and-dirty usage example of of Bing Voice Recognition RESTful API

bing-speech-to-text-example

openstack-log-processor

This repository contains a collection of nagios plugins to monitor Hadoop ecosystem.

nagios-hadoop

Keedio's Hadoop Watcher is a functionality for watching a hdfs path for changes.

Hadoop-Watcher

Hue application for Apache Storm

storm-hue

Mako

hue

Let’s Big Data. Hue is an open source Web interface for analyzing data with Hadoop and Spark. http://gethue.com

Flume interceptor to enrich event body to JSON format with some extra data

flume-enrichment-interceptor-skeleton

Buildoop recipes, for easy package version maintenance

buildoopRecipes

Shell

keedio-stacks

Ambari Stacks made by keedio

Flume-ng-source-VFS is a custom Apache Flume source component for processing files under supported file sytems by Apache-Commons-Vfs2™

Flume-ng-source-VFS

OpenStack log collection PoC

openstack-operations-poc

Flume sink to publish in Microsoft Azure Event Hubs

flume-ng-event-hub-sink

Custom Flume Sink for sending events via GELF protocol.

Flume-sink-Gelf

Training repo for OpenShift

openshift-kafka

Shell

opensfhit-training

Keedio's VFS2-Monitor is a feature for monitoring changes in directories of supported file systems.

VFS2-Monitor

Azure Blob Storage shared connection service for Apache NiFi

nifi-azure-blob-connection-service-bundle

flume-opsec-source

tailer-example

A flume sink to send events over a TCP connection

flume-tcp-sink

A Flume HBase Sink serializer for split CSV events into HBase Columns

flume-hbase-csv-serializer

Scripts to process the Air Pollution Database of the European Environment Agency

air-pollution-data

nodejs_training

Training repo for Node.js

Azure Blob Storage NiFi processors

nifi-azure-blob-storage-processor-bundle

ganglia-storm

Skeleton of a cacheable Flume interceptor.

flume-cacheable-interceptor-skeleton

json4s encoder/decoder for kafka

kafka-json4s-codecs

Serializer for build Avro file using Flume event headers

flume-headers-to-avro-serializer

flume-configurator

AvroRepoKafkaProducerTest

tuneable-data-generator

Simple Apache Flink job to inyect data in ElasticSearch via Keedio Stacks

CsvToElasticSearchInjector

Custom ambari-admin style

ambari-admin

Flume Hbase Serializer to split event body into chunks to send to HBase columns

flume-hbase-offset-serializer

front-kds-logs

Some kafka tools for testing purposes

kafka-utilities

flume-filedump-interceptor

flume-event-header-fields-copy-interceptor

Some tools to test custom flume sources

flume-stress-test-tools

Shell

kafka-log4j-appender

Log4j Appender sending log messages to kafka topics

Vagrant based test environment

keedio-vagrant

Ruby

ambari-web

This repository contains required modifications to ambari-web javascripts in order to deploy a keedio stack with ambari