谁能给我解释一下Cassandra 2.1.15 WordCount示例中的以下几行?
CqlConfigHelper.setInputCQLPageRowSize(job.getConfiguration(), "3");
CqlConfigHelper.setInputCql(job.getConfiguration(), "select * from " + COLUMN_FAMILY + " where token(id) > ? and token(id) <= ? allow filtering");
如何定义将用于替换“”的具体值?在查询中?
页面行大小是什么意思?
如何定义将用于替换“”的具体值?在查询中?
你不知道 这些参数化的值由输入格式创建的拆分设置。它们是自动设置的,但可以通过调整分割尺寸进行调整(一定程度)。
页面行大小是什么意思?
页面行大小确定在执行过程中映射程序在单个请求中检索到的CQL行的数量。如果C *分区包含10000个CQL行,并且页面行大小设置为1000,则将需要10个请求来检索所有数据。
本文收集自互联网,转载请注明来源。
如有侵权,请联系[email protected] 删除。
我来说两句