@Test public void syncInitKvsSynchronous() { KeyValueService kvs = createRawKeyValueService(false); assertThat(kvs.isInitialized()).isTrue(); assertThat(kvs.getAllTableNames()).isEmpty(); }
@Override public InMemoryKeyValueService createRawKeyValueService( MetricsManager metricsManager, KeyValueServiceConfig config, Supplier<Optional<KeyValueServiceRuntimeConfig>> runtimeConfig, Optional<LeaderConfig> leaderConfig, Optional<String> unused, LongSupplier unusedLongSupplier, boolean initializeAsync) { if (initializeAsync) { log.warn("Asynchronous initialization not implemented, will initialize synchronously."); } AtlasDbVersion.ensureVersionReported(); return new InMemoryKeyValueService(false); }
InMemoryAtlasDbFactory implements AtlasDbFactory { @Override public InMemoryKeyValueService createRawKeyValueService( MetricsManager metricsManager, KeyValueServiceConfig config, Supplier<Optional<KeyValueServiceRuntimeConfig>> runtimeConfig, Optional<LeaderConfig> leaderConfig, Optional<String> unused, LongSupplier unusedLongSupplier, boolean initializeAsync) { if (initializeAsync) { log.warn("Asynchronous initialization not implemented, will initialize synchronously."); } AtlasDbVersion.ensureVersionReported(); return new InMemoryKeyValueService(false); } }
InMemoryAtlasDbFactory implements AtlasDbFactory { @Override public InMemoryKeyValueService createRawKeyValueService( MetricsManager metricsManager, KeyValueServiceConfig config, Supplier<Optional<KeyValueServiceRuntimeConfig>> runtimeConfig, Optional<LeaderConfig> leaderConfig, Optional<String> unused, LongSupplier unusedLongSupplier, boolean initializeAsync) { if (initializeAsync) { log.warn("Asynchronous initialization not implemented, will initialize synchronously."); } AtlasDbVersion.ensureVersionReported(); return new InMemoryKeyValueService(false); }  }
InMemoryAtlasDbFactory implements AtlasDbFactory { @Override public InMemoryKeyValueService createRawKeyValueService( MetricsManager metricsManager, KeyValueServiceConfig config, Supplier<Optional<KeyValueServiceRuntimeConfig>> runtimeConfig, Optional<LeaderConfig> leaderConfig, Optional<String> unused, LongSupplier unusedLongSupplier, boolean initializeAsync) { if (initializeAsync) { log.warn("Asynchronous initialization not implemented, will initialize synchronously."); } AtlasDbVersion.ensureVersionReported(); return new InMemoryKeyValueService(false); }  @Override String getType(); @Override InMemoryKeyValueService createRawKeyValueService(
            MetricsManager metricsManager,
            KeyValueServiceConfig config,
            Supplier<Optional<KeyValueServiceRuntimeConfig>> runtimeConfig,
            Optional<LeaderConfig> leaderConfig,
            Optional<String> unused,
            LongSupplier unusedLongSupplier,
            boolean initializeAsync); @Override ManagedTimestampService createManagedTimestampService(
            KeyValueService rawKvs,
            Optional<TableReference> unused,
            boolean initializeAsync); }
InMemoryAtlasDbFactory implements AtlasDbFactory { @Override public InMemoryKeyValueService createRawKeyValueService( MetricsManager metricsManager, KeyValueServiceConfig config, Supplier<Optional<KeyValueServiceRuntimeConfig>> runtimeConfig, Optional<LeaderConfig> leaderConfig, Optional<String> unused, LongSupplier unusedLongSupplier, boolean initializeAsync) { if (initializeAsync) { log.warn("Asynchronous initialization not implemented, will initialize synchronously."); } AtlasDbVersion.ensureVersionReported(); return new InMemoryKeyValueService(false); }  @Override String getType(); @Override InMemoryKeyValueService createRawKeyValueService(
            MetricsManager metricsManager,
            KeyValueServiceConfig config,
            Supplier<Optional<KeyValueServiceRuntimeConfig>> runtimeConfig,
            Optional<LeaderConfig> leaderConfig,
            Optional<String> unused,
            LongSupplier unusedLongSupplier,
            boolean initializeAsync); @Override ManagedTimestampService createManagedTimestampService(
            KeyValueService rawKvs,
            Optional<TableReference> unused,
            boolean initializeAsync);  }