anemos-io / protobeam

Related projects ⓘ

Alternatives and complementary repositories for protobeam

• bullet-db / bullet-core
  Bullet is a streaming query engine that can be plugged into any singular data stream using a Stream Processing framework like Apache Stor…
  ☆41Updated last year
• SponsorPay / jaquet
  Spark stream from kafka(json) to s3(parquet)
  ☆15Updated 6 years ago
• GoogleCloudDataproc / spark-spanner-connector
  Cloud Spanner Connector for Apache Spark
  ☆17Updated last month
• steveloughran / zero-rename-committer
  Paper: A Zero-rename committer for object stores
  ☆20Updated 3 years ago
• ExpediaGroup / hiveberg
  Demonstration of a Hive Input Format for Iceberg
  ☆26Updated 3 years ago
• nezihyigitbasi / FlinkParquet
  Using the Parquet file format (with Avro) to process data with Apache Flink
  ☆14Updated 9 years ago
• isarn / isarn-sketches
  Sketching data structures for scala, including t-digest
  ☆15Updated 3 years ago
• lensesio / datagen
  A small project to allow publishing data to Apache Kafka, Apache Pulsar or any other target system
  ☆14Updated 4 years ago
• apache / beam-site
  Apache Beam Site
  ☆29Updated 3 weeks ago
• jpzk / kafcache
  Kafka Streams + Memcached (e.g. AWS ElasticCache) for low-latency in-memory lookups
  ☆13Updated 5 years ago
• lensesio / avro-sql
  Use SQL to transform your avro schema/records
  ☆28Updated 6 years ago
• memsql / streamliner-examples
  Example code for building your own MemSQL Streamliner Pipelines
  ☆23Updated 7 years ago
• farmdawgnation / kafka-hawk
  An application that records stats about consumer group offset commits and reports them as prometheus metrics
  ☆14Updated 5 years ago
• TIBCOSoftware / snappy-examples
  Use cases built on SnappyData. Use cases contained here: 1. Ad Analytics 2. Streaming data ingestion from RabbitMQ.
  ☆32Updated 2 years ago
• maropu / datasketches-spark
  Data Sketches for Apache Spark
  ☆21Updated last year
• ExpediaGroup / shunting-yard
  Shunting Yard is a real-time data replication tool that copies data between Hive Metastores.
  ☆20Updated 3 years ago
• paypal / dione
  Dione - a Spark and HDFS indexing library
  ☆50Updated 7 months ago
• concord / concord-jvm
  Java and Scala client libraries for Concord
  ☆13Updated 7 years ago
• cyanfr / dbvis_to_hortonworks_hiveserver2
  Connect DBVisualizer to Hortonwork HiveServer2
  ☆9Updated 9 years ago
• avensolutions / cdc-at-scale-using-spark
  Scalable CDC Pattern Implemented using PySpark
  ☆18Updated 5 years ago
• wushujames / kafka-utilities
  ☆26Updated 4 years ago
• qubole / streamx
  kafka-connect-s3 : Ingest data from Kafka to Object Stores(s3)
  ☆96Updated 5 years ago
• ExpediaGroup / jasvorno
  A library for strong, schema based conversion between 'natural' JSON documents and Avro
  ☆18Updated 8 months ago
• rayokota / keta
  A Transactional Metadata Store Backed by Apache Kafka
  ☆22Updated 3 weeks ago
• lensesio / lenses-jdbc
  Lenses.io JDBC driver for Apache Kafka
  ☆20Updated 3 years ago
• B23admin / nifi-stateless-operator
  An Operator for scheduling and executing NiFi Flows as Jobs on Kubernetes
  ☆53Updated 4 years ago
• lensesio / kafka-connect-common
  Common components used across the datamountaineer kafka connect connectors
  ☆21Updated 3 years ago
• dataArtisans / cascading-flink
  Cascading on Apache Flink®
  ☆54Updated 9 months ago