【05 计算平台 蓉荣】Flink 批处理及其应⽤计算 存储 Queue 存储类 • Kafka • Datahub • SLS • MQ • OSS • OTS • HBase • RDS • ADS • HDFS • OSS • HDFS • ElasticSearch • OTS • HBase • RDS • ADS • PetaData • HiTSDB • HyBridDB • Kafka0 码力 | 12 页 | 1.44 MB | 1 年前3
Introduction to Apache Flink and Apache Kafka - CS 591 K1: Data Stream Processing and Analytics Spring 2020framework • True streaming at its core • Streaming & Batch API Historic data Kafka, RabbitMQ, ... HDFS, JDBC, ... Event logs ETL, Graphs, Machine Learning Relational, … Low latency, windowing,0 码力 | 26 页 | 3.33 MB | 1 年前3
Flink如何实时分析Iceberg数据湖的CDC数据A3a/21 Kudu 维护 CDC 数据p 、支持L时更新数据,时效性佳。 2、CK加速,适合OLAP分析。 方案评估 优点 、cedKudup群,a较小众。维护 O本q。 2、H HDFS / S3 / OSS 等D裂。数据c e,且KAO本不如S3 / OSS。 3、Kudud批量P描不如3ar4u1t。 4、不支持增量SF。 h点 直接D入CDC到Hi2+分析 、流程能E作0 码力 | 36 页 | 781.69 KB | 1 年前3
PyFlink 1.15 Documentationpyfs $ ./bin/flink run --python examples/python/table/word_count.py --pyFiles file:///user. ˓→txt,hdfs:///$namenode_address/username.txt For example, if you have a directory named myDir which has the0 码力 | 36 页 | 266.77 KB | 1 年前3
PyFlink 1.16 Documentationpyfs $ ./bin/flink run --python examples/python/table/word_count.py --pyFiles file:///user. ˓→txt,hdfs:///$namenode_address/username.txt For example, if you have a directory named myDir which has the0 码力 | 36 页 | 266.80 KB | 1 年前3
共 5 条
- 1













