hdfsstream create --name dataset1 --definition "kafka --topic=kafka_test --zkconnect=10.10.1.20:2181 --queueSize=64 |hdfs --inputType=application/json --idleTimeout=10000 --partitionPath=dateFormat('yyyy/MM/dd/HH/mm')" --deploy
其中
原文作者: sdvdxl
原文链接: https://todu.top/posts/37291/
发表日期: March 14th 2016, 4:10:23 pm
版权声明: 本文采用知识共享署名-非商业性使用 4.0 国际许可协议进行许可
提问交流: 去博客源码处提Issue交流
- Next Postgolang容易忽略导致入坑的方面
- Previous Postgolang命令