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

Transaction.put介绍

[英]Puts values into the key-value store. If you put a null or the empty byte array, then this is treated like a delete to the store.
[中]将值放入键值存储。如果放入null或空字节数组，则这将被视为对存储的删除。

代码示例

代码示例来源：origin: palantir/atlasdb

private void storeData() {
  services.getTransactionManager().runTaskThrowOnConflict(txn -> {
    Map<Cell, byte[]> values = new HashMap<>(NUM_ROWS * NUM_COLS_PER_ROW);
    for (int i = 0; i < NUM_ROWS; i++) {
      for (int j = 0; j < NUM_COLS_PER_ROW; j++) {
        values.put(cell(i, j), Ints.toByteArray(i * NUM_COLS_PER_ROW + j));
      }
    }
    txn.put(this.tableRef, values);
    return null;
  });
}

代码示例来源：origin: palantir/atlasdb

private void storeData() {
  services.getTransactionManager().runTaskThrowOnConflict(txn -> {
    Map<Cell, byte[]> values = new HashMap<>(numRows * numColumnsPerRow);
    for (int i = 0; i < numRows; i++) {
      for (int j = 0; j < numColumnsPerRow; j++) {
        values.put(cell(i, j), Ints.toByteArray(i * numColumnsPerRow + j));
      }
    }
    txn.put(getTableRef(), values);
    return null;
  });
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<DataStreamIdxRow, ? extends DataStreamIdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (DataStreamIdxTrigger trigger : triggers) {
    trigger.putDataStreamIdx(values);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<DataStreamMetadataRow, ? extends DataStreamMetadataNamedColumnValue<?>> rows) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(rows));
  for (DataStreamMetadataTrigger trigger : triggers) {
    trigger.putDataStreamMetadata(rows);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<TableClearsRow, ? extends TableClearsNamedColumnValue<?>> rows) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(rows));
  for (TableClearsTrigger trigger : triggers) {
    trigger.putTableClears(rows);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<KvDynamicColumnsRow, ? extends KvDynamicColumnsColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (KvDynamicColumnsTrigger trigger : triggers) {
    trigger.putKvDynamicColumns(values);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<DataStreamValueRow, ? extends DataStreamValueNamedColumnValue<?>> rows) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(rows));
  for (DataStreamValueTrigger trigger : triggers) {
    trigger.putDataStreamValue(rows);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<UserPhotosStreamValueRow, ? extends UserPhotosStreamValueNamedColumnValue<?>> rows) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(rows));
  for (UserPhotosStreamValueTrigger trigger : triggers) {
    trigger.putUserPhotosStreamValue(rows);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<CreatedIdxRow, ? extends CreatedIdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (CreatedIdxTrigger trigger : triggers) {
    trigger.putCreatedIdx(values);
  }
}

代码示例来源：origin: palantir/atlasdb

private static void storeDataInTable(ConsecutiveNarrowTable table, int numOverwrites) {
    IntStream.range(0, numOverwrites + 1).forEach(
        $ -> table.getTransactionManager().runTaskThrowOnConflict(
            txn -> {
              Map<Cell, byte[]> values =
                  Tables.generateContinuousBatch(table.getRandom(), 0, table.getNumRows());
              txn.put(table.getTableRef(), values);
              return null;
            }));
  }
}

代码示例来源：origin: palantir/atlasdb

@Test
public void commitWithPreCommitConditionOnRetry() {
  Supplier<PreCommitCondition> conditionSupplier = mock(Supplier.class);
  when(conditionSupplier.get()).thenReturn(ALWAYS_FAILS_CONDITION)
      .thenReturn(PreCommitConditions.NO_OP);
  serializableTxManager.runTaskWithConditionWithRetry(conditionSupplier, (tx, condition) -> {
    tx.put(TABLE, ImmutableMap.of(TEST_CELL, PtBytes.toBytes("value")));
    return null;
  });
}

代码示例来源：origin: palantir/atlasdb

private void writeCells(TableReference table, ImmutableMap<Cell, byte[]> cellsToWrite) {
  Transaction writeTransaction = txManager.createNewTransaction();
  writeTransaction.put(table, cellsToWrite);
  writeTransaction.commit();
}

代码示例来源：origin: palantir/atlasdb

@Override
public void setupTableData() {
  getKvs().truncateTable(getTableRef());
  Map<Cell, byte[]> batch = Tables.generateRandomBatch(random, 1);
  getTransactionManager().runTaskThrowOnConflict(txn -> {
    txn.put(getTableRef(), batch);
    return null;
  });
  cells = batch.keySet();
}

代码示例来源：origin: palantir/atlasdb

public long addTodoWithIdAndReturnTimestamp(long id, Todo todo) {
  return transactionManager.runTaskWithRetry((transaction) -> {
    Cell thisCell = Cell.create(ValueType.FIXED_LONG.convertFromJava(id),
        TodoSchema.todoTextColumn());
    Map<Cell, byte[]> write = ImmutableMap.of(thisCell, ValueType.STRING.convertFromJava(todo.text()));
    transaction.put(TodoSchema.todoTable(), write);
    return transaction.getTimestamp();
  });
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<StreamTestMaxMemStreamHashAidxRow, ? extends StreamTestMaxMemStreamHashAidxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (StreamTestMaxMemStreamHashAidxTrigger trigger : triggers) {
    trigger.putStreamTestMaxMemStreamHashAidx(values);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<FooToIdCondIdxRow, ? extends FooToIdCondIdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (FooToIdCondIdxTrigger trigger : triggers) {
    trigger.putFooToIdCondIdx(values);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<StreamTestWithHashStreamIdxRow, ? extends StreamTestWithHashStreamIdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (StreamTestWithHashStreamIdxTrigger trigger : triggers) {
    trigger.putStreamTestWithHashStreamIdx(values);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<Index2IdxRow, ? extends Index2IdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (Index2IdxTrigger trigger : triggers) {
    trigger.putIndex2Idx(values);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<StreamTestStreamHashAidxRow, ? extends StreamTestStreamHashAidxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (StreamTestStreamHashAidxTrigger trigger : triggers) {
    trigger.putStreamTestStreamHashAidx(values);
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public void put(Multimap<Index1IdxRow, ? extends Index1IdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (Index1IdxTrigger trigger : triggers) {
    trigger.putIndex1Idx(values);
  }
}