| Package | Description | 
|---|---|
| com.hazelcast.jet.core | Jet's Core API. | 
| com.hazelcast.jet.core.test | Utilities for writing tests of Core API Processors. | 
| com.hazelcast.jet.pipeline | The Pipeline API is Jet's high-level API to build and execute
 distributed computation jobs. | 
| Modifier and Type | Interface and Description | 
|---|---|
| static interface  | Processor.ContextContext passed to the processor in the
  init()call. | 
| Modifier and Type | Method and Description | 
|---|---|
| default void | ProcessorSupplier. init(ProcessorSupplier.Context context)Called on each cluster member after deserialization. | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | TestProcessorContextProcessor.Contextimplementation suitable to be used in tests. | 
| class  | TestProcessorSupplierContextImplementation of  ProcessorSupplier.Contextsuitable to be used
 in tests. | 
| Modifier and Type | Method and Description | 
|---|---|
| static Supplier<Processor> | TestSupport. supplierFrom(ProcessorMetaSupplier supplier,
            ProcessorSupplier.Context context)Wraps the provided  ProcessorMetaSupplierwith aSupplier<Processor>that returns processors obtained from it. | 
| static Supplier<Processor> | TestSupport. supplierFrom(ProcessorSupplier supplier,
            ProcessorSupplier.Context context)Wraps the provided  ProcessorSupplierwith aSupplier<Processor>that returns processors obtained from it. | 
| Modifier and Type | Method and Description | 
|---|---|
| FunctionEx<? super ProcessorSupplier.Context,? extends C> | ServiceFactory. createContextFn()Returns the function that creates the shared context object. | 
| Modifier and Type | Method and Description | 
|---|---|
| static <S> ServiceFactory<?,S> | ServiceFactories. sharedService(FunctionEx<? super ProcessorSupplier.Context,S> createServiceFn)A variant of  sharedService(createFn, destroyFn)with a no-opdestroyFn. | 
| static <S> ServiceFactory<?,S> | ServiceFactories. sharedService(FunctionEx<? super ProcessorSupplier.Context,S> createServiceFn,
             ConsumerEx<S> destroyServiceFn)Returns a  ServiceFactorywhich will provide a single shared
 service object per cluster member. | 
| static <C> ServiceFactory<C,Void> | ServiceFactory. withCreateContextFn(FunctionEx<? super ProcessorSupplier.Context,? extends C> createContextFn)Creates a new  ServiceFactorywith the given function that
 creates the shared context object. | 
Copyright © 2022 Hazelcast, Inc.. All rights reserved.