flink-connector-opensearch

Stream indexer

Connects Flink data streams to OpenSearch for indexing and querying

Apache flink

GitHub

23 stars
32 watching
24 forks
Language: Java
last commit: 22 days 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 58
apache/flink-connector-pulsar A connector for streaming data from a distributed messaging system to Apache Flink 50
apache/flink-connector-jdbc A Java-based connector for connecting Apache Flink to relational databases via JDBC. 121
apache/flink-connector-hbase A connector for integrating HBase with the Apache Flink stream processing framework 29
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 8
snowflakedb/snowflake-kafka-connector A plugin that enables data ingestion from Kafka topics to Snowflake tables 139
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. 142
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 915
arkena00/ndb Provides a flexible and generic interface to connect to various databases using C++ queries. 30