com.palantir.atlasdb.transaction.api.Transaction.useTable()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(6.5k)|赞(0)|评价(0)|浏览(115)

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

Transaction.useTable介绍

[英]Informs the transaction that a particular table has been written to.
[中]通知事务已写入特定表。

代码示例

代码示例来源: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<SnapshotsStreamIdxRow, ? extends SnapshotsStreamIdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (SnapshotsStreamIdxTrigger trigger : triggers) {
    trigger.putSnapshotsStreamIdx(values);
  }
}

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

@Override
public void put(Multimap<SweepNameToIdRow, ? extends SweepNameToIdNamedColumnValue<?>> rows) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(rows));
  for (SweepNameToIdTrigger trigger : triggers) {
    trigger.putSweepNameToId(rows);
  }
}

代码示例来源: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

@Override
public void put(Multimap<BlobsSerializableRow, ? extends BlobsSerializableNamedColumnValue<?>> rows) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(rows));
  for (BlobsSerializableTrigger trigger : triggers) {
    trigger.putBlobsSerializable(rows);
  }
}

代码示例来源: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<StreamTestStreamIdxRow, ? extends StreamTestStreamIdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (StreamTestStreamIdxTrigger trigger : triggers) {
    trigger.putStreamTestStreamIdx(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<StreamTestWithHashStreamHashAidxRow, ? extends StreamTestWithHashStreamHashAidxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (StreamTestWithHashStreamHashAidxTrigger trigger : triggers) {
    trigger.putStreamTestWithHashStreamHashAidx(values);
  }
}

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

@Override
public void put(Multimap<TestHashComponentsStreamIdxRow, ? extends TestHashComponentsStreamIdxColumnValue> values) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(values));
  for (TestHashComponentsStreamIdxTrigger trigger : triggers) {
    trigger.putTestHashComponentsStreamIdx(values);
  }
}

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

@Override
public void put(Multimap<TestHashComponentsStreamMetadataRow, ? extends TestHashComponentsStreamMetadataNamedColumnValue<?>> rows) {
  t.useTable(tableRef, this);
  t.put(tableRef, ColumnValues.toCellValues(rows));
  for (TestHashComponentsStreamMetadataTrigger trigger : triggers) {
    trigger.putTestHashComponentsStreamMetadata(rows);
  }
}

代码示例来源: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);
  }
}

相关文章