public class LatencyTrackingStateFactory<K,N,V,S extends State,IS extends InternalKvState<K,N,?>> extends Object
AbstractLatencyTrackState
.Modifier and Type | Method and Description |
---|---|
static <K,N,V,S extends State> |
createStateAndWrapWithLatencyTrackingIfEnabled(InternalKvState<K,N,?> kvState,
StateDescriptor<S,V> stateDescriptor,
LatencyTrackingStateConfig latencyTrackingStateConfig)
Create latency tracking state if enabled.
|
public static <K,N,V,S extends State> InternalKvState<K,N,?> createStateAndWrapWithLatencyTrackingIfEnabled(InternalKvState<K,N,?> kvState, StateDescriptor<S,V> stateDescriptor, LatencyTrackingStateConfig latencyTrackingStateConfig) throws Exception
Exception
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.