com.hazelcast.jet.core.test

Class TestProcessorSupplierContext

java.lang.Object

com.hazelcast.jet.core.test.TestProcessorSupplierContext

All Implemented Interfaces:

ProcessorSupplier.Context

public class TestProcessorSupplierContext
extends Object
implements ProcessorSupplier.Context

Simple implementation of ProcessorSupplier.Context.

Constructor Summary

Constructors

Constructor and Description
TestProcessorSupplierContext()

Method Summary

Modifier and Type	Method and Description
JetInstance	jetInstance() Returns the current Jet instance
int	localParallelism() Returns the number of processors that the associated ProcessorSupplier will be asked to create.
com.hazelcast.logging.ILogger	logger() Returns a logger for the associated ProcessorSupplier.
TestProcessorSupplierContext	setJetInstance(JetInstance jetInstance) Set the jet instance.
TestProcessorSupplierContext	setLocalParallelism(int localParallelism) Set local parallelism.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestProcessorSupplierContext

public TestProcessorSupplierContext()

Method Detail

jetInstance

public JetInstance jetInstance()

Description copied from interface: ProcessorSupplier.Context

Returns the current Jet instance

Specified by:

jetInstance in interface ProcessorSupplier.Context

setJetInstance

public TestProcessorSupplierContext setJetInstance(JetInstance jetInstance)

Set the jet instance.

localParallelism

public int localParallelism()

Description copied from interface: ProcessorSupplier.Context

Returns the number of processors that the associated ProcessorSupplier will be asked to create.

Specified by:

localParallelism in interface ProcessorSupplier.Context

logger

@Nonnull
public com.hazelcast.logging.ILogger logger()

Description copied from interface: ProcessorSupplier.Context

Returns a logger for the associated ProcessorSupplier.

Specified by:

logger in interface ProcessorSupplier.Context

setLocalParallelism

public TestProcessorSupplierContext setLocalParallelism(int localParallelism)

Set local parallelism.