org.apache.spark.api.java.function

Interface MapGroupsWithStateFunction<K,V,S,R>

All Superinterfaces:

java.io.Serializable

@Experimental
 @Evolving
public interface MapGroupsWithStateFunction<K,V,S,R>
extends java.io.Serializable

::Experimental:: Base interface for a map function used in KeyValueGroupedDataset.mapGroupsWithState( MapGroupsWithStateFunction, org.apache.spark.sql.Encoder, org.apache.spark.sql.Encoder)

Since:

2.1.1

Method Summary

Modifier and Type	Method and Description
R	call(K key, java.util.Iterator<V> values, GroupState<S> state)

Method Detail

call

R call(K key,
       java.util.Iterator<V> values,
       GroupState<S> state)
throws Exception

Throws:

Exception