K- The type of key the state is associated to
N- The type of the namespace
T- The type of elements in the aggregated by the ReduceFunction
public interface InternalReducingState<K,N,T> extends InternalMergingState<K,N,T,T,T>, ReducingState<T>
getKeySerializer, getNamespaceSerializer, getSerializedValue, getValueSerializer, setCurrentNamespace
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.