com.marklogic.hub.step.impl

Class StepRunnerUtil

java.lang.Object

com.marklogic.hub.step.impl.StepRunnerUtil

public class StepRunnerUtil
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
StepRunnerUtil()

Method Summary

Modifier and Type	Method and Description
protected static RunStepResponse	createStepResponse(Flow flow, java.lang.String step, java.lang.String jobId)
protected static RunStepResponse	getResponse(com.fasterxml.jackson.databind.JsonNode jobNode, java.lang.String step)
protected static java.lang.String	jsonToString(com.fasterxml.jackson.databind.JsonNode node)
static java.util.Map<java.lang.String,java.lang.Object>	makeCombinedOptions(Flow flow, StepDefinition stepDef, java.lang.String stepNumber, java.util.Map<java.lang.String,java.lang.Object> runtimeOptions) Note that this logic exists in flow-utils.sjs as well; this is apparently because FlowRunner needs to combine options before it runs any steps.
protected static java.lang.String	objectToString(java.lang.Object obj)

Methods inherited from class java.lang.Object

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

Constructor Detail

StepRunnerUtil

public StepRunnerUtil()

Method Detail

getResponse

protected static RunStepResponse getResponse(com.fasterxml.jackson.databind.JsonNode jobNode,
                                             java.lang.String step)

createStepResponse

protected static RunStepResponse createStepResponse(Flow flow,
                                                    java.lang.String step,
                                                    java.lang.String jobId)

jsonToString

protected static java.lang.String jsonToString(com.fasterxml.jackson.databind.JsonNode node)

objectToString

protected static java.lang.String objectToString(java.lang.Object obj)

makeCombinedOptions

public static java.util.Map<java.lang.String,java.lang.Object> makeCombinedOptions(Flow flow,
                                                                                   StepDefinition stepDef,
                                                                                   java.lang.String stepNumber,
                                                                                   java.util.Map<java.lang.String,java.lang.Object> runtimeOptions)

Note that this logic exists in flow-utils.sjs as well; this is apparently because FlowRunner needs to combine options before it runs any steps. But each call to process a batch of items also needs to combine steps, as it's not always invoked by FlowRunner. So there's some duplication that would be good to get rid of, possibly by having FlowRunner make a call to ML to combine options.

Parameters:

flow -

stepDef -

stepNumber -

runtimeOptions -

Returns: