Java Mutation类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.google.bigtable.v2.Mutation类的典型用法代码示例。如果您正苦于以下问题：Java Mutation类的具体用法？Java Mutation怎么用？Java Mutation使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

Mutation类属于com.google.bigtable.v2包，在下文中一共展示了Mutation类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: processElement

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@ProcessElement
public void processElement(ProcessContext c) {
	InputContent i = c.element();
	String jobName = c.getPipelineOptions().getJobName();
	ByteString rowkey = ByteString.copyFromUtf8(jobName + "#" + i.expectedDocumentHash); 
	ByteString value = ByteString.copyFromUtf8(i.text);
	
	Iterable<Mutation> mutations =
		ImmutableList.of(Mutation.newBuilder()
			.setSetCell(
				Mutation.SetCell.newBuilder()
					.setFamilyName(IndexerPipelineUtils.DEAD_LETTER_TABLE_ERR_CF)
					.setColumnQualifier(ByteString.copyFromUtf8("text"))
					.setValue(value)
			)
               .build());
	
	c.output(KV.of(rowkey, mutations));			
}

开发者ID:GoogleCloudPlatform，项目名称:dataflow-opinion-analysis，代码行数:20，代码来源:FileIndexerPipeline.java

示例2: testDeleteRow

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testDeleteRow() throws Exception {
  final BigtableMutationImpl bigtableMutationImpl = (BigtableMutationImpl) this.bigtableMutation.deleteRow();
  verifyGetMutateRowRequest();

  bigtableMutationImpl.execute();
  bigtableMutationImpl.executeAsync();

  assertEquals(1, bigtableMutationImpl.getMutateRowRequest().getMutationsCount());
  final Mutation mutation = bigtableMutationImpl.getMutateRowRequest().getMutations(0);
  assertEquals(Mutation.MutationCase.DELETE_FROM_ROW, mutation.getMutationCase());
  assertEquals(Mutation.DeleteFromRow.getDefaultInstance(), mutation.getDeleteFromRow());
  assertEquals(Mutation.DeleteFromFamily.getDefaultInstance(), mutation.getDeleteFromFamily());
  assertEquals(Mutation.DeleteFromColumn.getDefaultInstance(), mutation.getDeleteFromColumn());
  assertEquals(Mutation.SetCell.getDefaultInstance(), mutation.getSetCell());

  verify(bigtableMock.getMockedDataClient()).mutateRow(bigtableMutation.getMutateRowRequest().build());
  verify(bigtableMock.getMockedDataClient()).mutateRowAsync(bigtableMutation.getMutateRowRequest().build());
  verifyNoMoreInteractions(bigtableMock.getMockedDataClient());
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:21，代码来源:BigtableMutationImplTest.java

示例3: testWritingFailsTableDoesNotExist

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
/** Tests that when writing to a non-existent table, the write fails. */
@Test
public void testWritingFailsTableDoesNotExist() throws Exception {
  final String table = "TEST-TABLE";

  PCollection<KV<ByteString, Iterable<Mutation>>> emptyInput =
      p.apply(
          Create.empty(
              KvCoder.of(ByteStringCoder.of(), IterableCoder.of(ProtoCoder.of(Mutation.class)))));

  // Exception will be thrown by write.validate() when writeToDynamic is applied.
  thrown.expect(IllegalArgumentException.class);
  thrown.expectMessage(String.format("Table %s does not exist", table));

  emptyInput.apply("write", defaultWrite.withTableId(table));
  p.run();
}

开发者ID:apache，项目名称:beam，代码行数:18，代码来源:BigtableIOTest.java

示例4: deleteCellsFromColumn

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Override
public BigtableMutation deleteCellsFromColumn(final String columnFamily,
                                              final String columnQualifier,
                                              final Optional<Long> startTimestampMicros,
                                              final Optional<Long> endTimestampMicros) {
  final TimestampRange.Builder timestampRange = TimestampRange.newBuilder();
  startTimestampMicros.ifPresent(timestampRange::setStartTimestampMicros);
  endTimestampMicros.ifPresent(timestampRange::setEndTimestampMicros);

  final Mutation.DeleteFromColumn.Builder deleteFromColumn =
      Mutation.DeleteFromColumn.newBuilder()
          .setFamilyName(columnFamily)
          .setColumnQualifier(ByteString.copyFromUtf8(columnQualifier))
          .setTimeRange(timestampRange);

  mutateRowRequest.addMutations(Mutation.newBuilder().setDeleteFromColumn(deleteFromColumn));
  return this;
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:19，代码来源:BigtableMutationImpl.java

示例5: testDeleteColumnFamily

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testDeleteColumnFamily() throws Exception {
  final BigtableMutationImpl bigtableMutationImpl =
          (BigtableMutationImpl) this.bigtableMutation.deleteColumnFamily("family");
  verifyGetMutateRowRequest();

  bigtableMutationImpl.execute();
  bigtableMutationImpl.executeAsync();

  assertEquals(1, bigtableMutationImpl.getMutateRowRequest().getMutationsCount());
  final Mutation mutation = bigtableMutationImpl.getMutateRowRequest().getMutations(0);
  assertEquals(Mutation.MutationCase.DELETE_FROM_FAMILY, mutation.getMutationCase());
  assertEquals("family", mutation.getDeleteFromFamily().getFamilyName());
  assertEquals(Mutation.DeleteFromRow.getDefaultInstance(), mutation.getDeleteFromRow());
  assertEquals(Mutation.DeleteFromColumn.getDefaultInstance(), mutation.getDeleteFromColumn());
  assertEquals(Mutation.SetCell.getDefaultInstance(), mutation.getSetCell());

  verify(bigtableMock.getMockedDataClient()).mutateRow(bigtableMutation.getMutateRowRequest().build());
  verify(bigtableMock.getMockedDataClient()).mutateRowAsync(bigtableMutation.getMutateRowRequest().build());
  verifyNoMoreInteractions(bigtableMock.getMockedDataClient());
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:22，代码来源:BigtableMutationImplTest.java

示例6: testDeleteColumn

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testDeleteColumn() throws Exception {
  final BigtableMutationImpl bigtableMutationImpl =
          (BigtableMutationImpl) this.bigtableMutation.deleteColumn("family:qualifier");
  verifyGetMutateRowRequest();

  bigtableMutationImpl.execute();
  bigtableMutationImpl.executeAsync();

  assertEquals(1, bigtableMutationImpl.getMutateRowRequest().getMutationsCount());
  final Mutation mutation = bigtableMutationImpl.getMutateRowRequest().getMutations(0);
  assertEquals(Mutation.MutationCase.DELETE_FROM_COLUMN, mutation.getMutationCase());
  assertEquals("family", mutation.getDeleteFromColumn().getFamilyName());
  assertEquals("qualifier", mutation.getDeleteFromColumn().getColumnQualifier().toStringUtf8());
  assertEquals(Mutation.DeleteFromRow.getDefaultInstance(), mutation.getDeleteFromRow());
  assertEquals(Mutation.DeleteFromFamily.getDefaultInstance(), mutation.getDeleteFromFamily());
  assertEquals(Mutation.SetCell.getDefaultInstance(), mutation.getSetCell());

  verify(bigtableMock.getMockedDataClient()).mutateRow(bigtableMutation.getMutateRowRequest().build());
  verify(bigtableMock.getMockedDataClient()).mutateRowAsync(bigtableMutation.getMutateRowRequest().build());
  verifyNoMoreInteractions(bigtableMock.getMockedDataClient());
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:23，代码来源:BigtableMutationImplTest.java

示例7: testDeleteColumnFamilyAndQualifier

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testDeleteColumnFamilyAndQualifier() throws Exception {
  final BigtableMutationImpl bigtableMutationImpl =
          (BigtableMutationImpl) this.bigtableMutation.deleteColumn("family", "qualifier");
  verifyGetMutateRowRequest();

  bigtableMutationImpl.execute();
  bigtableMutationImpl.executeAsync();

  assertEquals(1, bigtableMutationImpl.getMutateRowRequest().getMutationsCount());
  final Mutation mutation = bigtableMutationImpl.getMutateRowRequest().getMutations(0);
  assertEquals(Mutation.MutationCase.DELETE_FROM_COLUMN, mutation.getMutationCase());
  assertEquals("family", mutation.getDeleteFromColumn().getFamilyName());
  assertEquals("qualifier", mutation.getDeleteFromColumn().getColumnQualifier().toStringUtf8());
  assertEquals(Mutation.DeleteFromRow.getDefaultInstance(), mutation.getDeleteFromRow());
  assertEquals(Mutation.DeleteFromFamily.getDefaultInstance(), mutation.getDeleteFromFamily());
  assertEquals(Mutation.SetCell.getDefaultInstance(), mutation.getSetCell());

  verify(bigtableMock.getMockedDataClient()).mutateRow(bigtableMutation.getMutateRowRequest().build());
  verify(bigtableMock.getMockedDataClient()).mutateRowAsync(bigtableMutation.getMutateRowRequest().build());
  verifyNoMoreInteractions(bigtableMock.getMockedDataClient());
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:23，代码来源:BigtableMutationImplTest.java

示例8: writeRecord

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Override
public ListenableFuture<MutateRowResponse> writeRecord(
    KV<ByteString, Iterable<Mutation>> record)
    throws IOException {
  MutateRowRequest r =
      MutateRowRequest.newBuilder()
          .setTableName(tableName)
          .setRowKey(record.getKey())
          .addAllMutations(record.getValue())
          .build();
  return bulkMutation.add(r);
}

开发者ID:apache，项目名称:beam，代码行数:13，代码来源:BigtableServiceImpl.java

示例9: expand

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Override
public PDone expand(PCollection<KV<ByteString, Iterable<Mutation>>> input) {
  getBigtableConfig().validate();

  input.apply(ParDo.of(new BigtableWriterFn(getBigtableConfig().getTableId(),
      new SerializableFunction<PipelineOptions, BigtableService>() {
        @Override
        public BigtableService apply(PipelineOptions options) {
          return getBigtableConfig().getBigtableService(options);
        }
      })));
  return PDone.in(input.getPipeline());
}

开发者ID:apache，项目名称:beam，代码行数:14，代码来源:BigtableIO.java

示例10: BigtableWriteException

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
public BigtableWriteException(KV<ByteString, Iterable<Mutation>> record, Throwable cause) {
  super(
      String.format(
          "Error mutating row %s with mutations %s",
          record.getKey().toStringUtf8(),
          record.getValue()),
      cause);
}

开发者ID:apache，项目名称:beam，代码行数:9，代码来源:BigtableIO.java

示例11: testCoderInference

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testCoderInference() {
  SerializableFunction<SchemaAndRecord, KV<ByteString, Mutation>> parseFn =
      new SerializableFunction<SchemaAndRecord, KV<ByteString, Mutation>>() {
        @Override
        public KV<ByteString, Mutation> apply(SchemaAndRecord input) {
          return null;
        }
      };

  assertEquals(
      KvCoder.of(ByteStringCoder.of(), ProtoCoder.of(Mutation.class)),
      BigQueryIO.read(parseFn).inferCoder(CoderRegistry.createDefault()));
}

开发者ID:apache，项目名称:beam，代码行数:15，代码来源:BigQueryIOReadTest.java

示例12: testE2EBigtableWrite

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testE2EBigtableWrite() throws Exception {
  final String tableName = bigtableOptions.getInstanceName().toTableNameStr(tableId);
  final String instanceName = bigtableOptions.getInstanceName().toString();
  final int numRows = 1000;
  final List<KV<ByteString, ByteString>> testData = generateTableData(numRows);

  createEmptyTable(instanceName, tableId);

  Pipeline p = Pipeline.create(options);
  p.apply(GenerateSequence.from(0).to(numRows))
      .apply(ParDo.of(new DoFn<Long, KV<ByteString, Iterable<Mutation>>>() {
        @ProcessElement
        public void processElement(ProcessContext c) {
          int index = c.element().intValue();

          Iterable<Mutation> mutations =
              ImmutableList.of(Mutation.newBuilder()
                  .setSetCell(
                      Mutation.SetCell.newBuilder()
                          .setValue(testData.get(index).getValue())
                          .setFamilyName(COLUMN_FAMILY_NAME))
                  .build());
          c.output(KV.of(testData.get(index).getKey(), mutations));
        }
      }))
      .apply(BigtableIO.write()
        .withBigtableOptions(bigtableOptions)
        .withTableId(tableId));
  p.run();

  // Test number of column families and column family name equality
  Table table = getTable(tableName);
  assertThat(table.getColumnFamiliesMap().keySet(), Matchers.hasSize(1));
  assertThat(table.getColumnFamiliesMap(), Matchers.hasKey(COLUMN_FAMILY_NAME));

  // Test table data equality
  List<KV<ByteString, ByteString>> tableData = getTableData(tableName);
  assertThat(tableData, Matchers.containsInAnyOrder(testData.toArray()));
}

开发者ID:apache，项目名称:beam，代码行数:41，代码来源:BigtableWriteIT.java

示例13: makeWrite

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
/** Helper function to make a single row mutation to be written. */
private static KV<ByteString, Iterable<Mutation>> makeWrite(String key, String value) {
  ByteString rowKey = ByteString.copyFromUtf8(key);
  Iterable<Mutation> mutations =
      ImmutableList.of(
          Mutation.newBuilder()
              .setSetCell(SetCell.newBuilder().setValue(ByteString.copyFromUtf8(value)))
              .build());
  return KV.of(rowKey, mutations);
}

开发者ID:apache，项目名称:beam，代码行数:11，代码来源:BigtableIOTest.java

示例14: writeRecord

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Override
public ListenableFuture<MutateRowResponse> writeRecord(
    KV<ByteString, Iterable<Mutation>> record) {
  service.verifyTableExists(tableId);
  Map<ByteString, ByteString> table = service.getTable(tableId);
  ByteString key = record.getKey();
  for (Mutation m : record.getValue()) {
    SetCell cell = m.getSetCell();
    if (cell.getValue().isEmpty()) {
      return Futures.immediateFailedCheckedFuture(new IOException("cell value missing"));
    }
    table.put(key, cell.getValue());
  }
  return Futures.immediateFuture(MutateRowResponse.getDefaultInstance());
}

开发者ID:apache，项目名称:beam，代码行数:16，代码来源:BigtableIOTest.java

示例15: deleteColumnFamily

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Override
public BigtableMutation deleteColumnFamily(String columnFamily) {
  final Mutation.DeleteFromFamily.Builder deleteFromFamily =
      Mutation.DeleteFromFamily.newBuilder().setFamilyName(columnFamily);
  mutateRowRequest.addMutations(Mutation.newBuilder().setDeleteFromFamily(deleteFromFamily));
  return this;
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:8，代码来源:BigtableMutationImpl.java

示例16: write

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Override
public BigtableMutation write(final String columnFamily, final String columnQualifier,
                              final ByteString value, final long timestampMicros) {
  final Mutation.SetCell.Builder setCell = Mutation.SetCell.newBuilder()
      .setFamilyName(columnFamily)
      .setColumnQualifier(ByteString.copyFromUtf8(columnQualifier))
      .setValue(value)
      .setTimestampMicros(timestampMicros);
  mutateRowRequest.addMutations(Mutation.newBuilder().setSetCell(setCell));
  return this;
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:12，代码来源:BigtableMutationImpl.java

示例17: testDeleteCellsFromColumn

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testDeleteCellsFromColumn() throws Exception {
  final BigtableMutationImpl bigtableMutationImpl = (BigtableMutationImpl) this.bigtableMutation
          .deleteCellsFromColumn("family", "qualifier", Optional.empty(), Optional.empty())
          .deleteCellsFromColumn("family", "qualifier", Optional.of(100L), Optional.of(999L));
  verifyGetMutateRowRequest();

  bigtableMutationImpl.execute();
  bigtableMutationImpl.executeAsync();

  assertEquals(2, bigtableMutationImpl.getMutateRowRequest().getMutationsCount());

  Mutation mutation = bigtableMutationImpl.getMutateRowRequest().getMutations(0);
  assertEquals(Mutation.MutationCase.DELETE_FROM_COLUMN, mutation.getMutationCase());
  assertEquals("family", mutation.getDeleteFromColumn().getFamilyName());
  assertEquals("qualifier", mutation.getDeleteFromColumn().getColumnQualifier().toStringUtf8());
  assertEquals(TimestampRange.getDefaultInstance(), mutation.getDeleteFromColumn().getTimeRange());
  assertEquals(Mutation.DeleteFromRow.getDefaultInstance(), mutation.getDeleteFromRow());
  assertEquals(Mutation.DeleteFromFamily.getDefaultInstance(), mutation.getDeleteFromFamily());
  assertEquals(Mutation.SetCell.getDefaultInstance(), mutation.getSetCell());

  mutation = bigtableMutationImpl.getMutateRowRequest().getMutations(1);
  assertEquals(Mutation.MutationCase.DELETE_FROM_COLUMN, mutation.getMutationCase());
  assertEquals("family", mutation.getDeleteFromColumn().getFamilyName());
  assertEquals("qualifier", mutation.getDeleteFromColumn().getColumnQualifier().toStringUtf8());
  assertEquals(100L, mutation.getDeleteFromColumn().getTimeRange().getStartTimestampMicros());
  assertEquals(999L, mutation.getDeleteFromColumn().getTimeRange().getEndTimestampMicros());
  assertEquals(Mutation.DeleteFromRow.getDefaultInstance(), mutation.getDeleteFromRow());
  assertEquals(Mutation.DeleteFromFamily.getDefaultInstance(), mutation.getDeleteFromFamily());
  assertEquals(Mutation.SetCell.getDefaultInstance(), mutation.getSetCell());

  verify(bigtableMock.getMockedDataClient()).mutateRow(bigtableMutation.getMutateRowRequest().build());
  verify(bigtableMock.getMockedDataClient()).mutateRowAsync(bigtableMutation.getMutateRowRequest().build());
  verifyNoMoreInteractions(bigtableMock.getMockedDataClient());
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:36，代码来源:BigtableMutationImplTest.java

示例18: testWriteColumnValue

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testWriteColumnValue() throws Exception {
  final BigtableMutationImpl bigtableMutationImpl = (BigtableMutationImpl) this.bigtableMutation
          .write("family:qualifier", ByteString.copyFromUtf8("value"))
          .write("family", "qualifier", ByteString.copyFromUtf8("value"));
  verifyGetMutateRowRequest();

  bigtableMutationImpl.execute();
  bigtableMutationImpl.executeAsync();

  assertEquals(2, bigtableMutationImpl.getMutateRowRequest().getMutationsCount());
  for (Mutation mutation : bigtableMutationImpl.getMutateRowRequest().getMutationsList()) {
    assertEquals(Mutation.MutationCase.SET_CELL, mutation.getMutationCase());
    assertEquals("family", mutation.getSetCell().getFamilyName());
    assertEquals("qualifier", mutation.getSetCell().getColumnQualifier().toStringUtf8());
    assertEquals("value", mutation.getSetCell().getValue().toStringUtf8());
    assertEquals(Mutation.DeleteFromRow.getDefaultInstance(), mutation.getDeleteFromRow());
    assertEquals(Mutation.DeleteFromFamily.getDefaultInstance(), mutation.getDeleteFromFamily());
    assertEquals(Mutation.DeleteFromColumn.getDefaultInstance(), mutation.getDeleteFromColumn());

    // Check timestamp in last 1 second
    final long tsMillis = TimeUnit.MICROSECONDS.toMillis(mutation.getSetCell().getTimestampMicros());
    final long nowMillis = System.currentTimeMillis();
    assertTrue(tsMillis <= nowMillis && tsMillis > nowMillis - TimeUnit.SECONDS.toMillis(1));
  }

  verify(bigtableMock.getMockedDataClient()).mutateRow(bigtableMutation.getMutateRowRequest().build());
  verify(bigtableMock.getMockedDataClient()).mutateRowAsync(bigtableMutation.getMutateRowRequest().build());
  verifyNoMoreInteractions(bigtableMock.getMockedDataClient());
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:31，代码来源:BigtableMutationImplTest.java

示例19: testWriteColumnAndTimestamp

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
@Test
public void testWriteColumnAndTimestamp() throws Exception {
  final BigtableMutationImpl bigtableMutationImpl = (BigtableMutationImpl) this.bigtableMutation
          .write("family:qualifier", ByteString.copyFromUtf8("value"), 100L)
          .write("family", "qualifier", ByteString.copyFromUtf8("value"), 100L);
  verifyGetMutateRowRequest();

  bigtableMutationImpl.execute();
  bigtableMutationImpl.executeAsync();

  assertEquals(2, bigtableMutationImpl.getMutateRowRequest().getMutationsCount());

  for (Mutation mutation : bigtableMutationImpl.getMutateRowRequest().getMutationsList()) {
    assertEquals(Mutation.MutationCase.SET_CELL, mutation.getMutationCase());
    assertEquals("family", mutation.getSetCell().getFamilyName());
    assertEquals("qualifier", mutation.getSetCell().getColumnQualifier().toStringUtf8());
    assertEquals("value", mutation.getSetCell().getValue().toStringUtf8());
    assertEquals(100L, mutation.getSetCell().getTimestampMicros());
    assertEquals(Mutation.DeleteFromRow.getDefaultInstance(), mutation.getDeleteFromRow());
    assertEquals(Mutation.DeleteFromFamily.getDefaultInstance(), mutation.getDeleteFromFamily());
    assertEquals(Mutation.DeleteFromColumn.getDefaultInstance(), mutation.getDeleteFromColumn());
  }

  verify(bigtableMock.getMockedDataClient()).mutateRow(bigtableMutation.getMutateRowRequest().build());
  verify(bigtableMock.getMockedDataClient()).mutateRowAsync(bigtableMutation.getMutateRowRequest().build());
  verifyNoMoreInteractions(bigtableMock.getMockedDataClient());
}

开发者ID:spotify，项目名称:simple-bigtable，代码行数:28，代码来源:BigtableMutationImplTest.java

示例20: mutateRow

import com.google.bigtable.v2.Mutation; //导入依赖的package包/类
public AsyncFuture<Void> mutateRow(final ByteString rowKey, final Mutations mutations) {
    return async.call(() -> {
        mutations.getMutations().forEach(mutation -> {
            switch (mutation.getMutationCase()) {
                case SET_CELL:
                    final Mutation.SetCell setCell = mutation.getSetCell();
                    final ColumnFamily columnFamily =
                        columnFamilies.get(Pair.of(table, setCell.getFamilyName()));

                    if (columnFamily == null) {
                        throw new IllegalArgumentException(
                            "no such column family: " + setCell.getFamilyName());
                    }

                    RowStorage rowStorage;

                    synchronized (lock) {
                        final Pair<ByteString, ColumnFamily> key =
                            Pair.of(rowKey, columnFamily);

                        rowStorage = rows.get(key);

                        if (rowStorage == null) {
                            rowStorage = new RowStorage(columnFamily);
                            rows.put(key, rowStorage);
                        }
                    }

                    rowStorage.runSetCell(setCell);
                    break;
                default:
                    throw new IllegalArgumentException(
                        "Unsupported mutation: " + mutation.getMutationCase());
            }
        });

        return null;
    });
}

开发者ID:spotify，项目名称:heroic，代码行数:40，代码来源:FakeBigtableConnection.java

注：本文中的com.google.bigtable.v2.Mutation类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java HelpSystem类代码示例发布时间：2022-05-22

Java JsonListEntry类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18260|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9674|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8177|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8548|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8456|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9388|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8427|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7862|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8411|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7394|2022-11-06

客服电话

电子邮件

Java Mutation类代码示例

示例1: processElement

示例2: testDeleteRow

示例3: testWritingFailsTableDoesNotExist

示例4: deleteCellsFromColumn

示例5: testDeleteColumnFamily

示例6: testDeleteColumn

示例7: testDeleteColumnFamilyAndQualifier

示例8: writeRecord

示例9: expand

示例10: BigtableWriteException

示例11: testCoderInference

示例12: testE2EBigtableWrite

示例13: makeWrite

示例14: writeRecord

示例15: deleteColumnFamily

示例16: write

示例17: testDeleteCellsFromColumn

示例18: testWriteColumnValue

示例19: testWriteColumnAndTimestamp

示例20: mutateRow

请发表评论

全部评论

上一篇：

下一篇：

CVE-2022-2366

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053