Spatial Join

Spatial Dimention Join on T-Drive

创建Kafka topic。

kafka-topics.sh --create --bootstrap-server localhost:9092 --partitions 6 --topic tdrive
kafka-topics.sh --create --bootstrap-server localhost:9092 --partitions 6 --topic dim-o

导入T-Drive数据。

cat tdrive_merge.txt | kafka-producer tdrive

提交Flink任务.

--bootstrap-server room:9092 --t-topic tdrive --d-topic beijing --o-topic dim-o