public class ProxyInternalTimeServiceManager<K> extends Object implements org.apache.flink.streaming.api.operators.InternalTimeServiceManager<K>
InternalTimeServiceManager
for the wrapped operators.Constructor and Description |
---|
ProxyInternalTimeServiceManager(org.apache.flink.streaming.api.operators.InternalTimeServiceManager<K> wrappedManager,
StateNamePrefix stateNamePrefix) |
Modifier and Type | Method and Description |
---|---|
void |
advanceWatermark(org.apache.flink.streaming.api.watermark.Watermark watermark) |
<N> org.apache.flink.streaming.api.operators.InternalTimerService<N> |
getInternalTimerService(String name,
org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer,
org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer,
org.apache.flink.streaming.api.operators.Triggerable<K,N> triggerable) |
void |
snapshotToRawKeyedState(org.apache.flink.runtime.state.KeyedStateCheckpointOutputStream stateCheckpointOutputStream,
String operatorName) |
public ProxyInternalTimeServiceManager(org.apache.flink.streaming.api.operators.InternalTimeServiceManager<K> wrappedManager, StateNamePrefix stateNamePrefix)
public <N> org.apache.flink.streaming.api.operators.InternalTimerService<N> getInternalTimerService(String name, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.typeutils.TypeSerializer<N> namespaceSerializer, org.apache.flink.streaming.api.operators.Triggerable<K,N> triggerable)
getInternalTimerService
in interface org.apache.flink.streaming.api.operators.InternalTimeServiceManager<K>
public void advanceWatermark(org.apache.flink.streaming.api.watermark.Watermark watermark) throws Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.