Interface FlatMapGroupsWithStateFunction<K,V,S,R>
- All Superinterfaces:
Serializable
@Experimental
@Evolving
public interface FlatMapGroupsWithStateFunction<K,V,S,R>
extends 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
-
Method Details
-
call
- Throws:
Exception
-