com.netflix.astyanax.model.Row.getRawKey()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(4.9k)|赞(0)|评价(0)|浏览(91)

本文整理了Java中com.netflix.astyanax.model.Row.getRawKey方法的一些代码示例,展示了Row.getRawKey的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Row.getRawKey方法的具体详情如下:
包路径:com.netflix.astyanax.model.Row
类名称:Row
方法名:getRawKey

Row.getRawKey介绍

[英]Return the raw byte buffer for this key
[中]返回此键的原始字节缓冲区

代码示例

代码示例来源:origin: com.bazaarvoice.emodb/emodb-sor

ByteBuffer rowKey = row.getRawKey();
long nextTableUuid = AstyanaxStorage.getTableUuid(row.getRawKey());
if (nextTableUuid != tableUuid) {
int shardId = AstyanaxStorage.getShardId(row.getRawKey());
ByteBuffer nextPossibleTableStart = AstyanaxStorage.getRowKeyRaw(shardId, tableUuid + 1, "");
ByteBuffer end = rowRange.getEnd();

代码示例来源:origin: com.bazaarvoice.emodb/emodb-sor

ByteBuffer rowKey = row.getRawKey();
long nextTableUuid = AstyanaxStorage.getTableUuid(row.getRawKey());
if (nextTableUuid != tableUuid) {
int shardId = AstyanaxStorage.getShardId(row.getRawKey());
ByteBuffer nextPossibleTableStart = AstyanaxStorage.getRowKeyRaw(shardId, tableUuid + 1, "");
ByteBuffer end = rowRange.getEnd();

代码示例来源:origin: bazaarvoice/emodb

ByteBuffer rowKey = row.getRawKey();
long nextTableUuid = AstyanaxStorage.getTableUuid(row.getRawKey());
if (nextTableUuid != tableUuid) {
int shardId = AstyanaxStorage.getShardId(row.getRawKey());
ByteBuffer nextPossibleTableStart = AstyanaxStorage.getRowKeyRaw(shardId, tableUuid + 1, "");
ByteBuffer end = rowRange.getEnd();

代码示例来源:origin: bazaarvoice/emodb

ByteBuffer rowKey = row.getRawKey();
long nextTableUuid = AstyanaxStorage.getTableUuid(row.getRawKey());
if (nextTableUuid != tableUuid) {
int shardId = AstyanaxStorage.getShardId(row.getRawKey());
ByteBuffer nextPossibleTableStart = AstyanaxStorage.getRowKeyRaw(shardId, tableUuid + 1, "");
ByteBuffer end = rowRange.getEnd();

代码示例来源:origin: com.netflix.astyanax/astyanax-cassandra

continue;
rowCount++;
String idString = serializers.keyAsString(row.getRawKey());
count += writeColumnsAsRows(idString, row.getColumns(), firstRow);
firstRow = false;
    String idString = serializers.keyAsString(row.getRawKey());
    out.append(jsonifyString(this.fieldNames.get(Field.ROW_KEY))).append(":")
        .append(jsonifyString(idString));
    String idString = serializers.keyAsString(row.getRawKey());
    out.append(jsonifyString(idString)).append(":{");

代码示例来源:origin: com.netflix.astyanax/astyanax-cql

String lastToken = partitioner.getTokenForKey(lastRow.getRawKey());
checkpointManager.trackCheckpoint(startToken, currentToken);
if (repeatLastToken) {
    if (!lastToken.equals(partitioner.getTokenForKey(rows.getRowByIndex(i).getRawKey()))) {
      break;

代码示例来源:origin: com.bazaarvoice.astyanax/astyanax-recipes

String lastToken = partitioner.getTokenForKey(lastRow.getRawKey());
checkpointManager.trackCheckpoint(startToken, currentToken);
if (repeatLastToken) {
    if (!lastToken.equals(partitioner.getTokenForKey(rows.getRowByIndex(i).getRawKey()))) {
      break;

代码示例来源:origin: com.netflix.astyanax/astyanax-recipes

String lastToken = partitioner.getTokenForKey(lastRow.getRawKey());
checkpointManager.trackCheckpoint(startToken, currentToken);
if (repeatLastToken) {
    if (!lastToken.equals(partitioner.getTokenForKey(rows.getRowByIndex(i).getRawKey()))) {
      break;

代码示例来源:origin: com.bazaarvoice.emodb/emodb-sor

ByteBuffer newRowKey = dest.getRowKey(AstyanaxStorage.getContentKey(row.getRawKey()));
  C lastColumn = columns.getColumnByIndex(columns.size() - 1).getName();
  Iterator<List<Column<C>>> columnsIter = Iterators.partition(
      columnScan(row.getRawKey(), sourcePlacement, sourceCf, lastColumn, null,
          false, columnInc, Long.MAX_VALUE, 1, ReadConsistency.STRONG),
      MAX_COLUMN_SCAN_BATCH);

代码示例来源:origin: com.bazaarvoice.emodb/emodb-sor

ByteBuffer newRowKey = dest.getRowKey(AstyanaxStorage.getContentKey(row.getRawKey()));
  UUID lastColumn = columns.getColumnByIndex(columns.size() - 1).getName();
  Iterator<List<Column<UUID>>> columnsIter = Iterators.partition(
      columnScan(row.getRawKey(), sourcePlacement, sourceCf, lastColumn, null,
          false, Long.MAX_VALUE, 1, ReadConsistency.STRONG),
      MAX_COLUMN_SCAN_BATCH);

代码示例来源:origin: bazaarvoice/emodb

ByteBuffer newRowKey = dest.getRowKey(AstyanaxStorage.getContentKey(row.getRawKey()));
  UUID lastColumn = columns.getColumnByIndex(columns.size() - 1).getName();
  Iterator<List<Column<UUID>>> columnsIter = Iterators.partition(
      columnScan(row.getRawKey(), sourcePlacement, sourceCf, lastColumn, null,
          false, Long.MAX_VALUE, 1, ReadConsistency.STRONG),
      MAX_COLUMN_SCAN_BATCH);

代码示例来源:origin: bazaarvoice/emodb

ByteBuffer newRowKey = dest.getRowKey(AstyanaxStorage.getContentKey(row.getRawKey()));
  C lastColumn = columns.getColumnByIndex(columns.size() - 1).getName();
  Iterator<List<Column<C>>> columnsIter = Iterators.partition(
      columnScan(row.getRawKey(), sourcePlacement, sourceCf, lastColumn, null,
          false, columnInc, Long.MAX_VALUE, 1, ReadConsistency.STRONG),
      MAX_COLUMN_SCAN_BATCH);

代码示例来源:origin: bazaarvoice/emodb

for (Row<ByteBuffer, Composite> row : rows) {
  ByteBuffer newRowKey = dest.getRowKey(AstyanaxStorage.getContentKey(row.getRawKey()));
          .getKey(row.getRawKey())
          .getColumn(getColumn(ColumnGroup.Z, chunkId));
      Column<Composite> chunk;

相关文章