com.hazelcast.jet

Class AbstractProcessor.FlatMapper<T,R>

java.lang.Object

com.hazelcast.jet.AbstractProcessor.FlatMapper<T,R>

Type Parameters:

T - type of the input item

R - type of the emitted item

Enclosing class:

AbstractProcessor

protected final class AbstractProcessor.FlatMapper<T,R>
extends Object

A helper that simplifies the implementation of tryProcess() 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.emitCooperatively(int, Traverser). Example:

 public static class SplitWordsP extends AbstractProcessor {

     private FlatMapper<String, String> flatMapper =
             flatMapper((String 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 Type	Method and Description
boolean	tryProcess(T item) Method designed to be called from one of AbstractProcessor#tryProcessX() methods.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

tryProcess

public boolean tryProcess(@Nonnull
                          T item)

Method designed to be called from one of AbstractProcessor#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