Package com.hazelcast.jet.pipeline

package com.hazelcast.jet.pipeline

Class	Description
EnterpriseSinks	Contains factory methods for enterprise-only pipeline sinks.
IMapExtension<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.
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.
IMapExtension.IMapBatchStageWithKey<T,K>	Deprecated, for removal: This API element is subject to removal in a future version. Use pipeline.rebalance() instead.
IMapExtension.IMapGeneralStage<T,S extends IMapExtension.IMapGeneralStage<T,S>>	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.
IMapExtension.IMapGeneralStageWithKey<T,K,S extends IMapExtension.IMapGeneralStageWithKey<T,K,S>>	Deprecated, for removal: This API element is subject to removal in a future version. Use pipeline.rebalance() instead.
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.
IMapExtension.IMapStreamStageWithKey<T,K>	Deprecated, for removal: This API element is subject to removal in a future version. Use pipeline.rebalance() instead.