> For the complete documentation index, see [llms.txt](https://glink.gitbook.io/docs/llms.txt). Markdown versions of documentation pages are available by appending `.md` to page URLs; this page is available as [Markdown](https://glink.gitbook.io/docs/demo/spatial-join.md).

# 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数据。

```bash
cat tdrive_merge.txt | kafka-producer tdrive
```

提交Flink任务.

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