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)