GitHub topics: datastream
apache/flink-connector-jdbc
Apache flink
Language: Java - Size: 1.77 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 157 - Forks: 182
kayahr/datastream
Data stream classes for writing and reading all kinds of data types, even single bits
Language: TypeScript - Size: 1.98 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 0 - Forks: 0
DPSN-org/dpsn-client-nodejs
Unlock decentralized, real-time data streaming with DPSN SDK—publish, subscribe, and scale with ease
Language: TypeScript - Size: 104 KB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 0 - Forks: 0
apache/flink-connector-cassandra
Apache flink
Language: Java - Size: 427 KB - Last synced at: 6 days ago - Pushed at: 12 days ago - Stars: 18 - Forks: 27
apache/flink-connector-kafka
Apache flink
Language: Java - Size: 3.8 MB - Last synced at: about 12 hours ago - Pushed at: 12 days ago - Stars: 152 - Forks: 151
apache/flink-connector-elasticsearch
Apache Flink connector for ElasticSearch
Language: Java - Size: 1.07 MB - Last synced at: 6 days ago - Pushed at: 17 days ago - Stars: 82 - Forks: 94
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.
Language: Java - Size: 32.8 MB - Last synced at: 12 days ago - Pushed at: about 1 year ago - Stars: 55 - Forks: 9
apache/flink-connector-opensearch
Apache flink
Language: Java - Size: 177 KB - Last synced at: 6 days ago - Pushed at: 27 days ago - Stars: 23 - Forks: 27
mhahsler/stream
A framework for data stream modeling and associated data mining tasks such as clustering and classification. - R Package
Language: R - Size: 4.08 MB - Last synced at: 20 days ago - Pushed at: 3 months ago - Stars: 41 - Forks: 8
apache/flink-connector-aws
Apache flink
Language: Java - Size: 1.19 MB - Last synced at: 6 days ago - Pushed at: 25 days ago - Stars: 70 - Forks: 67
apache/flink-connector-pulsar
Apache flink
Language: Java - Size: 1.14 MB - Last synced at: 6 days ago - Pushed at: 9 months ago - Stars: 57 - Forks: 67
apache/flink-connector-gcp-pubsub
Apache flink
Language: Java - Size: 240 KB - Last synced at: 6 days ago - Pushed at: 8 months ago - Stars: 12 - Forks: 24
Fremen-Labs/elastro
A comprehensive Python library for Elasticsearch management with both programmatic and CLI interfaces
Language: Python - Size: 120 KB - Last synced at: 9 days ago - Pushed at: 2 months ago - Stars: 2 - Forks: 1
apache/flink-connector-hbase
Apache flink
Language: Java - Size: 607 KB - Last synced at: about 12 hours ago - Pushed at: 5 months ago - Stars: 32 - Forks: 34
apache/flink-connector-kudu
Apache flink
Language: Java - Size: 306 KB - Last synced at: 6 days ago - Pushed at: 2 months ago - Stars: 4 - Forks: 8
apache/flink-connector-rabbitmq
Apache flink
Language: Java - Size: 288 KB - Last synced at: about 13 hours ago - Pushed at: about 1 year ago - Stars: 21 - Forks: 15
apache/flink-connector-redis-streams
Apache flink
Size: 11.7 KB - Last synced at: about 13 hours ago - Pushed at: over 2 years ago - Stars: 18 - Forks: 4
eouna/pack-binary
use to read or write binary files / binary data stream
Language: PHP - Size: 44.9 KB - Last synced at: about 1 month ago - Pushed at: almost 5 years ago - Stars: 3 - Forks: 0
apache/flink-connector-hive
Apache flink
Language: Java - Size: 5.54 MB - Last synced at: 6 days ago - Pushed at: 4 months ago - Stars: 8 - Forks: 20
mhahsler/streamMOA
Interface for data stream clustering algorithms implemented in the MOA (Massive Online Analysis) framework.
Language: R - Size: 4.82 MB - Last synced at: 1 day ago - Pushed at: 10 months ago - Stars: 13 - Forks: 3
ljnsn/dsws-client
Python wrapper for the Datastream Web Services API (DSWS)
Language: Python - Size: 540 KB - Last synced at: 24 days ago - Pushed at: about 2 months ago - Stars: 2 - Forks: 0
hmgomes/StreamingRandomPatches
Repository for the StreamingRandomPatches algorithm implemented in MOA 2019.04
Language: Java - Size: 71.1 MB - Last synced at: 2 months ago - Pushed at: about 4 years ago - Stars: 5 - Forks: 1
collabH/flink-connector-kudu
基于Apache-bahir-kudu-connector的flink-connector-kudu，支持Flink1.11.x DynamicTableSource/Sink，支持Range分区等
Language: Java - Size: 142 KB - Last synced at: 3 months ago - Pushed at: about 2 years ago - Stars: 46 - Forks: 24
Spiryd/Clustermancer
Language: Rust - Size: 763 KB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 0 - Forks: 0
hmgomes/AdaptiveRandomForest
Repository for the AdaptiveRandomForest algorithm implemented in MOA 2016-04
Language: Java - Size: 53.4 MB - Last synced at: 2 months ago - Pushed at: over 7 years ago - Stars: 41 - Forks: 10
sharvillimaye/LightningJX
LightningJX (Lightning JSON/XML) is a high-performance, real-time data processing library designed for efficiently handling JSON and XML data streams.
Language: C - Size: 55.7 KB - Last synced at: 3 months ago - Pushed at: 10 months ago - Stars: 0 - Forks: 0
Chrisss93/flink-connector-nats
Flink DataStream connectors for NATS JetStream
Language: Java - Size: 279 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 5 - Forks: 1
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.
Language: Rust - Size: 40 KB - Last synced at: about 1 month ago - Pushed at: almost 4 years ago - Stars: 9 - Forks: 2
ogozuacik/d3-discriminative-drift-detector-concept-drift
unsupervised concept drift detection
Language: Python - Size: 14.6 KB - Last synced at: over 1 year ago - Pushed at: almost 4 years ago - Stars: 35 - Forks: 10
ogozuacik/concept-drift-datasets-scikit-multiflow
concept drift datasets edited to work with scikit-multiflow directly
Size: 90.5 MB - Last synced at: over 1 year ago - Pushed at: almost 6 years ago - Stars: 37 - Forks: 9
ahhaque/FUSION
Efficient Multistream Classification using Direct DensIty Ratio Estimation
Language: Python - Size: 38.1 KB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 5
ahhaque/SAND
SAND: Semi-Supervised Adaptive Novel Class Detection and Classification over Data Stream
Language: Java - Size: 10.7 MB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 10 - Forks: 5
rbtr/pachinko
modular pluggable media sorter
Language: Go - Size: 229 KB - Last synced at: about 1 year ago - Pushed at: about 5 years ago - Stars: 27 - Forks: 1
777388/Cerberus
highlight and open up a serverless no incoming/outgoing page to obfuscate where you're coming from, avoiding Trackers, **Some sites wont allow you in**
Language: JavaScript - Size: 2.93 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
CharlieH7/LeetCode-Questions
This is where I'll store code solutions for the questions I practice on Leetcode!!
Language: Java - Size: 181 KB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
blewater/tlex
Multi Docker Containers Logger & Stats Aggregator
Language: Go - Size: 1.52 MB - Last synced at: 4 months ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 0
s-bauza/AGBD
ADMINISTRACIÓN Y GESTIÓN DE BASES DE DATOS
Size: 18.8 MB - Last synced at: 19 days ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0
sepehrbakhshi/BELS
Broad Ensemble Learning System (BELS)
Language: Python - Size: 64.5 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0
iamirmasoud/data_streaming
Hands on data streaming
Language: Jupyter Notebook - Size: 14.1 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0
soheilabadifard/DynED
Dynamic Ensemble Diversification
Language: Python - Size: 34.9 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 2 - Forks: 0
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.
Language: Java - Size: 10.7 MB - Last synced at: over 1 year ago - Pushed at: over 7 years ago - Stars: 10 - Forks: 4
pedominguezbr/gcp-terraform-datastream-cloudsql
Language: HCL - Size: 3.91 KB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
FelipeSouzaF/maxwell-dt-stream
Maxwell deamon data stream project
Language: JavaScript - Size: 2.31 MB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 0 - Forks: 0
jchambyd/LFDD
Landmark-based Feature Drift Detector
Language: Java - Size: 12.6 MB - Last synced at: almost 2 years ago - Pushed at: about 6 years ago - Stars: 2 - Forks: 0
chus-chus/sketchModelling
Code supporting a series of experiments on the use of efficient sliding window sketches to aid in the modelling of time series.
Language: Jupyter Notebook - Size: 757 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 0
Waikato/moa-flow
Simple workflow API for MOA.
Language: Java - Size: 167 KB - Last synced at: 2 months ago - Pushed at: over 3 years ago - Stars: 4 - Forks: 3
data-max-hq/terraform-datastream-postgres-bq 📦
Use GCP Datastream to incrementally load PostgreSQL to BigQuery
Language: HCL - Size: 2.93 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 1 - Forks: 0
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.
Language: R - Size: 203 MB - Last synced at: over 2 years ago - Pushed at: about 4 years ago - Stars: 3 - Forks: 5
Feq1007/StreamDatasets
常见数据流分类任务真实数据集下载地址和人造数据集生成器简介，类别不平衡数据流分类baseline
Size: 5.86 KB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
epomatti/gcp-bigquery
Data sync via CDC from GCP Cloud SQL to Big Query using Datastream
Language: HCL - Size: 26.4 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
JonathanSanch/NTFLX-M1-Challenge-Sanchez-Jonathan
Netflix Pathways Project 1 - Iterate through collections; stream data into classes and objects; JUnit Testing.
Language: Java - Size: 19.5 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
chaineresearch/datastreams Fork of oceanprotocol/market
🧜♀️ A fork of the Ocean Protocol Market for the Streaming Data Asset extension
Language: TypeScript - Size: 41.1 MB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0
Unidata/LDM-MCIDAS
The LDM-McIDAS Decoders set of LDM-compatible decoders for products contained in the Unidata-Wisconsin (LDM feed type UNIWISC aka MCIDAS), NIMAGE FSL2 and LIGHTNING data streams that are available by IDD feed to core Unidata sites.
Language: C - Size: 2.39 MB - Last synced at: 4 months ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1
jchambyd/FIGMN-C
Fast Incremental Gaussian Mixture Networks
Language: C++ - Size: 894 KB - Last synced at: almost 2 years ago - Pushed at: over 7 years ago - Stars: 3 - Forks: 1
jchambyd/EDIST2
EDIST2: Error Distance Approach for Drift Detection and Monitoring
Language: Java - Size: 3.8 MB - Last synced at: almost 2 years ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 1
Jolly-w/streaming-datasets Fork of scikit-multiflow/streaming-datasets
A collection of data sets for stream learning.
Size: 96 MB - Last synced at: over 1 year ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0
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.
Language: C# - Size: 70.3 KB - Last synced at: 3 months ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 1
elaysason/Weather-Prediction-Project
Creating Kafka stream and use it to predict the precipitation across the globe.
Language: Jupyter Notebook - Size: 4.74 MB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 0 - Forks: 0
Refinitiv-API-Samples/Article.Datastream.Python.LoadDataUsingMultiprocessingInPython
In this Article, we will demonstrate examples of one of the DSWS Python API to load data using parallel processing functionality for reducing the execution time and lead to useful case studies.
Language: Jupyter Notebook - Size: 506 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0
Joseph0472/AlgorithmsforMD
Implementation tasks for multiple algorithms to process massive data. The algorithms are written in Python.
Language: Python - Size: 19.9 MB - Last synced at: about 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0
LeidenUniversityLibrary/islandora_check_datastreams
Islandora module to check if all necessary datastreams are available for objects.
Language: PHP - Size: 63.5 KB - Last synced at: over 2 years ago - Pushed at: about 4 years ago - Stars: 0 - Forks: 1
yaricom/gostream
The simple data stream implementation using GO language based on the Redis stream
Language: Go - Size: 13.7 KB - Last synced at: 2 months ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0
maltendeitering/datastream-example
A simple datastream built with Apache Kafka and Python running on Docker.
Language: Python - Size: 1.56 MB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0
coralogix/akamai-datastream-cli
Akamai DataStream CLI to collect logs from Akamai DataStream API and send it Coralogix.
Language: Go - Size: 14.6 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1
jvtm/puro
Puro - Highly configurable data streams in Python 3.x
Language: Python - Size: 37.1 KB - Last synced at: 6 days ago - Pushed at: over 7 years ago - Stars: 3 - Forks: 0
claudiomarpda/Battleship
Language: Java - Size: 50.7 MB - Last synced at: over 2 years ago - Pushed at: over 7 years ago - Stars: 0 - Forks: 0
