Package com.hazelcast.usercode.jet

Class UserCodeTransforms

java.lang.Object
com.hazelcast.usercode.jet.UserCodeTransforms
@Beta public final class UserCodeTransforms extends Object
Transforms which allow the user to call the user-defined function in one of the supported runtimes from inside a Jet pipeline.
Since:
5.4

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final String
    DEFAULT_RESOURCE_FILE_NAME
    The name of the resource zip file that contains the user code.

  • Method Summary

    Modifier and Type
    Method
    Description
    static <T, R> com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.StreamStage<? extends T>,com.hazelcast.jet.pipeline.StreamStage<R>>
    mapUsingUserCode(UserCodeConfig config)
    A stage transforming method that allows the user-defined function to add to the pipeline stage.
    static <T, R> com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.StreamStage<? extends T>,com.hazelcast.jet.pipeline.StreamStage<R>>
    mapUsingUserCode(UserCodeConfig config, boolean preserveOrder, int maxConcurrentOps)
    A stage transforming method that allows the user-defined function to add to the pipeline stage.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • DEFAULT_RESOURCE_FILE_NAME

      public static final String DEFAULT_RESOURCE_FILE_NAME
      The name of the resource zip file that contains the user code.
      See Also:

  • Method Details

    • mapUsingUserCode

      @Nonnull public static <T, R> com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.StreamStage<? extends T>,com.hazelcast.jet.pipeline.StreamStage<R>> mapUsingUserCode(UserCodeConfig config)
      A stage transforming method that allows the user-defined function to add to the pipeline stage.

      The user-defined function should be deployed in a container which is based on one of the Hazelcast user code runtime base images. And, provide the name of the image and credentials (if any).

      Type Parameters:
      T - -> Type of the upstream stage.
      R - -> Type of the downstream stage.
      Since:
      5.4

    • mapUsingUserCode

      @Nonnull public static <T, R> com.hazelcast.function.FunctionEx<com.hazelcast.jet.pipeline.StreamStage<? extends T>,com.hazelcast.jet.pipeline.StreamStage<R>> mapUsingUserCode(UserCodeConfig config, boolean preserveOrder, int maxConcurrentOps)
      A stage transforming method that allows the user-defined function to add to the pipeline stage.

      The user-defined function should be deployed in a container which is based on one of the Hazelcast user code runtime base images. And, provide the name of the image and credentials (if any).

      Type Parameters:
      T - -> Type of the upstream stage.
      R - -> Type of the downstream stage.
      Parameters:
      preserveOrder - -> whether the ordering of the input items should be preserved
      maxConcurrentOps - -> maximum number of concurrent async operations per processor
      Since:
      5.4