BigTable ReadModifyWriteRow 支持映射函数

Question

我知道 BigTable 支持操作 append 和 increment 使用 ReadModifyWriteRow 请求，但我想知道是否有支持或替代方法来使用更通用的映射函数，其中单元格的值可以是在某种闭包中访问和修改？例如，在单元格中按位ANDing 长值：

Function<Long, Long> modifyFunc = f -> f & 10L;

ReadModifyWriteRow
  .create("tableName", "rowKey")
  .apply("family", "qualifier", modifyFunc);

Answer 1

Bigtable 不支持进行这样的映射，因此您可以尝试以下选项。由于需要一致性，这仅适用于单个集群实例。

您可以添加一列来跟踪行版本（除了现有的行版本），然后您可以读取数据和版本，在内存中对其进行修改，然后使用版本和新值执行 checkAndMutate。像这样的：

Row row = dataClient.readRow(tableId, rowkey);
ArrayList<RowCell> cells = row.getCells();

// Get the value and timestamp/version from the cell you are targetting.
RowCell cell = cells.get(...);
long version = cell.getTimestamp();
ByteString value = cell.getValue();

// Do your mapping to the new value.
ByteString newValue = ...;

Mutation mutation =
    Mutation.create().setCell(COLUMN_FAMILY_NAME, COLUMN_NAME, timestamp, newValue);

// Filter on a column that tracks the version to do validation.
Filter filter =
    FILTERS
        .chain()
        .filter(FILTERS.family().exactMatch(COLUMN_FAMILY_NAME))
        .filter(FILTERS.qualifier().exactMatch(VERSION_COLUMN))
        .filter(FILTERS.value().exactMatch(version));

ConditionalRowMutation conditionalRowMutation =
    ConditionalRowMutation.create(tableId, rowkey).condition(filter).then(mutation);

boolean success = dataClient.checkAndMutateRow(conditionalRowMutation);