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>
    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.
    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.
    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.
    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>
    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.