Uses of Annotation Interface
com.hazelcast.jet.annotation.EvolvingApi
Packages that use EvolvingApi
Package
Description
Jet's configuration data objects.
This package contains various mock sources to help with pipeline testing
and development.
Packages with annotations of type EvolvingApi
Package
Description
Contributes
gRPC service factories that can be to apply transformations to
a pipeline which for each input item calls to a gRPC service.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.config
Methods in com.hazelcast.jet.config with annotations of type EvolvingApiModifier and TypeMethodDescription<T,S extends StreamSerializer<T>>
JobConfigJobConfig.registerSerializer(Class<T> clazz, Class<S> serializerClass) Registers the given serializer for the given class for the scope of the job. -
Uses of EvolvingApi in com.hazelcast.jet.pipeline.test
Classes in com.hazelcast.jet.pipeline.test with annotations of type EvolvingApiModifier and TypeClassDescriptionfinal classAn exception which indicates that an assertion passed successfully.final classContains 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 EvolvingApiModifier and TypeMethodDescriptionstatic StreamSource<SimpleEvent>TestSources.itemStream(int itemsPerSecond) Returns a streaming source that generates events of typeSimpleEventat the specified rate.static <T> StreamSource<T>TestSources.itemStream(int itemsPerSecond, GeneratorFunction<? extends T> generatorFn) Returns a streaming source that generates events created by thegeneratorFnat the specified rate.