首先,来看怎么构造一个org.apache.hadoop.yarn.client.api.YarnClientclass
ClientHelper(conf: Configuration) extends Logging { val yarnClient =
YarnClient.createYa....
分类:
移动开发 时间:
2014-05-10 22:39:32
阅读次数:
656
运行脚本,提交job往YARN提交Samza
job要使用run-job.sh这个脚本。samza-example/target/bin/run-job.sh
--config-factory=samza.config.factories.PropertiesConfigFactory --conf...
分类:
其他好文 时间:
2014-05-10 17:52:13
阅读次数:
609
参考这个里边对API的调用http://samza.incubator.apache.org/learn/documentation/0.7.0/container/metrics.html参考这里列出的可用配置http://samza.incubator.apache.org/learn/docu...
分类:
其他好文 时间:
2014-04-29 23:50:43
阅读次数:
843