Uses of Class
com.hazelcast.jet.annotation.EvolvingApi
Package | Description |
---|---|
com.hazelcast.jet.pipeline.test |
This package contains various mock sources to help with pipeline testing
and development.
|
com.hazelcast.jet.python |
Contributes a
PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig)
transform that allows you to transform Jet pipeline data using a Python
function. |
Package | Description |
---|---|
com.hazelcast.jet.python |
Contributes a
PythonTransforms.mapUsingPython(com.hazelcast.jet.python.PythonServiceConfig)
transform that allows you to transform Jet pipeline data using a Python
function. |
-
Uses of EvolvingApi in com.hazelcast.jet.pipeline.test
Classes in com.hazelcast.jet.pipeline.test with annotations of type EvolvingApi Modifier and Type Class Description class
AssertionCompletedException
An exception which indicates that an assertion passed successfully.class
TestSources
Contains factory methods for various mock sources which can be used for pipeline testing and development.Methods in com.hazelcast.jet.pipeline.test with annotations of type EvolvingApi Modifier and Type Method Description static StreamSource<SimpleEvent>
TestSources. itemStream(int itemsPerSecond)
Returns a streaming source which generates events of typeSimpleEvent
at the specified rate infinitely.static <T> StreamSource<T>
TestSources. itemStream(int itemsPerSecond, GeneratorFunction<? extends T> generatorFn)
Returns a streaming source which generates events created by thegeneratorFn
at the specified rate infinitely. -
Uses of EvolvingApi in com.hazelcast.jet.python
Classes in com.hazelcast.jet.python with annotations of type EvolvingApi Modifier and Type Class Description class
PythonTransforms
Transforms which allow the user to call Python user-defined functions from inside a Jet pipeline.