@Test public void testCurrentProcessingTime() throws Exception { @SuppressWarnings("unchecked") Triggerable<Integer, String> mockTriggerable = mock(Triggerable.class); TestKeyContext keyContext = new TestKeyContext(); TestProcessingTimeService processingTimeService = new TestProcessingTimeService(); InternalTimerServiceImpl<Integer, String> timerService = createAndStartInternalTimerService(mockTriggerable, keyContext, processingTimeService, testKeyGroupRange, createQueueFactory()); processingTimeService.setCurrentTime(17L); assertEquals(17, timerService.currentProcessingTime()); processingTimeService.setCurrentTime(42); assertEquals(42, timerService.currentProcessingTime()); }
@Override public long currentProcessingTime() { return processingTimeService.getCurrentProcessingTime(); }
InternalTimerServiceImpl implements InternalTimerService<N>, ProcessingTimeCallback { @Override public long currentProcessingTime() { return processingTimeService.getCurrentProcessingTime(); } }
InternalTimerServiceImpl implements InternalTimerService<N>, ProcessingTimeCallback { @Override public long currentProcessingTime() { return processingTimeService.getCurrentProcessingTime(); } InternalTimerServiceImpl(
		KeyGroupRange localKeyGroupRange,
		KeyContext keyContext,
		ProcessingTimeService processingTimeService,
		KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K, N>> processingTimeTimersQueue,
		KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K, N>> eventTimeTimersQueue); }
InternalTimerServiceImpl implements InternalTimerService<N>, ProcessingTimeCallback { @Override public long currentProcessingTime() { return processingTimeService.getCurrentProcessingTime(); } InternalTimerServiceImpl(
		KeyGroupRange localKeyGroupRange,
		KeyContext keyContext,
		ProcessingTimeService processingTimeService,
		KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K, N>> processingTimeTimersQueue,
		KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K, N>> eventTimeTimersQueue); void startTimerService(
			TypeSerializer<K> keySerializer,
			TypeSerializer<N> namespaceSerializer,
			Triggerable<K, N> triggerTarget); @Override long currentProcessingTime(); @Override long currentWatermark(); @Override void registerProcessingTimeTimer(N namespace, long time); @Override void registerEventTimeTimer(N namespace, long time); @Override void deleteProcessingTimeTimer(N namespace, long time); @Override void deleteEventTimeTimer(N namespace, long time); @Override void onProcessingTime(long time); void advanceWatermark(long time); InternalTimersSnapshot<K, N> snapshotTimersForKeyGroup(int keyGroupIdx); TypeSerializer<K> getKeySerializer(); TypeSerializer<N> getNamespaceSerializer(); @SuppressWarnings("unchecked") void restoreTimersForKeyGroup(InternalTimersSnapshot<?, ?> restoredSnapshot, int keyGroupIdx); @VisibleForTesting int numProcessingTimeTimers(); @VisibleForTesting int numEventTimeTimers(); @VisibleForTesting int numProcessingTimeTimers(N namespace); @VisibleForTesting int numEventTimeTimers(N namespace); }
InternalTimerServiceImpl implements InternalTimerService<N>, ProcessingTimeCallback { @Override public long currentProcessingTime() { return processingTimeService.getCurrentProcessingTime(); } InternalTimerServiceImpl(
		KeyGroupRange localKeyGroupRange,
		KeyContext keyContext,
		ProcessingTimeService processingTimeService,
		KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K, N>> processingTimeTimersQueue,
		KeyGroupedInternalPriorityQueue<TimerHeapInternalTimer<K, N>> eventTimeTimersQueue); void startTimerService(
			TypeSerializer<K> keySerializer,
			TypeSerializer<N> namespaceSerializer,
			Triggerable<K, N> triggerTarget); @Override long currentProcessingTime(); @Override long currentWatermark(); @Override void registerProcessingTimeTimer(N namespace, long time); @Override void registerEventTimeTimer(N namespace, long time); @Override void deleteProcessingTimeTimer(N namespace, long time); @Override void deleteEventTimeTimer(N namespace, long time); @Override void onProcessingTime(long time); void advanceWatermark(long time); InternalTimersSnapshot<K, N> snapshotTimersForKeyGroup(int keyGroupIdx); TypeSerializer<K> getKeySerializer(); TypeSerializer<N> getNamespaceSerializer(); @SuppressWarnings("unchecked") void restoreTimersForKeyGroup(InternalTimersSnapshot<?, ?> restoredSnapshot, int keyGroupIdx); @VisibleForTesting int numProcessingTimeTimers(); @VisibleForTesting int numEventTimeTimers(); @VisibleForTesting int numProcessingTimeTimers(N namespace); @VisibleForTesting int numEventTimeTimers(N namespace);  }