Package org.apache.spark.api.java.function

Interface MapGroupsWithStateFunction<K,V,S,R>

All Superinterfaces:

Serializable

@Experimental
@Evolving
public interface MapGroupsWithStateFunction<K,V,S,R>
extends 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	Description
R	call(K key, Iterator<V> values, GroupState<S> state)

Method Details

call

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

Throws:

Exception