Package | Description |
---|---|
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultTimeServiceProvider
A
TimeServiceProvider which assigns as current processing time the result of calling
System.currentTimeMillis() and registers timers using a ScheduledThreadPoolExecutor . |
class |
TestTimeServiceProvider
This is a
TimeServiceProvider used strictly for testing the
processing time functionality. |
Modifier and Type | Method and Description |
---|---|
void |
StreamTask.setTimeService(TimeServiceProvider timeProvider)
Allows the user to specify his own
TimerServiceProvider . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.