public class FlatMapFunctionExecutor extends BaseOperation implements Function
Constructor and Description |
---|
FlatMapFunctionExecutor(FlatMapFunction function) |
Modifier and Type | Method and Description |
---|---|
void |
execute(TridentTuple tuple,
TridentCollector collector)
Performs the function logic on an individual tuple and emits 0 or more tuples.
|
cleanup, prepare
public FlatMapFunctionExecutor(FlatMapFunction function)
public void execute(TridentTuple tuple, TridentCollector collector)
Function
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.