org.apache.samza.container.placement

Class ContainerPlacementMessage

java.lang.Object

org.apache.samza.container.placement.ContainerPlacementMessage

Direct Known Subclasses:

ContainerPlacementRequestMessage, ContainerPlacementResponseMessage

public abstract class ContainerPlacementMessage
extends java.lang.Object

Encapsulates the request or response payload information between the ContainerPlacementService and external controllers issuing placement actions

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ContainerPlacementMessage.StatusCode

Field Summary

Fields

Modifier and Type	Field and Description
protected java.lang.String	deploymentId Unique identifier for a deployment so messages can be invalidated across a job restarts for ex yarn bases cluster manager can be set to app attempt id
protected java.lang.String	destinationHost
protected java.lang.String	processorId
protected java.time.Duration	requestExpiry
protected ContainerPlacementMessage.StatusCode	statusCode
protected long	timestamp
protected java.util.UUID	uuid Unique identifier of a request or response message.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ContainerPlacementMessage(java.util.UUID uuid, java.lang.String deploymentId, java.lang.String processorId, java.lang.String destinationHost, ContainerPlacementMessage.StatusCode statusCode, long timestamp)
protected	ContainerPlacementMessage(java.util.UUID uuid, java.lang.String deploymentId, java.lang.String processorId, java.lang.String destinationHost, java.time.Duration requestExpiry, ContainerPlacementMessage.StatusCode statusCode, long timestamp)

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object o)
java.lang.String	getDeploymentId()
java.lang.String	getDestinationHost()
java.lang.String	getProcessorId()
java.time.Duration	getRequestExpiry()
ContainerPlacementMessage.StatusCode	getStatusCode()
long	getTimestamp()
java.util.UUID	getUuid()
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

uuid

protected final java.util.UUID uuid

Unique identifier of a request or response message. Helps in identifying duplicate request messages.

deploymentId

protected final java.lang.String deploymentId

Unique identifier for a deployment so messages can be invalidated across a job restarts for ex yarn bases cluster manager can be set to app attempt id

processorId

protected final java.lang.String processorId

destinationHost

protected final java.lang.String destinationHost

requestExpiry

protected final java.time.Duration requestExpiry

statusCode

protected final ContainerPlacementMessage.StatusCode statusCode

timestamp

protected final long timestamp

Constructor Detail

ContainerPlacementMessage

protected ContainerPlacementMessage(java.util.UUID uuid,
                                    java.lang.String deploymentId,
                                    java.lang.String processorId,
                                    java.lang.String destinationHost,
                                    java.time.Duration requestExpiry,
                                    ContainerPlacementMessage.StatusCode statusCode,
                                    long timestamp)

ContainerPlacementMessage

protected ContainerPlacementMessage(java.util.UUID uuid,
                                    java.lang.String deploymentId,
                                    java.lang.String processorId,
                                    java.lang.String destinationHost,
                                    ContainerPlacementMessage.StatusCode statusCode,
                                    long timestamp)

Method Detail

getDeploymentId

public java.lang.String getDeploymentId()

getProcessorId

public java.lang.String getProcessorId()

getDestinationHost

public java.lang.String getDestinationHost()

getStatusCode

public ContainerPlacementMessage.StatusCode getStatusCode()

getRequestExpiry

public java.time.Duration getRequestExpiry()

getUuid

public java.util.UUID getUuid()

getTimestamp

public long getTimestamp()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object