@Test public void testVerifyRetrySettings() throws IOException { configuration.set(BIGTABLE_USE_TIMEOUTS_KEY, "true"); BigtableDataSettings dataSettings = ((BigtableHBaseVeneerSettings) BigtableHBaseVeneerSettings.create(configuration)) .getDataSettings(); BigtableDataSettings defaultDataSettings = BigtableDataSettings.newBuilder() .setProjectId("project-id") .setInstanceId("instance-id") .build(); assertEquals( defaultDataSettings.getStubSettings().readRowsSettings().getRetryableCodes(), dataSettings.getStubSettings().readRowsSettings().getRetryableCodes()); assertRetriableOperation( defaultDataSettings.getStubSettings().readRowSettings(), dataSettings.getStubSettings().readRowSettings()); assertRetriableOperation( defaultDataSettings.getStubSettings().mutateRowSettings(), dataSettings.getStubSettings().mutateRowSettings()); assertRetriableOperation( defaultDataSettings.getStubSettings().sampleRowKeysSettings(), dataSettings.getStubSettings().sampleRowKeysSettings()); assertNonRetriableOperation( defaultDataSettings.getStubSettings().readModifyWriteRowSettings(), dataSettings.getStubSettings().readModifyWriteRowSettings()); assertNonRetriableOperation( defaultDataSettings.getStubSettings().checkAndMutateRowSettings(), dataSettings.getStubSettings().checkAndMutateRowSettings()); }
public BigtableDataSettings getDataSettings() { return dataSettings; }
BigtableHBaseVeneerSettings extends BigtableHBaseSettings { public BigtableDataSettings getDataSettings() { return dataSettings; } }
BigtableHBaseVeneerSettings extends BigtableHBaseSettings { public BigtableDataSettings getDataSettings() { return dataSettings; } BigtableHBaseVeneerSettings(Configuration configuration); }
BigtableHBaseVeneerSettings extends BigtableHBaseSettings { public BigtableDataSettings getDataSettings() { return dataSettings; } BigtableHBaseVeneerSettings(Configuration configuration); @Override String getDataHost(); @Override String getAdminHost(); @Override int getPort(); @Override int getBulkMaxRowCount(); @Override long getBatchingMaxRequestSize(); @Override boolean isRetriesWithoutTimestampAllowed(); boolean isChannelPoolCachingEnabled(); BigtableDataSettings getDataSettings(); BigtableTableAdminSettings getTableAdminSettings(); @Nullable BigtableInstanceAdminSettings getInstanceAdminSettings(); }
BigtableHBaseVeneerSettings extends BigtableHBaseSettings { public BigtableDataSettings getDataSettings() { return dataSettings; } BigtableHBaseVeneerSettings(Configuration configuration); @Override String getDataHost(); @Override String getAdminHost(); @Override int getPort(); @Override int getBulkMaxRowCount(); @Override long getBatchingMaxRequestSize(); @Override boolean isRetriesWithoutTimestampAllowed(); boolean isChannelPoolCachingEnabled(); BigtableDataSettings getDataSettings(); BigtableTableAdminSettings getTableAdminSettings(); @Nullable BigtableInstanceAdminSettings getInstanceAdminSettings();  }