ScaleUnlimited / flink-streaming-kmeans
Simple implementation of KMeans clustering on Flink, using iterations
☆10Updated 6 years ago
Alternatives and similar repositories for flink-streaming-kmeans:
Users that are interested in flink-streaming-kmeans are comparing it to the libraries listed below
- Using the Parquet file format (with Avro) to process data with Apache Flink☆14Updated 9 years ago
- Integration of Iceberg table management into Spark SQL☆11Updated 5 years ago
- Fast reactive bridge between Java applications and Yandex.ClickHouse database☆11Updated 6 years ago
- Flink performance tests☆28Updated 5 years ago
- Read druid segments from hadoop☆10Updated 8 years ago
- ☆18Updated 6 years ago
- Redesign to eliminate all string identifiers and hide partitioning details from app developer.☆16Updated 13 years ago
- Flink Examples☆39Updated 8 years ago
- Ambari View for the Ambari Store☆15Updated 9 years ago
- graphx example☆24Updated 9 years ago
- Java and Scala client libraries for Concord☆13Updated 7 years ago
- Sparking Using Java8☆17Updated 9 years ago
- Jetstream Esper Processor implementation☆23Updated 9 years ago
- A shim for using Cassandra as a backend for OpenTSDB. Not to be used as a general Cassandra client.☆7Updated 5 years ago
- UberScriptQuery, a SQL-like DSL to make writing Spark jobs super easy☆62Updated last year
- ByteBuffer collection classes for java and jvm-based languages.☆33Updated 6 years ago
- Toolkit that can bundle any Spring Boot application into an Apache Ambari Service, enabling Ambari to provision, manage and monitor the s…☆13Updated 9 years ago
- Stratosphere is now Apache Flink.☆196Updated last year
- ☆2Updated 3 years ago
- Proteus engine contains an overhauled version of Apache Flink supporting hybrid computation on batch datasets and data streams. Please re…☆9Updated 6 years ago
- Flink Cookbook - This is work in progress.☆17Updated 6 years ago
- Java implementation of TPC-C benchmark☆38Updated 8 years ago
- phData Pulse application log aggregation and monitoring☆13Updated 4 years ago
- Apache Flink example CEP program to monitor data center temperatures☆129Updated 6 years ago
- A streaming key-value store implementation using native Flink Streaming operators☆23Updated 9 years ago
- DBSCAN clustering algorithm implemented in Apache Spark (MapReduce Framework).☆14Updated 8 years ago
- Spark CEP is an extension of Spark Streaming to support SQL-based query processing☆56Updated 7 years ago
- Example using Grafana with Druid☆11Updated 9 years ago
- Flowmix is a flexible event processing engine for Apache Storm. It supports complex correlations of events via sliding/tumbling windows. …☆57Updated 8 years ago
- ☆17Updated 5 years ago