public class FlowConverter
extends com.marklogic.client.ext.helper.LoggingObject
Constructor and Description |
---|
FlowConverter(HubConfig hubConfig) |
Modifier and Type | Method and Description |
---|---|
protected void |
addToCollections(com.fasterxml.jackson.databind.node.ObjectNode stepArtifact,
com.fasterxml.jackson.databind.JsonNode inlineStep,
java.lang.String flowName)
For any step, ensure that the stepName is in the collections array.
|
protected com.fasterxml.jackson.databind.node.ObjectNode |
buildStepArtifact(com.fasterxml.jackson.databind.JsonNode inlineStep,
Mapping mapping,
java.lang.String flowName)
Extracted for easy unit testing; has no dependencies on anything other than the inputs.
|
void |
convertFlows()
Convert the flow files in a user's local project.
|
protected com.fasterxml.jackson.databind.node.ObjectNode |
createStepArtifact(java.lang.String flowName,
com.fasterxml.jackson.databind.JsonNode inlineStep) |
void |
deleteLegacyMappings()
After flows have been converted, a user needs to delete any legacy mappings that exist, as these have now been
converted to mapping steps.
|
protected java.lang.String |
getEntityNameFromEntityType(java.lang.String targetEntityType)
To avoid making flow conversion depend on connecting to ML, we're implementing a simple approach here to try to
extract the entity name that should work most of the time.
|
protected Mapping |
getMappingArtifact(java.lang.String flowName,
com.fasterxml.jackson.databind.JsonNode inlineStep) |
protected java.lang.String |
getStepName(com.fasterxml.jackson.databind.node.ObjectNode stepNode) |
protected void |
transformMatchingOptions(com.fasterxml.jackson.databind.node.ObjectNode stepNode) |
protected void |
transformMergingOptions(com.fasterxml.jackson.databind.node.ObjectNode stepNode) |
public FlowConverter(HubConfig hubConfig)
public void deleteLegacyMappings()
public void convertFlows()
protected java.lang.String getStepName(com.fasterxml.jackson.databind.node.ObjectNode stepNode)
protected Mapping getMappingArtifact(java.lang.String flowName, com.fasterxml.jackson.databind.JsonNode inlineStep)
protected com.fasterxml.jackson.databind.node.ObjectNode createStepArtifact(java.lang.String flowName, com.fasterxml.jackson.databind.JsonNode inlineStep)
protected com.fasterxml.jackson.databind.node.ObjectNode buildStepArtifact(com.fasterxml.jackson.databind.JsonNode inlineStep, Mapping mapping, java.lang.String flowName)
inlineStep
- mapping
- flowName
- protected void addToCollections(com.fasterxml.jackson.databind.node.ObjectNode stepArtifact, com.fasterxml.jackson.databind.JsonNode inlineStep, java.lang.String flowName)
stepArtifact
- inlineStep
- flowName
- protected java.lang.String getEntityNameFromEntityType(java.lang.String targetEntityType)
targetEntityType
- protected void transformMatchingOptions(com.fasterxml.jackson.databind.node.ObjectNode stepNode)
protected void transformMergingOptions(com.fasterxml.jackson.databind.node.ObjectNode stepNode)