SESSION + Live Q&A

Next Steps in Stateful Streaming with Apache Flink

Come learn how Apache Flink is making stateful stream processing even more expressive and flexible to support applications in streaming that were previously not considered streamable.

Over the last years, data stream processing has redefined how many of us build data pipelines. Apache Flink is one of the systems at the forefront of that development: With its versatile APIs (event-time streaming, Stream SQL, events/state) and powerful execution model, Flink has been part of re-defining what stream processing can do. By now, Apache Flink powers some of the largest data stream processing pipelines in open source data stream processing.

Ranging from batch and streaming pipelines and analytics to microservices and applications, Flink has been used for a wide range of applications that can be unified under the paradigm of data stream processing. A key ingredient to that flexibility is Flink's handling of Streams and State. In the talk we will show how these are handled in Flink today and how they form a powerful abstraction for both streaming analytics and applications. We will also look at the future of stateful processing in Flink, and some new abstractions that extend the range of addressable use cases.



Speaker

Stephan Ewen

Committer @ApacheFlink, CTO @dataArtisans

Stephan Ewen is a PMC member and one of the original creators of Apache Flink, and co-founder and CTO of data Artisans (data-artisans.com). He holds a Ph.D. from the Berlin University of Technology.

Read more
Find Stephan Ewen at:

Location

Whittle, 3rd flr.

Track

Stream Processing in the Modern Age

Topics

Stream ProcessingApache FlinkData AnalyticsInterview AvailableDataEng

Share

From the same track

SESSION + Live Q&A event sourcing

Drivetribe: A Social Network on Streams

Drivetribe is the world's biggest motoring destination, as envisioned by Jeremy Clarkson, Richard Hammond, and James May. Built on top of the Event Sourcing/CQRS pattern, the Drivetribe platform uses Apache Kafka as its source of truth and Apache Flink as its processing backbone. This talk aims...

Aris Koliopoulos

CTO @Drivetribe

Hamish Dickson

Backend engineer @Drivetribe

SESSION + Live Q&A Scale

Lessons From a ~Yearly Re-Write of a Data Pipeline

Every year, we’ve set ourselves a goal of dramatically improving the performance and efficiency of our core data pipelines. We’ve done this by re-writing, effectively from scratch, the streaming pipelines that are responsible for processing over 120,000 events per second to deliver realtime...

Jibran Saithi

Lead Architect @Qubit

SESSION + Live Q&A Apache Kafka

Streaming SQL Foundations: Why I ❤ Streams+Tables

What does it mean to execute robust streaming queries in SQL? What is the relationship of streaming queries to classic relational queries? Are streams and tables the same thing conceptually, or different? And how does all of this relate to the programmatic frameworks like we’re all familiar...

Tyler Akidau

Engineer @Google & Founder/Committer on Apache Beam

SESSION + Live Q&A Stream Processing

Streaming Reactive Systems & Data Pipes w. squbs

Reactive libraries are nothing new to the JVM. Reactive Streams as an SPI has even made its way into Java 9. However, their uses within microservice components are still for relatively narrow purposes like service orchestration. But we think differently. Our whole presence and universe can be...

Akara Sucharitakul

Principal MTS, Architect @PayPal

Anil Gursel

Software Engineer @PayPal

UNCONFERENCE + Live Q&A Stream Processing

Stream Processing Open Space

View full Schedule