public class FlowManagerImpl extends com.marklogic.client.extensions.ResourceManager implements FlowManager
Constructor and Description |
---|
FlowManagerImpl(HubConfig hubConfig) |
Modifier and Type | Method and Description |
---|---|
Flow |
getFlow(java.lang.String entityName,
java.lang.String flowName)
Retrieves a named flow from a given entity
|
Flow |
getFlow(java.lang.String entityName,
java.lang.String flowName,
FlowType flowType)
Retrieves a named flow from a given entity
|
Flow |
getFlowFromProperties(java.nio.file.Path propertiesFile)
Obtains a flow from a property file
|
java.util.List<Flow> |
getFlows(java.lang.String entityName)
Retrieves a list of flows installed on the MarkLogic server
|
java.util.List<java.lang.String> |
getLegacyFlows()
Updates the indexes in the database based on the project
|
java.util.List<Flow> |
getLocalFlows()
retrieves a list of all the flows on the local files systems
|
java.util.List<Flow> |
getLocalFlowsForEntity(java.lang.String entityName)
retrieves a list of all the flows on the local files systems
|
java.util.List<Flow> |
getLocalFlowsForEntity(java.lang.String entityName,
FlowType flowType)
retrieves a list of all the flows on the local files systems
|
FlowRunner |
newFlowRunner()
Creates and returns a new FlowRunner object using the FlowManager's hubconfig
|
java.util.List<java.lang.String> |
updateLegacyFlows(java.lang.String fromVersion)
Sets the version that the legacy flow is to be updated from
|
getName, startLogging, stopLogging
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create, flowFromXml
public FlowManagerImpl(HubConfig hubConfig)
public java.util.List<Flow> getLocalFlows()
FlowManager
getLocalFlows
in interface FlowManager
public java.util.List<Flow> getLocalFlowsForEntity(java.lang.String entityName)
FlowManager
getLocalFlowsForEntity
in interface FlowManager
entityName
- - string name of the entity for the flowpublic java.util.List<Flow> getLocalFlowsForEntity(java.lang.String entityName, FlowType flowType)
FlowManager
getLocalFlowsForEntity
in interface FlowManager
entityName
- - string name of the entity for the flowflowType
- - the FlowType enum, eg: ingest or harmonizepublic Flow getFlowFromProperties(java.nio.file.Path propertiesFile)
FlowManager
getFlowFromProperties
in interface FlowManager
propertiesFile
- - the Path to the property filepublic java.util.List<Flow> getFlows(java.lang.String entityName)
FlowManager
getFlows
in interface FlowManager
entityName
- - the entity from which to fetch the flowspublic Flow getFlow(java.lang.String entityName, java.lang.String flowName)
FlowManager
getFlow
in interface FlowManager
entityName
- - the entity that the flow belongs toflowName
- - the name of the flow to getpublic Flow getFlow(java.lang.String entityName, java.lang.String flowName, FlowType flowType)
FlowManager
getFlow
in interface FlowManager
entityName
- - the entity that the flow belongs toflowName
- - the name of the flow to getflowType
- - the type of flow (ingest/harmonize)public java.util.List<java.lang.String> getLegacyFlows()
FlowManager
getLegacyFlows
in interface FlowManager
public java.util.List<java.lang.String> updateLegacyFlows(java.lang.String fromVersion)
FlowManager
updateLegacyFlows
in interface FlowManager
fromVersion
- - string representation of DHF versionpublic FlowRunner newFlowRunner()
FlowManager
newFlowRunner
in interface FlowManager