com.marklogic.hub.step

Class RunStepResponse

java.lang.Object

com.marklogic.hub.step.RunStepResponse

public class RunStepResponse
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
java.util.List<java.lang.String>	stepOutput

Constructor Summary

Constructors

Constructor and Description
RunStepResponse()

Method Summary

Modifier and Type	Method and Description
long	getFailedBatches()
long	getFailedEvents()
java.lang.String	getFlowName()
java.util.Map<java.lang.String,com.fasterxml.jackson.databind.JsonNode>	getFullOutput()
java.lang.String	getJobId()
java.lang.String	getStatus()
java.lang.String	getStepDefinitionName()
java.lang.String	getStepDefinitionType()
java.lang.String	getStepEndTime()
java.lang.String	getStepName()
java.util.List<java.lang.String>	getStepOutput()
java.lang.String	getStepStartTime()
long	getSuccessfulBatches()
long	getSuccessfulEvents()
java.lang.String	getTargetDatabase()
java.lang.String	getTargetEntityType()
long	getTotalEvents()
boolean	isSuccess()
RunStepResponse	setCounts(long totalEvents, long successfulEvents, long failedEvents, long successfulBatches, long failedBatches)
void	setStepEndTime(java.lang.String stepEndTime)
void	setStepStartTime(java.lang.String stepStartTime)
void	setTargetDatabase(java.lang.String targetDatabase)
com.fasterxml.jackson.databind.node.ObjectNode	toObjectNode()
java.lang.String	toString()
static RunStepResponse	withFlow(Flow flow)
RunStepResponse	withFullOutput(java.util.Map<java.lang.String,com.fasterxml.jackson.databind.JsonNode> fullOutput)
RunStepResponse	withJobId(java.lang.String jobId)
RunStepResponse	withStatus(java.lang.String status)
RunStepResponse	withStep(java.lang.String stepNum)
RunStepResponse	withStepOutput(java.util.List<java.lang.String> stepOutput)
RunStepResponse	withStepOutput(java.lang.String jobOutput)
RunStepResponse	withSuccess(boolean success)

Methods inherited from class java.lang.Object

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

Field Detail

stepOutput

public java.util.List<java.lang.String> stepOutput

Constructor Detail

RunStepResponse

public RunStepResponse()

Method Detail

setStepStartTime

public void setStepStartTime(java.lang.String stepStartTime)

setStepEndTime

public void setStepEndTime(java.lang.String stepEndTime)

toObjectNode

public com.fasterxml.jackson.databind.node.ObjectNode toObjectNode()

isSuccess

public boolean isSuccess()

Returns:

true if the job ran without errors, false otherwise.

withJobId

public RunStepResponse withJobId(java.lang.String jobId)

withFlow

public static RunStepResponse withFlow(Flow flow)

withStep

public RunStepResponse withStep(java.lang.String stepNum)

withStepOutput

public RunStepResponse withStepOutput(java.util.List<java.lang.String> stepOutput)

withFullOutput

public RunStepResponse withFullOutput(java.util.Map<java.lang.String,com.fasterxml.jackson.databind.JsonNode> fullOutput)

withStepOutput

public RunStepResponse withStepOutput(java.lang.String jobOutput)

withStatus

public RunStepResponse withStatus(java.lang.String status)

withSuccess

public RunStepResponse withSuccess(boolean success)

setCounts

public RunStepResponse setCounts(long totalEvents,
                                 long successfulEvents,
                                 long failedEvents,
                                 long successfulBatches,
                                 long failedBatches)

getJobId

public java.lang.String getJobId()

getFlowName

public java.lang.String getFlowName()

getFullOutput

public java.util.Map<java.lang.String,com.fasterxml.jackson.databind.JsonNode> getFullOutput()

getStatus

public java.lang.String getStatus()

getStepOutput

public java.util.List<java.lang.String> getStepOutput()

getSuccessfulEvents

public long getSuccessfulEvents()

getFailedEvents

public long getFailedEvents()

getTotalEvents

public long getTotalEvents()

getSuccessfulBatches

public long getSuccessfulBatches()

getFailedBatches

public long getFailedBatches()

getStepName

public java.lang.String getStepName()

getStepDefinitionType

public java.lang.String getStepDefinitionType()

getStepDefinitionName

public java.lang.String getStepDefinitionName()

getStepStartTime

public java.lang.String getStepStartTime()

getStepEndTime

public java.lang.String getStepEndTime()

getTargetEntityType

public java.lang.String getTargetEntityType()

getTargetDatabase

public java.lang.String getTargetDatabase()

setTargetDatabase

public void setTargetDatabase(java.lang.String targetDatabase)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object