卡桑德拉WordCount Hadoop

Question

有人能向我解释卡桑德拉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");

如何定义将用于替换"?“的具体价值？在查询中？

什么是页面行大小？

Answer 1

如何定义将用于替换"?“的具体价值？在查询中？

没有。这些参数化值是由输入格式创建的拆分设置的。它们是自动设置的，但可以通过调整拆分大小(在一定程度上)进行调整。

什么是页面行大小？

页行大小确定映射程序在执行过程中在单个请求中检索的CQL行数。如果C*分区包含10000个CQL行，并且页面行大小设置为1000，则需要10个请求来检索所有数据。