آموزش شروع کار با پردازش جریان با استفاده از Apache Flink

بررسی اجمالی دوره Course Overview

• بررسی اجمالی دوره Course Overview

درک جریان داده و پردازش جریان Understanding Streaming Data and Stream Processing

• چرا پردازش جریان Why Stream Processing?

• پردازش دسته ای در مقابل پردازش جریان Batch Processing vs. Stream Processing

• الزامات سیستم های پردازش جریان Requirements of Stream Processing Systems

• میکرو دسته برای پردازش جریان Micro-batches for Stream Processing

• معرفی Apache Flink برای پردازش جریان Introducing Apache Flink for Stream Processing

• مشتریان ، استادان و کارگران Clients, Masters, and Workers

• Flink را نصب و راه اندازی کنید Install and Set up Flink

پیاده سازی عملیات اساسی در جریان دادن داده ها Implementing Basic Operations on Streaming Data

• نمایش داده ها و تحولات در یک جریان Data Representation and Transformations on a Stream

• تحول فیلتر The Filter Transformation

• تحول نقشه The Map Transformation

• تحول FlatMap The FlatMap Transformation

• تحولات بدون دولت و دولت Stateless and Stateful Transformations

• جریانهای کلید دار Keyed Streams

• تحولات در جریانهای کلیددار Transformations on Keyed Streams

• عملیات کاهش The Reduce Operation

عملیات پنجره سازی در جریان ها Windowing Operations on Streams

• مقدمه ای بر تحولات پنجره Introduction to Window Transformations

• دست و پا زدن ویندوز Tumbling Windows

• کشویی ویندوز Sliding Windows

• تعداد ، جلسه و ویندوزهای جهانی Count, Session, and Global Windows

• زمان رویداد ، زمان بلع و زمان پردازش Event Time, Ingestion Time, and Processing Time

• پیاده سازی Tumbling و Sliding Windows Implementing Tumbling and Sliding Windows

• اجرای پنجره شمارش Implementing the Count Window

• اجرای پنجره جلسه Implementing the Session Window

• دریافت کلیدهای مصرف کننده توییتر و رمزهای دسترسی Getting the Twitter Consumer Keys and Access Tokens

• اتصال به Twitter Streaming API Connecting to the Twitter Streaming API

تحمل خطا با ایالت ها و ایست های بازرسی Fault Tolerance with State and Checkpoints

• دسته های دولت Categories of State

• توابع غنی برای ذخیره وضعیت Rich Functions to Store State

• تحولات را به حالت فعلی درآورد: ValueState & lt؛ T Making Transformations Stateful: ValueState<T>

• تحولات را به حالت فعلی درآورید: ListState & lt؛ T Making Transformations Stateful: ListState<T>

• تحولات را به حالت فعلی درآورید: ReducingState & lt؛ T Making Transformations Stateful: ReducingState<T>

• تحمل خطا با Checkpoint Fault Tolerance with Checkpoint

• راهکارهای راه اندازی مجدد Restart Strategies

کار با چندین منبع جریان Working with Multiple Stream Sources

• عملیات اتحادیه The Union Operation

• به عملیات بپیوندید The Join Operation