Package | Description |
---|---|
org.apache.flink.streaming.api.operators |
Constructor and Description |
---|
InternalTimerServiceSerializationProxy(Map<String,HeapInternalTimerService<K,N>> timerServicesMapToPopulate,
ClassLoader userCodeClassLoader,
int totalKeyGroups,
KeyGroupsList localKeyGroupRange,
KeyContext keyContext,
ProcessingTimeService processingTimeService,
int keyGroupIdx)
Constructor to use when restoring timer services.
|
InternalTimerServiceSerializationProxy(Map<String,HeapInternalTimerService<K,N>> timerServices,
int keyGroupIdx)
Constructor to use when writing timer services.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.