过滤器_Wide column模型_功能介绍_表格存储 Tablestore-阿里云

场景

以物联网中的智能电表为例，智能电表按一定的频率（例如每隔15秒）将当前的电压、电流、度数等信息写入表格存储。在按天做分析时，需要获取某一个电表当天是否出现过电压异常以及出现时的其他状态数据，用于判断是否需要对某条线路进行检修。

按照目前的方案，使用GetRange读取一个电表一天内的所有的监控数据，共有5760条，然后再对5760条信息进行过滤，最终获取了10个电压出现不稳定时的监控信息。

使用过滤器只返回了实际需要的10条数据，有效降低了返回的数据量。而且无需再对结果进行初步的过滤处理，节省了开发成本。

限制

过滤器的条件支持关系运算（=、!=、>、>=、<、<=）和逻辑运算（NOT、AND、OR），最多支持10个条件的组合。
过滤器中的参考列必须在读取的结果内。如果指定的要读取的列中不包含参考列，则过滤器无法获取参考列的值。
在GetRow、BatchGetRow和GetRange接口中使用过滤器不会改变接口的原生语义和限制项，详情请参见基础数据操作。
使用GetRange接口时，一次扫描数据的行数不能超过5000行或者数据大小不能超过4 MB。

当在该次扫描的5000行或者4 MB数据中没有满足过滤器条件的数据时，得到的Response中的Rows为空，但是NextStartPrimaryKey可能不为空，此时需要使用NextStartPrimaryKey继续读取数据，直到NextStartPrimaryKey为空。

接口

过滤器可以用于GetRow、BatchGetRow和GetRange接口。

过滤器目前包括SingleColumnValueFilter和CompositeColumnValueFilter，是基于一个或者多个参考列的列值决定是否过滤某行。

SingleColumnValueFilter：只判断某个参考列的列值。
当参考列不存在时，可以使用PassIfMissing参数决定此时是否满足条件，即设置当参考列不存在时的行为。
CompositeColumnValueFilter：根据多个参考列的列值的判断结果进行逻辑组合，决定是否过滤某行。

使用

您可以使用如下语言的SDK实现过滤器功能。

参数


参数	说明
ColumnName	过滤器中参考列的名称。
ColumnValue	过滤器中参考列的对比值。
CompareOperator	过滤器中的关系运算符。关系运算符包括EQUAL（=）、NOT_EQUAL（!=）、GREATER_THAN（>）、GREATER_EQUAL（>=）、LESS_THAN（<）和LESS_EQUAL（<=）。
LogicOperator	过滤器中的逻辑运算符。逻辑运算符包括NOT、AND和OR。
PassIfMissing	当参考列在某行中不存在时，是否返回该行。类型为bool值，默认值为true，表示如果参考列在某行中不存在时，则返回该行。当设置PassIfMissing为false时，如果参考列在某行中不存在时，则不返回该行。
LatestVersionsOnly	当参考列存在多个版本的数据时，是否只使用最新版本的值做比较。类型为bool值，默认值为true，表示如果参考列存在多个版本的数据时，则只使用该列最新版本的值进行比较。当设置LatestVersionsOnly为false时，如果参考列存在多个版本的数据时，则会使用该列的所有版本的值进行比较，此时只要有一个版本的值满足条件，就返回该行。

示例

构造SingleColumnValueFilter。

  //设置过滤器，当Col0列的值为0时，返回该行。
  SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter("Col0",
          SingleColumnValueFilter.CompareOperator.EQUAL, ColumnValue.fromLong(0));
  //如果不存在Col0列，也不返回该行。
  singleColumnValueFilter.setPassIfMissing(false);
  //只使用该列最新版本的值进行比较。
  singleColumnValueFilter.setLatestVersionsOnly(true);

构造CompositeColumnValueFilter。

  //composite1的条件为(Col0 == 0) AND (Col1 > 100)。
  CompositeColumnValueFilter composite1 = new CompositeColumnValueFilter(CompositeColumnValueFilter.LogicOperator.AND);
  SingleColumnValueFilter single1 = new SingleColumnValueFilter("Col0",
          SingleColumnValueFilter.CompareOperator.EQUAL, ColumnValue.fromLong(0));
  SingleColumnValueFilter single2 = new SingleColumnValueFilter("Col1",
          SingleColumnValueFilter.CompareOperator.GREATER_THAN, ColumnValue.fromLong(100));
  composite1.addFilter(single1);
  composite1.addFilter(single2);

  //composite2的条件为( (Col0 == 0) AND (Col1 > 100) ) OR (Col2 <= 10)。
  CompositeColumnValueFilter composite2 = new CompositeColumnValueFilter(CompositeColumnValueFilter.LogicOperator.OR);
  SingleColumnValueFilter single3 = new SingleColumnValueFilter("Col2",
          SingleColumnValueFilter.CompareOperator.LESS_EQUAL, ColumnValue.fromLong(10));
  composite2.addFilter(composite1);
  composite2.addFilter(single3);

计费

使用过滤器功能不影响现有计费规则。

使用过滤器后，可以有效的降低返回的数据量，但是由于过滤计算是服务器端在返回数据前进行的，并未降低磁盘IO次数，所以消耗的读CU与不使用过滤器时相同。例如使用GetRange读取到100条记录，共200 KB数据，消耗了50单位读CU，在使用过滤器后，实际只返回了10条数据，共20 KB，但是仍然会消耗50单位读CU。

错误码

详情请参见错误码参考。