FileSystemCheckpointManagerConfig extends MapConfig { public Optional<String> getFileSystemCheckpointRoot() { return Optional.ofNullable(get(CHECKPOINT_MANAGER_ROOT)); } FileSystemCheckpointManagerConfig(Config config); Optional<String> getFileSystemCheckpointRoot();  }
@Test public void testGetFileSystemCheckpointRoot() { String checkpointManagerRoot = "checkpointManagerRoot"; Config config = new MapConfig(ImmutableMap.of("task.checkpoint.path", checkpointManagerRoot)); FileSystemCheckpointManagerConfig fileSystemCheckpointManagerConfig = new FileSystemCheckpointManagerConfig(config); assertEquals(checkpointManagerRoot, fileSystemCheckpointManagerConfig.getFileSystemCheckpointRoot().get()); config = new MapConfig(); fileSystemCheckpointManagerConfig = new FileSystemCheckpointManagerConfig(config); assertFalse(fileSystemCheckpointManagerConfig.getFileSystemCheckpointRoot().isPresent()); }