Package com.hazelcast.jet.core
Class AbstractProcessor.FlatMapper<T,R>
java.lang.Object
com.hazelcast.jet.core.AbstractProcessor.FlatMapper<T,R>
- Type Parameters:
T
- type of the input itemR
- type of the emitted item
- Enclosing class:
- AbstractProcessor
A helper that simplifies the implementation of
tryProcess(ordinal, item)
for emitting collections. User
supplies a mapper
which takes an item and returns a traverser
over all output items that should be emitted. The tryProcess(Object)
method obtains and passes the traverser to AbstractProcessor.emitFromTraverser(int, Traverser)
.
Example:
public static class SplitWordsP extends AbstractProcessor {private FlatMapper<String, String> flatMapper = flatMapper(item -> Traverser.over(item.split("\\W")));
@Override
protected boolean tryProcess(int ordinal, Object item) throws Exception { return flatMapper.tryProcess((String) item); } }
-
Method Summary
Modifier and TypeMethodDescriptionboolean
tryProcess
(T item) Method designed to be called from one ofAbstractProcessor#tryProcessX()
methods.
-
Method Details
-
tryProcess
Method designed to be called from one ofAbstractProcessor#tryProcessX()
methods. The calling method must return this method's return value.- Parameters:
item
- the item to process- Returns:
- what the calling
tryProcessX()
method should return
-