flink-connector-opensearch

Stream indexer

Connects Flink data streams to OpenSearch for indexing and querying

Apache flink

GitHub

23 stars
31 watching
24 forks
Language: Java
last commit: 3 months ago
connectordatastreamflinkopensearchsqltable

Related projects:

Repository Description Stars
apache/flink-connector-aws Provides connectivity between Apache Flink and Amazon Web Services (AWS) for real-time data processing 60
apache/flink-connector-pulsar A connector for streaming data from a distributed messaging system to Apache Flink 53
apache/flink-connector-jdbc A Java-based connector for connecting Apache Flink to relational databases via JDBC. 127
apache/flink-connector-hbase A connector for integrating HBase with the Apache Flink stream processing framework 30
apache/flink-connector-gcp-pubsub A Java-based connector for integrating Google Cloud PubSub with Apache Flink's data processing framework 11
apache/flink-connector-rabbitmq A Flink connector for RabbitMQ message broker 19
apache/flink-connector-prometheus A Java-based connector for integrating Prometheus data into Apache Flink stream processing applications 9
snowflakedb/snowflake-kafka-connector A plugin that enables data ingestion from Kafka topics to Snowflake tables 141
apache/rocketmq-connect A tool for streaming data between Apache RocketMQ and other systems 122
flink-china/flink-forward-sf-2017 A collection of slides and videos from the Apache Flink conference in San Francisco 2017 17
apache/hbase-connectors Connects Apache HBase with other systems like Kafka and Spark for data processing and integration. 236
apache/rocketmq-flink Provides integration for RocketMQ with Apache Flink, enabling data streaming and messaging using the RocketMQ source and sink. 145
openscoring/openscoring A REST web service for real-time model scoring with high performance and extensibility 580
mysql/mysql-connector-j Provides a Java driver for connecting to MySQL databases 925
arkena00/ndb Provides a flexible and generic interface to connect to various databases using C++ queries. 30