public interface StepRunnerService
Modifier and Type | Method and Description |
---|---|
com.marklogic.client.SessionState |
newSessionState()
Creates an object to track a session for a set of operations
that require session state on the database server.
|
static StepRunnerService |
on(com.marklogic.client.DatabaseClient db)
Creates a StepRunnerService object for executing operations on the database server.
|
static StepRunnerService |
on(com.marklogic.client.DatabaseClient db,
com.marklogic.client.io.marker.JSONWriteHandle serviceDeclaration)
Creates a StepRunnerService object for executing operations on the database server.
|
com.fasterxml.jackson.databind.JsonNode |
processBatch(com.marklogic.client.SessionState api_session,
com.fasterxml.jackson.databind.JsonNode inputs)
Replacement for the mlRunFlow REST extension; processes a batch of items using the given flow and step
|
static StepRunnerService on(com.marklogic.client.DatabaseClient db)
db
- provides a client for communicating with the database serverstatic StepRunnerService on(com.marklogic.client.DatabaseClient db, com.marklogic.client.io.marker.JSONWriteHandle serviceDeclaration)
db
- provides a client for communicating with the database serverserviceDeclaration
- substitutes a custom implementation of the servicecom.marklogic.client.SessionState newSessionState()
com.fasterxml.jackson.databind.JsonNode processBatch(com.marklogic.client.SessionState api_session, com.fasterxml.jackson.databind.JsonNode inputs)
api_session
- Holds the session objectinputs
- provides input