#StreamProcessing

Three windowing flavors, one idea: mTopN for sliding windows by element count, tmTopN for time-based windows, cumTopN for cumulative history. All available across sum, avg, std, corr, beta, and more. #DolphinDB #TimeSeries #StreamProcessing

😡Tired of mismatched backtest and production logic? DolphinDB unifies stream & batch processing with sub-millisecond latency to power your quantitative strategies.👋 #DolphinDB #QuantFinance #StreamProcessing

It's 14:02. Your credit card just got stolen. How long does it take before your bank notices? We followed the same thief through two banks: one running on batch, one running on streaming. 🧵

Without context, every payment looks normal. Even the fraudulent ones. Payment fraud in the European Economic Area reached €4.2 billion in 2024 (EBA/ECB, 2025 Report on Payment Fraud).

So, is your fraud context on batch or streaming? Use cases for both: #StreamProcessing #FraudDetection

🚨New Video Alert!🚨 Just the facts today! What you need to know to get the conversation started and choose a #streamProcessing technology from a few popular options: #apacheFlink, #apacheSpark #structuredStreaming, and #kafkaStreams. What did I miss?

Flink® in production is learned the hard way. Most teams find its limits during an incident, not before. Stream Forward Prague brings together the engineers who’ve been there: → What broke → How they fixed it → What it made possible 18 November · What you’ll learn. What you’ll build ↓

What gets covered: → Flink at scale: state, checkpoint tuning, backpressure → Real-time AI: feature pipelines, online inference → Batch to streaming: replacing legacy ETL → Streamhouse: Flink for compute, Fluss for real-time storage, Paimon for history

Details and registration One ticket covers the full day, food and drinks included. → 18 November, Prague → Doors 08:30 · Talks 09:00–13:00 → Lab 14:00–17:00 · Drinks until 19:00 Register: #ApacheFlink #StreamProcessing

"#StreamProcessing Simplified: An Inside Look at #ApacheFlink for #ApacheKafka Users" A match made in heaven! Flink has: - Powerful runtime - APIs and language support - Unified stream and batch processing - Production-readiness #opensource #cloud

Processing continuous data streams with stateful computations, event-time windowing, and low-latency fault tolerance. Galgotias University prepares developers for real-time big data architecture! 🌊📊 #GalgotiasUniversity #StreamProcessing #ApacheFlink #DataEngineering

Backtest and live trading shouldn't use different indicator code. DolphinDB's Reactive State Engine runs ta module functions on streaming ticks—minute-level indicators, intraday charts, mobile app updates. #DolphinDB #StreamProcessing #QuantFinance

"Stateless vs Stateful #StreamProcessing with #KafkaStreams and #ApacheFlink - A Fraud Prevention Example" => 10min explanation using #SQL, #Java and #AI

Improve your Java skills with the Neo Stream Search Challenge! Explore Predicate functional interfaces and essential stream processing methods. Begin now: 👉 #JavaChallenge #StreamProcessing #JavaSkills

For nearly 2 years, I've been working on building audio processing infrastructure at @SpotifyEng . And finally, I can actually share it 🎉 #Python #MusicIR #streamprocessing #apachebeam

🔊Apache Flink 1.16 has just been released Here's a short overview video of the new features: #streamprocessing #apacheflink

Our paper titled “Evaluation of Stream Processing Frameworks” accepted for publication in IEEE Transactions for Parallel and Distributed Systems available from DOI: 10.1109/TPDS.2020.2978480 #throughput #latency #streamprocessing #StructuredStreaming #orms

#ApacheKafka is a #StreamProcessing platform for storing, consuming & processing data streams in real-time. Learn how to produce & consume data using Kafka and #Quarkus in this #InfoQ article by @alexsotob: #Java #Microservices #DevOps #Development

We are thrilled to announce the acquisition of @EventadorLabs, the platform to simplify #streamprocessing. Learn more about how this will accelerate the delivery of Cloudera DataFlow as a cloud-native self-service experience in CDP. #HarnessRealTime #Flink

Refine your Java skills in the Neo Stream Search Challenge! Uncover the nuances of the Predicate functional interface in stream processing. Let's dive into this exploration! 🔗 #JavaChallenge #StreamProcessing #JavaSkills

Can Apache Sedona work with Apache Flink? The short answer is YES! Apache Sedona can be used with Apache Flink to perform geospatial processing operations on streaming data. Details in a 🧵👇🏽 #geospatial #streamprocessing #apachesedona #apacheflink #bigdata #gischat

Improve your Java skills with the Neo Stream Search Challenge! Explore Predicate functional interfaces and essential stream processing methods. Begin now: 👉 #JavaChallenge #StreamProcessing #JavaSkills

#ApacheKafka folks: what are some of the most interesting #streamprocessing use cases you've encountered? I'm looking for inspiration. 🤩 GO.

Enhance your Java skills with the Neo Stream Search Challenge! Explore the intricacies of the Predicate functional interface in stream processing. Let's dive in! 🔗 #JavaChallenge #StreamProcessing #JavaSkills