@Test public void testRpcMethodWithoutRetry() throws IOException { configuration.set(ENABLE_GRPC_RETRIES_KEY, "false"); BigtableHBaseVeneerSettings settingUtils = ((BigtableHBaseVeneerSettings) BigtableHBaseVeneerSettings.create(configuration)); BigtableDataSettings settings = settingUtils.getDataSettings(); assertTrue(settings.getStubSettings().readRowsSettings().getRetryableCodes().isEmpty()); assertRpcWithoutTimeout(settings.getStubSettings().bulkReadRowsSettings()); assertRpcWithoutTimeout(settings.getStubSettings().bulkMutateRowsSettings()); assertRpcWithoutTimeout(settings.getStubSettings().readRowSettings()); assertRpcWithoutTimeout(settings.getStubSettings().mutateRowSettings()); assertRpcWithoutTimeout(settings.getStubSettings().sampleRowKeysSettings()); }
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();  }