com.hazelcast.jet.core

Class ProcessorMetaSupplier.SpecificMemberPms

java.lang.Object

com.hazelcast.jet.core.ProcessorMetaSupplier.SpecificMemberPms

All Implemented Interfaces:

ProcessorMetaSupplier, DataSerializable, IdentifiedDataSerializable, Serializable

Enclosing interface:

ProcessorMetaSupplier

public static class ProcessorMetaSupplier.SpecificMemberPms
extends Object
implements ProcessorMetaSupplier, IdentifiedDataSerializable

A meta-supplier that will only use the given ProcessorSupplier on a node with given Address.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.hazelcast.jet.core.ProcessorMetaSupplier

ProcessorMetaSupplier.Context, ProcessorMetaSupplier.ExpectNothingProcessorSupplier, ProcessorMetaSupplier.SpecificMemberPms

Method Summary

Modifier and Type	Method and Description
Function<? super Address,? extends ProcessorSupplier>	get(List<Address> addresses) Called to create a mapping from member Address to the ProcessorSupplier that will be sent to that member.
int	getClassId() Returns type identifier for this class.
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
void	init(ProcessorMetaSupplier.Context context) Called on the cluster member that receives the client request, after deserializing the meta-supplier instance.
int	preferredLocalParallelism() Returns the local parallelism the vertex should be configured with.
void	readData(ObjectDataInput in) Reads fields from the input stream
void	writeData(ObjectDataOutput out) Writes object fields to output stream

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.ProcessorMetaSupplier

close, closeIsCooperative, forceTotalParallelismOne, forceTotalParallelismOne, forceTotalParallelismOne, forceTotalParallelismOne, forceTotalParallelismOne, getRequiredPermission, getTags, initIsCooperative, of, of, of, of, of, of, of, of, preferLocalParallelismOne, preferLocalParallelismOne, preferLocalParallelismOne, preferLocalParallelismOne

Method Detail

init

public void init(@Nonnull
                 ProcessorMetaSupplier.Context context)
          throws Exception

Description copied from interface: ProcessorMetaSupplier

Called on the cluster member that receives the client request, after deserializing the meta-supplier instance. Gives access to the Hazelcast instance's services and provides the parallelism parameters determined from the cluster size.

Specified by:

init in interface ProcessorMetaSupplier

Throws:

Exception

get

@Nonnull
public Function<? super Address,? extends ProcessorSupplier> get(@Nonnull
                                                                          List<Address> addresses)

Description copied from interface: ProcessorMetaSupplier

Called to create a mapping from member Address to the ProcessorSupplier that will be sent to that member. Jet calls this method with a list of all cluster members' addresses and the returned function must be a mapping that returns a non-null value for each given address.

The method will be called once per job execution on the job's coordinator member. init() will have already been called.

Specified by:

get in interface ProcessorMetaSupplier

preferredLocalParallelism

public int preferredLocalParallelism()

Description copied from interface: ProcessorMetaSupplier

Returns the local parallelism the vertex should be configured with. The default implementation returns Vertex.LOCAL_PARALLELISM_USE_DEFAULT.

Specified by:

preferredLocalParallelism in interface ProcessorMetaSupplier

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException 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 interface IdentifiedDataSerializable

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 interface IdentifiedDataSerializable

Returns:

type ID