canal Spark SQL Adaptive Execution Chain Transform Scala Python PySpark Flink Savepoint Checkpoint Window ReduceFunction AggregateFunction ProcessWindowFunction Timestamp Watermark Broadcast State Async I/O AppendStreamTableSink RetractStreamTableSink UpsertStreamTableSink LookableTableSource Table API Temporal Table UDF UDAF UDTF 内存管理 反压 Kafka Connect KNN Kafka Log Compacted Topics 大数据 分布式 MapReduce Shuffle Merge Join Hash Join Nested Join PostgreSQL Database pyspark spark 分布式计算 Process Thread join big data commit coordinator 一致性 sql catalyst RBO CBO Spark SQL Scheduler LeetCode 算法 C C++ streaming updateStateByKey mapWithState network python Simpy rdd 数据倾斜 YAML Word2vec tensorflow Zeppelin notebook 持久化 zeppelin lbs mongodb geohash mysql html css emmet neo4j spatial geo seaborn matplotlib Mathjax java matrix linear algebra machine learning AUC PR Precision Recall F1