Package com.hazelcast.jet.core
Class ProcessorMetaSupplier.ExpectNothingProcessorSupplier
java.lang.Object
com.hazelcast.jet.core.ProcessorMetaSupplier.ExpectNothingProcessorSupplier
- All Implemented Interfaces:
ProcessorSupplier
,DataSerializable
,IdentifiedDataSerializable
,com.hazelcast.security.impl.function.SecuredFunction
,Serializable
- Enclosing interface:
- ProcessorMetaSupplier
public static class ProcessorMetaSupplier.ExpectNothingProcessorSupplier
extends Object
implements ProcessorSupplier, IdentifiedDataSerializable
- See Also:
-
Nested Class Summary
Nested classes/interfaces inherited from interface com.hazelcast.jet.core.ProcessorSupplier
ProcessorSupplier.Context
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionCollection<? extends Processor>
get
(int count) Called afterProcessorSupplier.init(Context)
to retrieve instances ofProcessor
that will be used during the execution of the Jet job.int
Returns type identifier for this class.int
Returns DataSerializableFactory factory ID for this class.void
Reads fields from the input streamvoid
Writes object fields to output streamMethods 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
close, closeIsCooperative, init, initIsCooperative
Methods inherited from interface com.hazelcast.security.impl.function.SecuredFunction
permissions
-
Constructor Details
-
ExpectNothingProcessorSupplier
public ExpectNothingProcessorSupplier()
-
-
Method Details
-
get
Description copied from interface:ProcessorSupplier
Called afterProcessorSupplier.init(Context)
to retrieve instances ofProcessor
that will be used during the execution of the Jet job.- Specified by:
get
in interfaceProcessorSupplier
- Parameters:
count
- the number of processor this method is required to create and return. It is equal toProcessorMetaSupplier.Context.localParallelism()
.
-
writeData
Description copied from interface:DataSerializable
Writes object fields to output stream- Specified by:
writeData
in interfaceDataSerializable
- Parameters:
out
- output- Throws:
IOException
- if an I/O error occurs. In particular, anIOException
may be thrown if the output stream has been closed.
-
readData
Description copied from interface:DataSerializable
Reads fields from the input stream- Specified by:
readData
in interfaceDataSerializable
- Parameters:
in
- input- Throws:
IOException
- if an I/O error occurs. In particular, anIOException
may be thrown if the input stream has been closed.
-
getFactoryId
public int getFactoryId()Description copied from interface:IdentifiedDataSerializable
Returns DataSerializableFactory factory ID for this class.- Specified by:
getFactoryId
in interfaceIdentifiedDataSerializable
- Returns:
- factory ID
-
getClassId
public int getClassId()Description copied from interface:IdentifiedDataSerializable
Returns type identifier for this class. It should be unique per DataSerializableFactory.- Specified by:
getClassId
in interfaceIdentifiedDataSerializable
- Returns:
- type ID
-