/** This is an automatically generated code sample.
To make this code sample work in your Oracle Cloud tenancy,
please replace the values for any parameters whose current values do not fit
your use case (such as resource IDs, strings containing ‘EXAMPLE’ or ‘unique_id’, and
boolean, number, and enum parameters with values not fitting your use case).
*/
import com.oracle.bmc.ConfigFileReader;
import com.oracle.bmc.auth.AuthenticationDetailsProvider;
import com.oracle.bmc.auth.ConfigFileAuthenticationDetailsProvider;
import com.oracle.bmc.dataintegration.DataIntegrationClient;
import com.oracle.bmc.dataintegration.model.*;
import com.oracle.bmc.dataintegration.requests.*;
import com.oracle.bmc.dataintegration.responses.*;
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Date;
import java.util.UUID;
import java.util.Arrays;
public class CreateDataFlowExample {
public static void main(String[] args) throws Exception {
/**
* Create a default authentication provider that uses the DEFAULT
* profile in the configuration file.
* Refer to <see href="https://docs.cloud.oracle.com/en-us/iaas/Content/API/Concepts/sdkconfig.htm#SDK_and_CLI_Configuration_File>the public documentation</see> on how to prepare a configuration file.
*/
final ConfigFileReader.ConfigFile configFile = ConfigFileReader.parseDefault();
final AuthenticationDetailsProvider provider = new ConfigFileAuthenticationDetailsProvider(configFile);
/* Create a service client */
DataIntegrationClient client = DataIntegrationClient.builder().build(provider);
/* Create a request and dependent object(s). */
CreateDataFlowDetails createDataFlowDetails = CreateDataFlowDetails.builder()
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.identifier("EXAMPLE-identifier-Value")
.nodes(new ArrayList<>(Arrays.asList(FlowNode.builder()
.key("EXAMPLE-key-Value")
.modelType("EXAMPLE-modelType-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value")
.inputLinks(new ArrayList<>(Arrays.asList(InputLink.builder()
.fromLink("EXAMPLE-fromLink-Value")
.fieldMap(RuleBasedEntityMap.builder()
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_dKj51",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(677)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.mapType(RuleBasedEntityMap.MapType.Mapbypattern)
.fromPattern("EXAMPLE-fromPattern-Value")
.toPattern("EXAMPLE-toPattern-Value")
.isJavaRegexSyntax(false)
.objectStatus(758)
.description("EXAMPLE-description-Value").build())
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.objectStatus(329)
.description("EXAMPLE-description-Value")
.port("EXAMPLE-port-Value").build())))
.outputLinks(new ArrayList<>(Arrays.asList(OutputLink.builder()
.toLinks(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.objectStatus(461)
.description("EXAMPLE-description-Value")
.port("EXAMPLE-port-Value").build())))
.operator(Pivot.builder()
.groupByColumns(DynamicProxyField.builder()
.type(ConfiguredType.builder()
.wrappedType("EXAMPLE-wrappedType-Value")
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_rVhvN",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(826)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.configDefinition(ConfigDefinition.builder()
.key("EXAMPLE-key-Value")
.modelType("EXAMPLE-modelType-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.isContained(true)
.objectStatus(712)
.configParameterDefinitions(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterDefinition>() {
{
put("EXAMPLE_KEY_BXIOK",ConfigParameterDefinition.builder()
.parameterName("EXAMPLE-parameterName-Value")
.description("EXAMPLE-description-Value")
.defaultValue("EXAMPLE-defaultValue-Value")
.classFieldName("EXAMPLE-classFieldName-Value")
.isStatic(true)
.isClassFieldValue(true).build());
}
}).build())
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.objectStatus(216)
.description("EXAMPLE-description-Value").build())
.labels(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_knQJM",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(430)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.objectStatus(178)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())
.materializedGroupByColumns(MaterializedDynamicField.builder()
.scope("EXAMPLE-scope-Value")
.type(MaterializedCompositeType.builder()
.elements(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
.pathNames(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
.configDefinition(ConfigDefinition.builder()
.key("EXAMPLE-key-Value")
.modelType("EXAMPLE-modelType-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.isContained(true)
.objectStatus(45)
.configParameterDefinitions(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterDefinition>() {
{
put("EXAMPLE_KEY_oZ9Vg",ConfigParameterDefinition.builder()
.parameterType(ArrayType.builder()
.elementType("EXAMPLE-elementType-Value")
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.objectStatus(356)
.description("EXAMPLE-description-Value").build())
.parameterName("EXAMPLE-parameterName-Value")
.description("EXAMPLE-description-Value")
.defaultValue("EXAMPLE-defaultValue-Value")
.classFieldName("EXAMPLE-classFieldName-Value")
.isStatic(false)
.isClassFieldValue(false).build());
}
}).build())
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.objectStatus(522)
.description("EXAMPLE-description-Value").build())
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_KrJ7M",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(298)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.objectStatus(57)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())
.pivotKeys(PivotKeys.builder()
.pivotAxis(new ArrayList<>(Arrays.asList("h")))
.pivotKeyValueMap(new HashMap<java.lang.String, java.util.List<java.lang.String>>() {
{
put("EXAMPLE_KEY_0fMPT",new ArrayList<>(Arrays.asList("EXAMPLE_VALUE_7yieuGfbRgKq5NswVAKO")));
}
})
.key("EXAMPLE-key-Value")
.modelType("EXAMPLE-modelType-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.objectStatus(608).build())
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value")
.objectVersion(565)
.inputPorts(new ArrayList<>(Arrays.asList(InputPort.builder()
.portType(InputPort.PortType.Model)
.fields(new ArrayList<>(Arrays.asList(DecisionOutputPort.builder()
.portType(DecisionOutputPort.PortType.Data)
.decisionOutputPortType(DecisionOutputPort.DecisionOutputPortType.EvalTrue)
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_kGggE",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(249)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.objectStatus(89)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())))
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_rBaqE",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(281)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.objectStatus(222)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())))
.outputPorts(new ArrayList<>(Arrays.asList(DynamicInputField.builder()
.type(CompositeType.builder()
.configDefinition(ConfigDefinition.builder()
.key("EXAMPLE-key-Value")
.modelType("EXAMPLE-modelType-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.isContained(true)
.objectStatus(268)
.configParameterDefinitions(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterDefinition>() {
{
put("EXAMPLE_KEY_xkevY",ConfigParameterDefinition.builder()
.parameterName("EXAMPLE-parameterName-Value")
.description("EXAMPLE-description-Value")
.defaultValue("EXAMPLE-defaultValue-Value")
.classFieldName("EXAMPLE-classFieldName-Value")
.isStatic(false)
.isClassFieldValue(true).build());
}
}).build())
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.name("EXAMPLE-name-Value")
.objectStatus(553)
.description("EXAMPLE-description-Value").build())
.labels(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_yGNOv",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(973)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.objectStatus(69)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())))
.objectStatus(882)
.identifier("EXAMPLE-identifier-Value")
.parameters(new ArrayList<>(Arrays.asList(Parameter.builder()
.type("EXAMPLE-type-Value")
.defaultValue("EXAMPLE-defaultValue-Value")
.rootObjectDefaultValue("EXAMPLE-rootObjectDefaultValue-Value")
.isInput(false)
.isOutput(true)
.outputAggregationType(Parameter.OutputAggregationType.Max)
.typeName("EXAMPLE-typeName-Value")
.usedFor("EXAMPLE-usedFor-Value")
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_lAZJ3",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(987)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.objectStatus(53)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())))
.opConfigValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_J4VNa",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(15)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build()).build())
.uiProperties(UIProperties.builder()
.coordinateX(new BigDecimal("6544.522"))
.coordinateY(new BigDecimal("8092.4346")).build())
.objectStatus(69).build())))
.parameters(new ArrayList<>(Arrays.asList(Parameter.builder()
.type("EXAMPLE-type-Value")
.defaultValue("EXAMPLE-defaultValue-Value")
.rootObjectDefaultValue("EXAMPLE-rootObjectDefaultValue-Value")
.isInput(true)
.isOutput(true)
.outputAggregationType(Parameter.OutputAggregationType.Min)
.typeName("EXAMPLE-typeName-Value")
.usedFor("EXAMPLE-usedFor-Value")
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_fNJTQ",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(849)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.objectStatus(555)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())))
.description("EXAMPLE-description-Value")
.flowConfigValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_gh1vF",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(77)
.objectValue("EXAMPLE-objectValue-Value")
.refValue("EXAMPLE-refValue-Value")
.parameterValue("EXAMPLE-parameterValue-Value")
.rootObjectValue("EXAMPLE-rootObjectValue-Value").build());
}
})
.parentRef(ParentReference.builder()
.parent("EXAMPLE-parent-Value")
.rootDocId("ocid1.test.oc1..<unique_ID>EXAMPLE-rootDocId-Value").build()).build())
.objectStatus(761)
.registryMetadata(RegistryMetadata.builder()
.aggregatorKey("EXAMPLE-aggregatorKey-Value")
.labels(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
.registryVersion(346)
.key("EXAMPLE-key-Value")
.isFavorite(true).build()).build();
CreateDataFlowRequest createDataFlowRequest = CreateDataFlowRequest.builder()
.workspaceId("ocid1.test.oc1..<unique_ID>EXAMPLE-workspaceId-Value")
.createDataFlowDetails(createDataFlowDetails)
.opcRetryToken("EXAMPLE-opcRetryToken-Value")
.opcRequestId("GSGLVICPQYWUJFT79X3P<unique_ID>").build();
/* Send request to the Client */
CreateDataFlowResponse response = client.createDataFlow(createDataFlowRequest);
}
}