io.parallec.core.task

Class ParallelTaskBean

java.lang.Object

io.parallec.core.task.ParallelTaskBean

public class ParallelTaskBean
extends java.lang.Object

The Class ParallelTaskBean. this is for serialization and see as a snapshot

Author:

Yuanteng (Jeff) Pei

Field Summary

Fields

Modifier and Type	Field and Description
private HttpMeta	commandMeta The command meta.
private double	durationSec The duration sec.
private java.lang.String	executeStartTime The execute start time.
private java.lang.String	executionEndTime The end time.
akka.actor.ActorRef	executionManager The executionManager.
private ParallecResponseHandler	handler The handler.
private HttpPollerProcessor	httpPollerProcessor The http poller processor.
private boolean	isPollable The is pollable.
private java.util.Map<java.lang.String,NodeReqResponse>	parallelTaskResult The parallel task result.
private java.util.Map<java.lang.String,java.lang.String>	replacementVarMap The replacement var map.
private java.util.Map<java.lang.String,StrStrMap>	replacementVarMapNodeSpecific The replacement var map node specific.
private java.lang.Integer	requestNum The request num.
private java.lang.Integer	requestNumActual The request num actual.
private RequestReplacementType	requestReplacementType The request replacement type.
private java.util.Map<java.lang.String,java.lang.Object>	responseContext The response context.
private java.lang.Integer	responsedNum The response received number.
private SshMeta	sshMeta The ssh meta.
private java.lang.String	state The state.
private java.lang.String	submitTime TODO: The start time.
private TargetHostMeta	targetHostMeta The target host meta.
private java.util.List<TaskErrorMeta>	taskErrorMetas The task error metas.
private java.lang.String	taskId The job id.
private TcpMeta	tcpMeta The ssh meta.
private java.lang.String	timeStamp The time stamp.

Constructor Summary

Constructors

Constructor and Description
ParallelTaskBean(ParallelTask task) Instantiates a new parallel task bean.

Method Summary

Modifier and Type	Method and Description
HttpMeta	getCommandMeta() Gets the command meta.
double	getDurationSec()
java.lang.String	getExecuteStartTime()
java.lang.String	getExecutionEndTime()
ParallecResponseHandler	getHandler() Gets the handler.
HttpPollerProcessor	getHttpPollerProcessor() Gets the http poller processor.
java.util.Map<java.lang.String,NodeReqResponse>	getParallelTaskResult() Gets the parallel task result.
java.util.Map<java.lang.String,java.lang.String>	getReplacementVarMap() Gets the replacement var map.
java.util.Map<java.lang.String,StrStrMap>	getReplacementVarMapNodeSpecific() Gets the replacement var map node specific.
java.lang.Integer	getRequestNum() Gets the request num.
java.lang.Integer	getRequestNumActual() Gets the request num actual.
RequestReplacementType	getRequestReplacementType() Gets the request replacement type.
java.util.Map<java.lang.String,java.lang.Object>	getResponseContext() Gets the response context.
java.lang.Integer	getResponsedNum() Gets the responsed num.
SshMeta	getSshMeta() Gets the ssh meta.
java.lang.String	getState() Gets the state.
java.lang.String	getSubmitTime()
TargetHostMeta	getTargetHostMeta() Gets the target host meta.
java.util.List<TaskErrorMeta>	getTaskErrorMetas() Gets the task error metas.
java.lang.String	getTaskId() Gets the task id.
TcpMeta	getTcpMeta()
java.lang.String	getTimeStamp() Gets the time stamp.
boolean	isPollable() Checks if is pollable.
void	setCommandMeta(HttpMeta commandMeta) Sets the command meta.
void	setDurationSec(double durationSec)
void	setExecuteStartTime(java.lang.String executeStartTime)
void	setExecutionEndTime(java.lang.String executionEndTime)
void	setHandler(ParallecResponseHandler handler) Sets the handler.
void	setHttpPollerProcessor(HttpPollerProcessor httpPollerProcessor) Sets the http poller processor.
void	setParallelTaskResult(java.util.Map<java.lang.String,NodeReqResponse> parallelTaskResult) Sets the parallel task result.
void	setPollable(boolean isPollable) Sets the pollable.
void	setRequestNum(java.lang.Integer requestNum) Sets the request num.
void	setRequestNumActual(java.lang.Integer requestNumActual) Sets the request num actual.
void	setRequestReplacementType(RequestReplacementType requestReplacementType) Sets the request replacement type.
void	setResponseContext(java.util.Map<java.lang.String,java.lang.Object> responseContext) Sets the response context.
void	setResponsedNum(java.lang.Integer responsedNum) Sets the responsed num.
void	setSshMeta(SshMeta sshMeta) Sets the ssh meta.
void	setState(java.lang.String state) Sets the state.
void	setSubmitTime(java.lang.String submitTime)
void	setTargetHostMeta(TargetHostMeta targetHostMeta) Sets the target host meta.
void	setTaskId(java.lang.String taskId) Sets the task id.
void	setTcpMeta(TcpMeta tcpMeta)
void	setTimeStamp(java.lang.String timeStamp) Sets the time stamp.

Methods inherited from class java.lang.Object

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

Field Detail

timeStamp

private java.lang.String timeStamp

The time stamp.

submitTime

private java.lang.String submitTime

TODO: The start time.

executeStartTime

private java.lang.String executeStartTime

The execute start time.

executionEndTime

private java.lang.String executionEndTime

The end time.

durationSec

private double durationSec

The duration sec.

requestNum

private java.lang.Integer requestNum

The request num.

requestNumActual

private java.lang.Integer requestNumActual

The request num actual.

responsedNum

private volatile java.lang.Integer responsedNum

The response received number.

taskErrorMetas

private final java.util.List<TaskErrorMeta> taskErrorMetas

The task error metas.

responseContext

private java.util.Map<java.lang.String,java.lang.Object> responseContext

The response context.

state

private java.lang.String state

The state.

taskId

private java.lang.String taskId

The job id.

handler

private ParallecResponseHandler handler

The handler.

parallelTaskResult

private java.util.Map<java.lang.String,NodeReqResponse> parallelTaskResult

The parallel task result.

commandMeta

private HttpMeta commandMeta

The command meta.

targetHostMeta

private TargetHostMeta targetHostMeta

The target host meta.

sshMeta

private SshMeta sshMeta

The ssh meta.

tcpMeta

private TcpMeta tcpMeta

The ssh meta.

executionManager

public akka.actor.ActorRef executionManager

The executionManager.

replacementVarMapNodeSpecific

private final java.util.Map<java.lang.String,StrStrMap> replacementVarMapNodeSpecific

The replacement var map node specific.

replacementVarMap

private final java.util.Map<java.lang.String,java.lang.String> replacementVarMap

The replacement var map.

requestReplacementType

private RequestReplacementType requestReplacementType

The request replacement type.

isPollable

private boolean isPollable

The is pollable.

httpPollerProcessor

private HttpPollerProcessor httpPollerProcessor

The http poller processor.

Constructor Detail

ParallelTaskBean

public ParallelTaskBean(ParallelTask task)

Instantiates a new parallel task bean.

Parameters:

task - the task

Method Detail

getTimeStamp

public java.lang.String getTimeStamp()

Gets the time stamp.

Returns:

the time stamp

setTimeStamp

public void setTimeStamp(java.lang.String timeStamp)

Sets the time stamp.

Parameters:

timeStamp - the new time stamp

getRequestNum

public java.lang.Integer getRequestNum()

Gets the request num.

Returns:

the request num

setRequestNum

public void setRequestNum(java.lang.Integer requestNum)

Sets the request num.

Parameters:

requestNum - the new request num

getRequestNumActual

public java.lang.Integer getRequestNumActual()

Gets the request num actual.

Returns:

the request num actual

setRequestNumActual

public void setRequestNumActual(java.lang.Integer requestNumActual)

Sets the request num actual.

Parameters:

requestNumActual - the new request num actual

getResponsedNum

public java.lang.Integer getResponsedNum()

Gets the responsed num.

Returns:

the responsed num

setResponsedNum

public void setResponsedNum(java.lang.Integer responsedNum)

Sets the responsed num.

Parameters:

responsedNum - the new responsed num

getResponseContext

public java.util.Map<java.lang.String,java.lang.Object> getResponseContext()

Gets the response context.

Returns:

the response context

setResponseContext

public void setResponseContext(java.util.Map<java.lang.String,java.lang.Object> responseContext)

Sets the response context.

Parameters:

responseContext - the response context

getState

public java.lang.String getState()

Gets the state.

Returns:

the state

setState

public void setState(java.lang.String state)

Sets the state.

Parameters:

state - the new state

getHandler

public ParallecResponseHandler getHandler()

Gets the handler.

Returns:

the handler

setHandler

public void setHandler(ParallecResponseHandler handler)

Sets the handler.

Parameters:

handler - the new handler

getParallelTaskResult

public java.util.Map<java.lang.String,NodeReqResponse> getParallelTaskResult()

Gets the parallel task result.

Returns:

the parallel task result

setParallelTaskResult

public void setParallelTaskResult(java.util.Map<java.lang.String,NodeReqResponse> parallelTaskResult)

Sets the parallel task result.

Parameters:

parallelTaskResult - the parallel task result

getCommandMeta

public HttpMeta getCommandMeta()

Gets the command meta.

Returns:

the command meta

setCommandMeta

public void setCommandMeta(HttpMeta commandMeta)

Sets the command meta.

Parameters:

commandMeta - the new command meta

getTargetHostMeta

public TargetHostMeta getTargetHostMeta()

Gets the target host meta.

Returns:

the target host meta

setTargetHostMeta

public void setTargetHostMeta(TargetHostMeta targetHostMeta)

Sets the target host meta.

Parameters:

targetHostMeta - the new target host meta

getSshMeta

public SshMeta getSshMeta()

Gets the ssh meta.

Returns:

the ssh meta

setSshMeta

public void setSshMeta(SshMeta sshMeta)

Sets the ssh meta.

Parameters:

sshMeta - the new ssh meta

getRequestReplacementType

public RequestReplacementType getRequestReplacementType()

Gets the request replacement type.

Returns:

the request replacement type

setRequestReplacementType

public void setRequestReplacementType(RequestReplacementType requestReplacementType)

Sets the request replacement type.

Parameters:

requestReplacementType - the new request replacement type

isPollable

public boolean isPollable()

Checks if is pollable.

Returns:

true, if is pollable

setPollable

public void setPollable(boolean isPollable)

Sets the pollable.

Parameters:

isPollable - the new pollable

getHttpPollerProcessor

public HttpPollerProcessor getHttpPollerProcessor()

Gets the http poller processor.

Returns:

the http poller processor

setHttpPollerProcessor

public void setHttpPollerProcessor(HttpPollerProcessor httpPollerProcessor)

Sets the http poller processor.

Parameters:

httpPollerProcessor - the new http poller processor

getTaskErrorMetas

public java.util.List<TaskErrorMeta> getTaskErrorMetas()

Gets the task error metas.

Returns:

the task error metas

getReplacementVarMapNodeSpecific

public java.util.Map<java.lang.String,StrStrMap> getReplacementVarMapNodeSpecific()

Gets the replacement var map node specific.

Returns:

the replacement var map node specific

getReplacementVarMap

public java.util.Map<java.lang.String,java.lang.String> getReplacementVarMap()

Gets the replacement var map.

Returns:

the replacement var map

getTaskId

public java.lang.String getTaskId()

Gets the task id.

Returns:

the task id

setTaskId

public void setTaskId(java.lang.String taskId)

Sets the task id.

Parameters:

taskId - the new task id

getSubmitTime

public java.lang.String getSubmitTime()

setSubmitTime

public void setSubmitTime(java.lang.String submitTime)

getExecuteStartTime

public java.lang.String getExecuteStartTime()

setExecuteStartTime

public void setExecuteStartTime(java.lang.String executeStartTime)

getExecutionEndTime

public java.lang.String getExecutionEndTime()

setExecutionEndTime

public void setExecutionEndTime(java.lang.String executionEndTime)

getDurationSec

public double getDurationSec()

setDurationSec

public void setDurationSec(double durationSec)

getTcpMeta

public TcpMeta getTcpMeta()

setTcpMeta

public void setTcpMeta(TcpMeta tcpMeta)