com.hazelcast.jet.core.test

Class TestProcessorSupplierContext

java.lang.Object

com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

com.hazelcast.jet.core.test.TestProcessorSupplierContext

All Implemented Interfaces:

ProcessorMetaSupplier.Context, ProcessorSupplier.Context

Direct Known Subclasses:

TestProcessorContext

public class TestProcessorSupplierContext
extends TestProcessorMetaSupplierContext
implements ProcessorSupplier.Context

ProcessorSupplier.Context implementation suitable to be used in tests.

Field Summary

Fields inherited from class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

logger

Constructor Summary

Constructors

Constructor and Description
TestProcessorSupplierContext()

Method Summary

Modifier and Type	Method and Description
protected String	loggerName()
TestProcessorSupplierContext	setJetInstance(JetInstance jetInstance) Set the jet instance.
TestProcessorSupplierContext	setLocalParallelism(int localParallelism) Set local parallelism.
TestProcessorSupplierContext	setLogger(ILogger logger) Set the logger.
TestProcessorSupplierContext	setTotalParallelism(int totalParallelism) Set total parallelism.
TestProcessorSupplierContext	setVertexName(String vertexName) Set the vertex name.

Methods inherited from class com.hazelcast.jet.core.test.TestProcessorMetaSupplierContext

jetInstance, localParallelism, logger, totalParallelism, vertexName

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.ProcessorSupplier.Context

logger

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

jetInstance, localParallelism, totalParallelism, vertexName

Constructor Detail

TestProcessorSupplierContext

public TestProcessorSupplierContext()

Method Detail

setLogger

@Nonnull
public TestProcessorSupplierContext setLogger(@Nonnull
                                                       ILogger logger)

Description copied from class: TestProcessorMetaSupplierContext

Set the logger.

Overrides:

setLogger in class TestProcessorMetaSupplierContext

setJetInstance

@Nonnull
public TestProcessorSupplierContext setJetInstance(@Nonnull
                                                            JetInstance jetInstance)

Description copied from class: TestProcessorMetaSupplierContext

Set the jet instance.

Overrides:

setJetInstance in class TestProcessorMetaSupplierContext

setVertexName

@Nonnull
public TestProcessorSupplierContext setVertexName(@Nonnull
                                                           String vertexName)

Description copied from class: TestProcessorMetaSupplierContext

Set the vertex name.

Overrides:

setVertexName in class TestProcessorMetaSupplierContext

setTotalParallelism

@Nonnull
public TestProcessorSupplierContext setTotalParallelism(int totalParallelism)

Description copied from class: TestProcessorMetaSupplierContext

Set total parallelism.

Overrides:

setTotalParallelism in class TestProcessorMetaSupplierContext

setLocalParallelism

@Nonnull
public TestProcessorSupplierContext setLocalParallelism(int localParallelism)

Description copied from class: TestProcessorMetaSupplierContext

Set local parallelism.

Overrides:

setLocalParallelism in class TestProcessorMetaSupplierContext

loggerName

protected String loggerName()

Overrides:

loggerName in class TestProcessorMetaSupplierContext