Java源码示例：org.apache.flink.runtime.util.ManualTicker
示例1
@Before
public void setUp() {
manualTicker = new ManualTicker();
completedOperationCache = new CompletedOperationCache<>(manualTicker);
}
示例2
@Before
public void setUp() {
manualTicker = new ManualTicker();
completedOperationCache = new CompletedOperationCache<>(manualTicker);
}
示例3
/**
* Tests that an expired execution graph is removed from the execution graph store.
*/
@Test
public void testExecutionGraphExpiration() throws Exception {
final File rootDir = temporaryFolder.newFolder();
final Time expirationTime = Time.milliseconds(1L);
final ManuallyTriggeredScheduledExecutor scheduledExecutor = new ManuallyTriggeredScheduledExecutor();
final ManualTicker manualTicker = new ManualTicker();
try (final FileArchivedExecutionGraphStore executionGraphStore = new FileArchivedExecutionGraphStore(
rootDir,
expirationTime,
Integer.MAX_VALUE,
10000L,
scheduledExecutor,
manualTicker)) {
final ArchivedExecutionGraph executionGraph = new ArchivedExecutionGraphBuilder().setState(JobStatus.FINISHED).build();
executionGraphStore.put(executionGraph);
// there should one execution graph
assertThat(executionGraphStore.size(), Matchers.equalTo(1));
manualTicker.advanceTime(expirationTime.toMilliseconds(), TimeUnit.MILLISECONDS);
// this should trigger the cleanup after expiration
scheduledExecutor.triggerScheduledTasks();
assertThat(executionGraphStore.size(), Matchers.equalTo(0));
assertThat(executionGraphStore.get(executionGraph.getJobID()), Matchers.nullValue());
final File storageDirectory = executionGraphStore.getStorageDir();
// check that the persisted file has been deleted
assertThat(storageDirectory.listFiles().length, Matchers.equalTo(0));
}
}
示例4
@Before
public void setUp() {
manualTicker = new ManualTicker();
completedOperationCache = new CompletedOperationCache<>(manualTicker);
}
示例5
/**
* Tests that an expired execution graph is removed from the execution graph store.
*/
@Test
public void testExecutionGraphExpiration() throws Exception {
final File rootDir = temporaryFolder.newFolder();
final Time expirationTime = Time.milliseconds(1L);
final ManuallyTriggeredScheduledExecutor scheduledExecutor = new ManuallyTriggeredScheduledExecutor();
final ManualTicker manualTicker = new ManualTicker();
try (final FileArchivedExecutionGraphStore executionGraphStore = new FileArchivedExecutionGraphStore(
rootDir,
expirationTime,
10000L,
scheduledExecutor,
manualTicker)) {
final ArchivedExecutionGraph executionGraph = new ArchivedExecutionGraphBuilder().setState(JobStatus.FINISHED).build();
executionGraphStore.put(executionGraph);
// there should one execution graph
assertThat(executionGraphStore.size(), Matchers.equalTo(1));
manualTicker.advanceTime(expirationTime.toMilliseconds(), TimeUnit.MILLISECONDS);
// this should trigger the cleanup after expiration
scheduledExecutor.triggerScheduledTasks();
assertThat(executionGraphStore.size(), Matchers.equalTo(0));
assertThat(executionGraphStore.get(executionGraph.getJobID()), Matchers.nullValue());
final File storageDirectory = executionGraphStore.getStorageDir();
// check that the persisted file has been deleted
assertThat(storageDirectory.listFiles().length, Matchers.equalTo(0));
}
}
示例6
/**
* Tests that an expired execution graph is removed from the execution graph store.
*/
@Test
public void testExecutionGraphExpiration() throws Exception {
final File rootDir = temporaryFolder.newFolder();
final Time expirationTime = Time.milliseconds(1L);
final ManuallyTriggeredScheduledExecutor scheduledExecutor = new ManuallyTriggeredScheduledExecutor();
final ManualTicker manualTicker = new ManualTicker();
try (final FileArchivedExecutionGraphStore executionGraphStore = new FileArchivedExecutionGraphStore(
rootDir,
expirationTime,
10000L,
scheduledExecutor,
manualTicker)) {
final ArchivedExecutionGraph executionGraph = new ArchivedExecutionGraphBuilder().setState(JobStatus.FINISHED).build();
executionGraphStore.put(executionGraph);
// there should one execution graph
assertThat(executionGraphStore.size(), Matchers.equalTo(1));
manualTicker.advanceTime(expirationTime.toMilliseconds(), TimeUnit.MILLISECONDS);
// this should trigger the cleanup after expiration
scheduledExecutor.triggerScheduledTasks();
assertThat(executionGraphStore.size(), Matchers.equalTo(0));
assertThat(executionGraphStore.get(executionGraph.getJobID()), Matchers.nullValue());
final File storageDirectory = executionGraphStore.getStorageDir();
// check that the persisted file has been deleted
assertThat(storageDirectory.listFiles().length, Matchers.equalTo(0));
}
}
