datastream
There are 67 repositories under datastream topic.
apache/flink-connector-kafka
Apache flink
apache/flink-connector-jdbc
Apache flink
apache/flink-connector-elasticsearch
Apache Flink connector for ElasticSearch
jnidzwetzki/bboxdb
BBoxDB is a scalable, highly available, and distributed data store for multi-dimensional big data. The software supports operations like multi-dimensional range queries and spatial joins. In addition, data streams are supported.
collabH/flink-connector-kudu
基于Apache-bahir-kudu-connector的flink-connector-kudu，支持Flink1.11.x DynamicTableSource/Sink，支持Range分区等
apache/flink-connector-pulsar
Apache flink
apache/flink-connector-aws
Apache flink
hmgomes/AdaptiveRandomForest
Repository for the AdaptiveRandomForest algorithm implemented in MOA 2016-04
ogozuacik/concept-drift-datasets-scikit-multiflow
concept drift datasets edited to work with scikit-multiflow directly
mhahsler/stream
A framework for data stream modeling and associated data mining tasks such as clustering and classification. - R Package
ogozuacik/d3-discriminative-drift-detector-concept-drift
unsupervised concept drift detection
rbtr/pachinko
modular pluggable media sorter
apache/flink-connector-hbase
Apache flink
apache/flink-connector-opensearch
Apache flink
apache/flink-connector-rabbitmq
Apache flink
apache/flink-connector-redis-streams
Apache flink
mhahsler/streamMOA
Interface for data stream clustering algorithms implemented in the MOA (Massive Online Analysis) framework.
ahhaque/ECHO
ECHO is a semi-supervised framework for classifying evolving data streams based on our previous approach SAND. The most expensive module of SAND is the change detection module, which has cubic time complexity. ECHO uses dynamic programming to reduce the time complexity. Moreover, ECHO has a maximum allowable sliding window size. If there is no concept drift detected within this limit, ECHO updates the classifiers and resets the sliding window. Experiment results show that ECHO achieves significant speed up over SAND while maintaining similar accuracy. Please refer to the paper (mentioned in the reference section) for further details.
ahhaque/SAND
SAND: Semi-Supervised Adaptive Novel Class Detection and Classification over Data Stream
apache/flink-connector-cassandra
Apache flink
angular-rust/ux-dataflow
UX-Dataflow is a streaming capable data multiplexer that allows you to aggregate data and then process it using a Chain of Responsibility design pattern.
apache/flink-connector-gcp-pubsub
Apache flink
chardonnensp/Datastream-Worldscope-fundamental-dataset
This guide aims to be a full instruction on how to download and merge Refinitiv (formerly Thomson Reuters) Datastream Worldscope data into one comprehensive dataset of yearly stock quoted financial statements.
sepehrbakhshi/BELS
Broad Ensemble Learning System (BELS)
Chrisss93/flink-connector-nats
Flink DataStream connectors for NATS JetStream
apache/flink-connector-hive
Apache flink
hmgomes/StreamingRandomPatches
Repository for the StreamingRandomPatches algorithm implemented in MOA 2019.04
jchambyd/FIGMN-C
Fast Incremental Gaussian Mixture Networks
Waikato/moa-flow
Simple workflow API for MOA.
eouna/pack-binary
use to read or write binary files / binary data stream
Feq1007/StreamDatasets
常见数据流分类任务真实数据集下载地址和人造数据集生成器简介，类别不平衡数据流分类baseline
jvtm/puro
Puro - Highly configurable data streams in Python 3.x
rzeldent/opc-iot-hub
This application uses the OPC Unified Architecture (OPC UA) to accept a list of nodes and subscribe to their value. When a change is received, it pushes the new value to an IOT hub. Here the data can be processed near real-time.
arjunprakash027/Fake-Heart-Sensor-Data-Using-Python-and-Kafka
Fake-Heart-Sensor-Data-Using-Python-and-Kafka is a GitHub project that provides a simple and easy-to-use way to generate simulated heart sensor data using Python and Kafka. This project is ideal for developers who want to test their applications with realistic heart sensor data or simulate a data stream for research purposes.
ljnsn/dsws-client
Python wrapper for the Datastream Web Services API (DSWS)
soheilabadifard/DynED
Dynamic Ensemble Diversification