本文整理了Java中com.netflix.astyanax.model.Row.getRawKey
方法的一些代码示例,展示了Row.getRawKey
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Row.getRawKey
方法的具体详情如下:
包路径:com.netflix.astyanax.model.Row
类名称: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;
内容来源于网络,如有侵权,请联系作者删除!