public interface FlatMapFunction extends Serializable
A one to many transformation function
Modifier and Type | Method and Description |
---|---|
Iterable<Values> |
execute(TridentTuple input)
Invoked by the framework for each trident tuple in a stream.
|
Iterable<Values> execute(TridentTuple input)
Invoked by the framework for each trident tuple in a stream.
input
- the input trident tupleCopyright © 2019 The Apache Software Foundation. All Rights Reserved.