public class MlcpRunner extends ProcessRunner
Constructor and Description |
---|
MlcpRunner(java.lang.String mlcpPath,
java.lang.String mainClass,
HubConfig hubConfig,
Flow flow,
com.marklogic.client.DatabaseClient databaseClient,
com.fasterxml.jackson.databind.JsonNode mlcpOptions,
FlowStatusListener statusListener) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getJobId() |
void |
run() |
getHubConfig, getProcessOutput, newRunner, withArgs, withHubconfig, withStreamConsumer
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public MlcpRunner(java.lang.String mlcpPath, java.lang.String mainClass, HubConfig hubConfig, Flow flow, com.marklogic.client.DatabaseClient databaseClient, com.fasterxml.jackson.databind.JsonNode mlcpOptions, FlowStatusListener statusListener)
public java.lang.String getJobId()
public void run()
run
in interface java.lang.Runnable
run
in class ProcessRunner