Ecosyste.ms: Repos

An open API service providing repository metadata for many open source software ecosystems.

GitHub topics: datastream

Repositories

apache/flink-connector-kudu

Apache flink

Language: Java - Size: 250 KB - Last synced: 3 days ago - Pushed: 3 days ago - Stars: 0 - Forks: 1

apache/flink-connector-cassandra

Apache flink

Language: Java - Size: 424 KB - Last synced: 8 days ago - Pushed: 25 days ago - Stars: 10 - Forks: 15

apache/flink-connector-redis-streams

Apache flink

Size: 11.7 KB - Last synced: 8 days ago - Pushed: over 1 year ago - Stars: 14 - Forks: 4

apache/flink-connector-jdbc

Apache flink

Language: Java - Size: 1.34 MB - Last synced: 9 days ago - Pushed: 9 days ago - Stars: 89 - Forks: 128

apache/flink-connector-kafka

Apache flink

Language: Java - Size: 4.12 MB - Last synced: 8 days ago - Pushed: 15 days ago - Stars: 96 - Forks: 84

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: 11 days ago - Pushed: almost 3 years ago - Stars: 9 - Forks: 2

apache/flink-connector-rabbitmq

Apache flink

Language: Java - Size: 288 KB - Last synced: 8 days ago - Pushed: 14 days ago - Stars: 14 - Forks: 14

ljnsn/dsws-client

Python wrapper for the Datastream Web Services API (DSWS)

Language: Python - Size: 373 KB - Last synced: 15 days ago - Pushed: 15 days ago - Stars: 2 - Forks: 0

apache/flink-connector-hbase

Apache flink

Language: Java - Size: 576 KB - Last synced: 8 days ago - Pushed: 18 days ago - Stars: 20 - Forks: 26

apache/flink-connector-pulsar

Apache flink

Language: Java - Size: 1.15 MB - Last synced: 28 days ago - Pushed: about 1 month ago - Stars: 39 - Forks: 43

mhahsler/stream

A framework for data stream modeling and associated data mining tasks such as clustering and classification. - R Package

Language: R - Size: 4.28 MB - Last synced: 25 days ago - Pushed: 25 days ago - Stars: 37 - Forks: 8

mhahsler/streamMOA

Interface for data stream clustering algorithms implemented in the MOA (Massive Online Analysis) framework.

Language: R - Size: 4.77 MB - Last synced: 26 days ago - Pushed: 27 days ago - Stars: 12 - Forks: 3

blewater/tlex

Multi Docker Containers Logger & Stats Aggregator

Language: Go - Size: 1.52 MB - Last synced: 27 days ago - Pushed: almost 5 years ago - Stars: 0 - Forks: 0

apache/flink-connector-elasticsearch

Apache Flink connector for ElasticSearch

Language: Java - Size: 1.04 MB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 63 - Forks: 73

apache/flink-connector-aws

Apache flink

Language: Java - Size: 1.01 MB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 36 - Forks: 38

apache/flink-connector-opensearch

Apache flink

Language: Java - Size: 116 KB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 17 - Forks: 25

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: 26 days ago - Pushed: 26 days ago - Stars: 50 - Forks: 8

apache/flink-connector-gcp-pubsub

Apache flink

Language: Java - Size: 193 KB - Last synced: 3 months ago - Pushed: 4 months ago - Stars: 7 - Forks: 15

ogozuacik/d3-discriminative-drift-detector-concept-drift

unsupervised concept drift detection

Language: Python - Size: 14.6 KB - Last synced: 4 months ago - Pushed: over 2 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: 4 months ago - Pushed: almost 5 years ago - Stars: 37 - Forks: 9

ahhaque/FUSION

Efficient Multistream Classification using Direct DensIty Ratio Estimation

Language: Python - Size: 38.1 KB - Last synced: 5 months ago - Pushed: over 6 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: 5 months ago - Pushed: over 6 years ago - Stars: 10 - Forks: 5

apache/flink-connector-hive

Apache flink

Language: Java - Size: 5.43 MB - Last synced: 3 months ago - Pushed: 3 months ago - Stars: 3 - Forks: 7

rbtr/pachinko

modular pluggable media sorter

Language: Go - Size: 229 KB - Last synced: 16 days ago - Pushed: almost 4 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: 6 months ago - Pushed: 6 months 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: 4 months ago - Pushed: 4 months ago - Stars: 0 - Forks: 0

s-bauza/AGBD

ADMINISTRACIÓN Y GESTIÓN DE BASES DE DATOS

Size: 18.8 MB - Last synced: 7 months ago - Pushed: 8 months ago - Stars: 0 - Forks: 0

sepehrbakhshi/BELS

Broad Ensemble Learning System (BELS)

Language: Python - Size: 64.5 KB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 1 - Forks: 0

iamirmasoud/data_streaming

Hands on data streaming

Language: Jupyter Notebook - Size: 14.1 MB - Last synced: 8 months ago - Pushed: 8 months ago - Stars: 0 - Forks: 0

soheilabadifard/DynED

Dynamic Ensemble Diversification

Language: Python - Size: 34.9 MB - Last synced: 4 months ago - Pushed: 5 months 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: 5 months ago - Pushed: over 6 years ago - Stars: 10 - Forks: 4

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: 58.6 KB - Last synced: 9 months ago - Pushed: 9 months ago - Stars: 3 - Forks: 0

Chrisss93/flink-connector-nats

Flink DataStream connectors for NATS JetStream

Language: Java - Size: 192 KB - Last synced: 9 months ago - Pushed: about 1 year ago - Stars: 3 - Forks: 1

pedominguezbr/gcp-terraform-datastream-cloudsql

Language: HCL - Size: 3.91 KB - Last synced: 10 months ago - Pushed: over 1 year 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: 10 months ago - Pushed: over 1 year 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: 10 months ago - Pushed: about 1 year ago - Stars: 0 - Forks: 1

FelipeSouzaF/maxwell-dt-stream

Maxwell deamon data stream project

Language: JavaScript - Size: 2.31 MB - Last synced: 11 months ago - Pushed: 11 months ago - Stars: 0 - Forks: 0

jchambyd/LFDD

Landmark-based Feature Drift Detector

Language: Java - Size: 12.6 MB - Last synced: 11 months ago - Pushed: about 5 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: 12 months ago - Pushed: 12 months ago - Stars: 2 - Forks: 0

collabH/flink-connector-kudu

基于Apache-bahir-kudu-connector的flink-connector-kudu，支持Flink1.11.x DynamicTableSource/Sink，支持Range分区等

Language: Java - Size: 141 KB - Last synced: 12 months ago - Pushed: 12 months ago - Stars: 40 - Forks: 23

Waikato/moa-flow

Simple workflow API for MOA.

Language: Java - Size: 167 KB - Last synced: about 2 months ago - Pushed: over 2 years ago - Stars: 4 - Forks: 3

hmgomes/StreamingRandomPatches

Repository for the StreamingRandomPatches algorithm implemented in MOA 2019.04

Language: Java - Size: 71.1 MB - Last synced: about 1 year ago - Pushed: about 3 years ago - Stars: 2 - Forks: 0

hmgomes/AdaptiveRandomForest

Repository for the AdaptiveRandomForest algorithm implemented in MOA 2016-04

Language: Java - Size: 53.4 MB - Last synced: about 1 year ago - Pushed: over 6 years ago - Stars: 31 - Forks: 10

data-max-hq/terraform-datastream-postgres-bq 📦

Use GCP Datastream to incrementally load PostgreSQL to BigQuery

Language: HCL - Size: 2.93 KB - Last synced: about 1 year ago - Pushed: over 1 year 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: about 1 year ago - Pushed: about 3 years ago - Stars: 3 - Forks: 5