com.hazelcast.jet.core.test

Class TestProcessorContext

java.lang.Object

com.hazelcast.jet.core.test.TestProcessorContext

All Implemented Interfaces:

Processor.Context

public class TestProcessorContext
extends Object
implements Processor.Context

Simple implementation of Processor.Context.

Constructor Summary

Constructors

Constructor and Description
TestProcessorContext() Constructor with default values.

Method Summary

Modifier and Type	Method and Description
int	globalProcessorIndex() Returns the index of the processor among all the processors created for this vertex on all nodes: its unique cluster-wide index.
JetInstance	jetInstance() Returns the current Jet instance
com.hazelcast.logging.ILogger	logger() Return a logger for the processor
ProcessingGuarantee	processingGuarantee() Returns the guarantee for current job.
TestProcessorContext	setGlobalProcessorIndex(int globalProcessorIndex) Set the global processor index
TestProcessorContext	setJetInstance(JetInstance jetInstance) Set the jet instance.
TestProcessorContext	setLogger(com.hazelcast.logging.ILogger logger) Set the logger.
TestProcessorContext	setProcessingGuarantee(ProcessingGuarantee processingGuarantee) Sets the processing guarantee.
TestProcessorContext	setVertexName(String vertexName) Set the vertex name.
String	vertexName() Returns the name of the vertex associated with this processor.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.jet.core.Processor.Context

snapshottingEnabled

Constructor Detail

TestProcessorContext

public TestProcessorContext()

Constructor with default values.

Method Detail

jetInstance

@Nonnull
public JetInstance jetInstance()

Description copied from interface: Processor.Context

Returns the current Jet instance

Specified by:

jetInstance in interface Processor.Context

setJetInstance

public TestProcessorContext setJetInstance(JetInstance jetInstance)

Set the jet instance.

logger

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

Description copied from interface: Processor.Context

Return a logger for the processor

Specified by:

logger in interface Processor.Context

setLogger

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

Set the logger.

vertexName

@Nonnull
public String vertexName()

Description copied from interface: Processor.Context

Returns the name of the vertex associated with this processor.

Specified by:

vertexName in interface Processor.Context

setVertexName

public TestProcessorContext setVertexName(@Nonnull
                                          String vertexName)

Set the vertex name.

globalProcessorIndex

public int globalProcessorIndex()

Description copied from interface: Processor.Context

Returns the index of the processor among all the processors created for this vertex on all nodes: its unique cluster-wide index.

Specified by:

globalProcessorIndex in interface Processor.Context

setGlobalProcessorIndex

public TestProcessorContext setGlobalProcessorIndex(int globalProcessorIndex)

Set the global processor index

processingGuarantee

public ProcessingGuarantee processingGuarantee()

Description copied from interface: Processor.Context

Returns the guarantee for current job.

Specified by:

processingGuarantee in interface Processor.Context

setProcessingGuarantee

public TestProcessorContext setProcessingGuarantee(ProcessingGuarantee processingGuarantee)

Sets the processing guarantee.