《01-鲁尼-圆桌Flink Forward Virtual Conference - April 2020 - Cloudera CDF Keynotev2的副本.pdf》由会员分享,可在线阅读,更多相关《01-鲁尼-圆桌Flink Forward Virtual Conference - April 2020 - Cloudera CDF Keynotev2的副本.pdf(31页珍藏版)》请在三个皮匠报告上搜索。
1、Apache Flink Completing Clouderas End-to-End Streaming Platform Joseph Witt Vice President Engineering, Cloudera Data Flow Marton Balassi Engineering Lead, Streaming Analytics 2020 Cloudera, Inc. All rights reserved.2 Data-in-Motion Philosophy Apache, Apache NiFi, Kafka, and Flink and their logos ar
2、e trademarks of the Apache Software Foundation in the United States and/or other countries. No endorsement by The Apache Software Foundation is implied by the use of these marks. 2020 Cloudera, Inc. All rights reserved.3 Complete and Connected Data Lifecycle Collect Edge SELECT TUMBLE_END(eventTime,
3、 INTERVAL 10 MINUTES) AS windowEnd, kioskHost, COUNT(*) AS numErrors, FIRST_VALUE(event) AS sample FROM kiosk_events_raw_sfo WHERE event LIKE %ERROR% GROUP BY kioskHost, TUMBLE_END(eventTime, INTERVAL 10 MINUTES); Let us compute the number of errors per host for each 10 minute window 2020 Cloudera, Inc. All rights reserved.18 Data-in-Motion Vision 2020 Cloudera, Inc. All rights reserved.19 Simplif