Package com.hazelcast.jet.pipeline

Interface IMapExtension<T,K>

Type Parameters:

T - type of the input item

K - type of the key

All Superinterfaces:

com.hazelcast.jet.pipeline.BatchStage.StageExtension<T,IMapExtension.IMapBatchStage<T>>, com.hazelcast.jet.pipeline.BatchStageWithKey.StageExtension<T,K,IMapExtension.IMapBatchStageWithKey<T,K>>, com.hazelcast.jet.pipeline.StreamStage.StageExtension<T,IMapExtension.IMapStreamStage<T>>, com.hazelcast.jet.pipeline.StreamStageWithKey.StageExtension<T,K,IMapExtension.IMapStreamStageWithKey<T,K>>

public interface IMapExtension<T,K>
extends com.hazelcast.jet.pipeline.StreamStage.StageExtension<T,IMapExtension.IMapStreamStage<T>>, com.hazelcast.jet.pipeline.StreamStageWithKey.StageExtension<T,K,IMapExtension.IMapStreamStageWithKey<T,K>>, com.hazelcast.jet.pipeline.BatchStage.StageExtension<T,IMapExtension.IMapBatchStage<T>>, com.hazelcast.jet.pipeline.BatchStageWithKey.StageExtension<T,K,IMapExtension.IMapBatchStageWithKey<T,K>>

Extends Pipeline stage with convenient methods utilising IMap in addition to GeneralStage.mapUsingIMap(java.lang.String, com.hazelcast.function.FunctionEx<? super T, ? extends K>, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.

Since:

5.7

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	IMapExtension.IMapBatchStage<T>	Extends Pipeline stage with convenient methods utilising IMap in addition to BatchStage.mapUsingIMap(java.lang.String, com.hazelcast.function.FunctionEx<? super T, ? extends K>, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.
static interface	IMapExtension.IMapBatchStageWithKey<T,K>	Extends Pipeline stage with convenient methods utilising IMap in addition to BatchStageWithKey.mapUsingIMap(java.lang.String, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.
static interface	IMapExtension.IMapGeneralStage<T>	Extends Pipeline stage with convenient methods utilising IMap in addition to GeneralStage.mapUsingIMap(java.lang.String, com.hazelcast.function.FunctionEx<? super T, ? extends K>, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.
static interface	IMapExtension.IMapGeneralStageWithKey<T,K>	Extends Pipeline stage with convenient methods utilising IMap in addition to GeneralStageWithKey.mapUsingIMap(java.lang.String, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.
static interface	IMapExtension.IMapStreamStage<T>	Extends Pipeline stage with convenient methods utilising IMap in addition to StreamStage.mapUsingIMap(java.lang.String, com.hazelcast.function.FunctionEx<? super T, ? extends K>, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.
static interface	IMapExtension.IMapStreamStageWithKey<T,K>	Extends Pipeline stage with convenient methods utilising IMap in addition to StreamStageWithKey.mapUsingIMap(java.lang.String, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.

Method Summary

Static Methods

Modifier and Type	Method	Description
static <T, K> IMapExtension<T,K>	iMapExtension()	Extends Pipeline stage with convenient methods utilising IMap in addition to GeneralStage.mapUsingIMap(java.lang.String, com.hazelcast.function.FunctionEx<? super T, ? extends K>, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.

Methods inherited from interface com.hazelcast.jet.pipeline.BatchStage.StageExtension

extend

Methods inherited from interface com.hazelcast.jet.pipeline.BatchStageWithKey.StageExtension

extend

Methods inherited from interface com.hazelcast.jet.pipeline.StreamStage.StageExtension

extend

Methods inherited from interface com.hazelcast.jet.pipeline.StreamStageWithKey.StageExtension

extend

Method Details

iMapExtension

@Nonnull
static <T,
K> IMapExtension<T,K> iMapExtension()

Extends Pipeline stage with convenient methods utilising IMap in addition to GeneralStage.mapUsingIMap(java.lang.String, com.hazelcast.function.FunctionEx<? super T, ? extends K>, com.hazelcast.function.BiFunctionEx<? super T, ? super V, ? extends R>) available in basic stages.

Example use:

 import static com.hazelcast.jet.pipeline.IMapExtension.iMapExtension;

 srcStage.using(iMapExtension())
         // additional methods available here
         .mapUsingPutIfAbsent("my-map", e -> e % 10, e -> e + 5, Tuple3::tuple3)
         // back to regular stage API
         .writeTo(Sinks.logger());
 

Type Parameters:

T - type of the input item

K - type of the key

Returns:

extension implementation

Since:

5.7