@Test public void testPutIsAdapted() { Put put = new Put(dataHelper.randomData("rk1")); adapter.adapt(put, mutation); Mockito.verify(putAdapter, Mockito.times(1)) .adapt(Mockito.any(Put.class), Mockito.eq(mutation)); }
@Override public void adapt( Mutation mutation, com.google.cloud.bigtable.data.v2.models.MutationApi<?> mutationModel) { MutationAdapter<Mutation> adapter = adapterMap.get(mutation.getClass()); if (adapter == null) { throw new UnsupportedOperationException( String.format( "Cannot adapt mutation of type %s.", mutation.getClass().getCanonicalName())); } adapter.adapt(mutation, mutationModel); }
HBaseMutationAdapter extends MutationAdapter<Mutation> { @Override public void adapt( Mutation mutation, com.google.cloud.bigtable.data.v2.models.MutationApi<?> mutationModel) { MutationAdapter<Mutation> adapter = adapterMap.get(mutation.getClass()); if (adapter == null) { throw new UnsupportedOperationException( String.format( "Cannot adapt mutation of type %s.", mutation.getClass().getCanonicalName())); } adapter.adapt(mutation, mutationModel); } }
HBaseMutationAdapter extends MutationAdapter<Mutation> { @Override public void adapt( Mutation mutation, com.google.cloud.bigtable.data.v2.models.MutationApi<?> mutationModel) { MutationAdapter<Mutation> adapter = adapterMap.get(mutation.getClass()); if (adapter == null) { throw new UnsupportedOperationException( String.format( "Cannot adapt mutation of type %s.", mutation.getClass().getCanonicalName())); } adapter.adapt(mutation, mutationModel); } HBaseMutationAdapter(
      MutationAdapter<Delete> deleteAdapter,
      MutationAdapter<Put> putAdapter,
      MutationAdapter<Increment> incrementAdapter,
      MutationAdapter<Append> appendAdapter); }
HBaseMutationAdapter extends MutationAdapter<Mutation> { @Override public void adapt( Mutation mutation, com.google.cloud.bigtable.data.v2.models.MutationApi<?> mutationModel) { MutationAdapter<Mutation> adapter = adapterMap.get(mutation.getClass()); if (adapter == null) { throw new UnsupportedOperationException( String.format( "Cannot adapt mutation of type %s.", mutation.getClass().getCanonicalName())); } adapter.adapt(mutation, mutationModel); } HBaseMutationAdapter(
      MutationAdapter<Delete> deleteAdapter,
      MutationAdapter<Put> putAdapter,
      MutationAdapter<Increment> incrementAdapter,
      MutationAdapter<Append> appendAdapter); @Override void adapt(
      Mutation mutation, com.google.cloud.bigtable.data.v2.models.MutationApi<?> mutationModel); }
HBaseMutationAdapter extends MutationAdapter<Mutation> { @Override public void adapt( Mutation mutation, com.google.cloud.bigtable.data.v2.models.MutationApi<?> mutationModel) { MutationAdapter<Mutation> adapter = adapterMap.get(mutation.getClass()); if (adapter == null) { throw new UnsupportedOperationException( String.format( "Cannot adapt mutation of type %s.", mutation.getClass().getCanonicalName())); } adapter.adapt(mutation, mutationModel); } HBaseMutationAdapter(
      MutationAdapter<Delete> deleteAdapter,
      MutationAdapter<Put> putAdapter,
      MutationAdapter<Increment> incrementAdapter,
      MutationAdapter<Append> appendAdapter); @Override void adapt(
      Mutation mutation, com.google.cloud.bigtable.data.v2.models.MutationApi<?> mutationModel);  }