org.apache.spark.api.java.function

Interface FlatMapGroupsWithStateFunction<K,V,S,R>

All Superinterfaces:

java.io.Serializable

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

::Experimental:: Base interface for a map function used in org.apache.spark.sql.KeyValueGroupedDataset.flatMapGroupsWithState( FlatMapGroupsWithStateFunction, org.apache.spark.sql.streaming.OutputMode, org.apache.spark.sql.Encoder, org.apache.spark.sql.Encoder)

Since:

2.1.1

Method Summary

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

Method Detail

call

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

Throws:

Exception