datastream
There are 71 repositories under datastream topic.
apache/flink-connector-jdbc
Apache flink
apache/flink-connector-kafka
Apache flink
apache/flink-connector-elasticsearch
Apache Flink connector for ElasticSearch
apache/flink-connector-aws
Apache flink
apache/flink-connector-pulsar
Apache flink
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分区等
hmgomes/AdaptiveRandomForest
Repository for the AdaptiveRandomForest algorithm implemented in MOA 2016-04
mhahsler/stream
A framework for data stream modeling and associated data mining tasks such as clustering and classification. - R Package
ogozuacik/concept-drift-datasets-scikit-multiflow
concept drift datasets edited to work with scikit-multiflow directly
ogozuacik/d3-discriminative-drift-detector-concept-drift
unsupervised concept drift detection
apache/flink-connector-hbase
Apache flink
rbtr/pachinko
modular pluggable media sorter
apache/flink-connector-opensearch
Apache flink
apache/flink-connector-rabbitmq
Apache flink
apache/flink-connector-cassandra
Apache flink
apache/flink-connector-redis-streams
Apache flink
ahhaque/SAND
SAND: Semi-Supervised Adaptive Novel Class Detection and Classification over Data Stream
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.
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)
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-hive
Apache flink
Chrisss93/flink-connector-nats
Flink DataStream connectors for NATS JetStream
apache/flink-connector-kudu
Apache flink
hmgomes/StreamingRandomPatches
Repository for the StreamingRandomPatches algorithm implemented in MOA 2019.04
eouna/pack-binary
use to read or write binary files / binary data stream
jchambyd/FIGMN-C
Fast Incremental Gaussian Mixture Networks
Waikato/moa-flow
Simple workflow API for MOA.
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.
soheilabadifard/DynED
DynED is a novel ensemble construction and maintenance approach for data stream classification that dynamically balances the diversity and prediction accuracy of its components.