/** 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.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 = new DataIntegrationClient(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").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").build())
				.name("EXAMPLE-name-Value")
				.description("EXAMPLE-description-Value")
				.inputLinks(new ArrayList<>(Arrays.asList(InputLink.builder()
						.fromLink("EXAMPLE-fromLink-Value")
						.fieldMap(DirectFieldMap.builder()
							.key("EXAMPLE-key-Value")
							.modelVersion("EXAMPLE-modelVersion-Value")
							.parentRef(ParentReference.builder()
								.parent("EXAMPLE-parent-Value").build())
							.configValues(ConfigValues.builder()
								.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
										{
											put("EXAMPLE_KEY_IQytb",ConfigParameterValue.builder()
										.stringValue("EXAMPLE-stringValue-Value")
										.intValue(324)
										.refValue("EXAMPLE-refValue-Value")
										.parameterValue("EXAMPLE-parameterValue-Value").build());
										}
 									})
								.parentRef(ParentReference.builder()
									.parent("EXAMPLE-parent-Value").build()).build())
							.sourceTypedObject("EXAMPLE-sourceTypedObject-Value")
							.targetTypedObject("EXAMPLE-targetTypedObject-Value")
							.objectStatus(269)
							.description("EXAMPLE-description-Value").build())
						.key("EXAMPLE-key-Value")
						.modelVersion("EXAMPLE-modelVersion-Value")
						.parentRef(ParentReference.builder()
							.parent("EXAMPLE-parent-Value").build())
						.objectStatus(275)
						.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").build())
						.objectStatus(409)
						.description("EXAMPLE-description-Value")
						.port("EXAMPLE-port-Value").build())))
				.operator(Projection.builder()
					.key("EXAMPLE-key-Value")
					.modelVersion("EXAMPLE-modelVersion-Value")
					.parentRef(ParentReference.builder()
						.parent("EXAMPLE-parent-Value").build())
					.name("EXAMPLE-name-Value")
					.description("EXAMPLE-description-Value")
					.objectVersion(699)
					.inputPorts(new ArrayList<>(Arrays.asList(InputPort.builder()
							.portType(InputPort.PortType.Control)
							.fields(new ArrayList<>(Arrays.asList(FlowPort.builder()
									.key("EXAMPLE-key-Value")
									.modelVersion("EXAMPLE-modelVersion-Value")
									.parentRef(ParentReference.builder()
										.parent("EXAMPLE-parent-Value").build())
									.configValues(ConfigValues.builder()
										.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
												{
													put("EXAMPLE_KEY_Izo7Y",ConfigParameterValue.builder()
												.stringValue("EXAMPLE-stringValue-Value")
												.intValue(42)
												.refValue("EXAMPLE-refValue-Value")
												.parameterValue("EXAMPLE-parameterValue-Value").build());
												}
 											})
										.parentRef(ParentReference.builder()
											.parent("EXAMPLE-parent-Value").build()).build())
									.objectStatus(511)
									.name("EXAMPLE-name-Value")
									.description("EXAMPLE-description-Value").build())))
							.key("EXAMPLE-key-Value")
							.modelVersion("EXAMPLE-modelVersion-Value")
							.parentRef(ParentReference.builder()
								.parent("EXAMPLE-parent-Value").build())
							.configValues(ConfigValues.builder()
								.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
										{
											put("EXAMPLE_KEY_9vw2C",ConfigParameterValue.builder()
										.stringValue("EXAMPLE-stringValue-Value")
										.intValue(671)
										.refValue("EXAMPLE-refValue-Value")
										.parameterValue("EXAMPLE-parameterValue-Value").build());
										}
 									})
								.parentRef(ParentReference.builder()
									.parent("EXAMPLE-parent-Value").build()).build())
							.objectStatus(903)
							.name("EXAMPLE-name-Value")
							.description("EXAMPLE-description-Value").build())))
					.outputPorts(new ArrayList<>(Arrays.asList(OutputPort.builder()
							.portType(OutputPort.PortType.Model)
							.fields(new ArrayList<>(Arrays.asList(MacroField.builder()
									.expr(Expression.builder()
										.key("EXAMPLE-key-Value")
										.modelType("EXAMPLE-modelType-Value")
										.modelVersion("EXAMPLE-modelVersion-Value")
										.parentRef(ParentReference.builder()
											.parent("EXAMPLE-parent-Value").build())
										.exprString("EXAMPLE-exprString-Value")
										.configValues(ConfigValues.builder()
											.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
													{
														put("EXAMPLE_KEY_WFYcv",ConfigParameterValue.builder()
													.stringValue("EXAMPLE-stringValue-Value")
													.intValue(845)
													.refValue("EXAMPLE-refValue-Value")
													.parameterValue("EXAMPLE-parameterValue-Value").build());
													}
 												})
											.parentRef(ParentReference.builder()
												.parent("EXAMPLE-parent-Value").build()).build())
										.objectStatus(777).build())
									.type(DerivedType.builder()
										.key("EXAMPLE-key-Value")
										.modelVersion("EXAMPLE-modelVersion-Value")
										.parentRef(ParentReference.builder()
											.parent("EXAMPLE-parent-Value").build())
										.name("EXAMPLE-name-Value")
										.objectStatus(621)
										.description("EXAMPLE-description-Value").build())
									.isUseSourceType(false)
									.useType(ConfiguredType.builder()
										.wrappedType("EXAMPLE-wrappedType-Value")
										.configValues(ConfigValues.builder()
											.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
													{
														put("EXAMPLE_KEY_syQbv",ConfigParameterValue.builder()
													.stringValue("EXAMPLE-stringValue-Value")
													.intValue(210)
													.refValue("EXAMPLE-refValue-Value")
													.parameterValue("EXAMPLE-parameterValue-Value").build());
													}
 												})
											.parentRef(ParentReference.builder()
												.parent("EXAMPLE-parent-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").build())
											.name("EXAMPLE-name-Value")
											.isContained(false)
											.objectStatus(667)
											.configParameterDefinitions(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterDefinition>() {
													{
														put("EXAMPLE_KEY_AhXTk",ConfigParameterDefinition.builder()
													.parameterType(DataType.builder()
														.dtType(DataType.DtType.Structured)
														.typeSystemName("EXAMPLE-typeSystemName-Value")
														.key("EXAMPLE-key-Value")
														.modelVersion("EXAMPLE-modelVersion-Value")
														.parentRef(ParentReference.builder()
															.parent("EXAMPLE-parent-Value").build())
														.name("EXAMPLE-name-Value")
														.objectStatus(467)
														.description("EXAMPLE-description-Value").build())
													.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").build())
										.name("EXAMPLE-name-Value")
										.objectStatus(371)
										.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").build())
									.configValues(ConfigValues.builder()
										.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
												{
													put("EXAMPLE_KEY_GGOzD",ConfigParameterValue.builder()
												.stringValue("EXAMPLE-stringValue-Value")
												.intValue(560)
												.refValue("EXAMPLE-refValue-Value")
												.parameterValue("EXAMPLE-parameterValue-Value").build());
												}
 											})
										.parentRef(ParentReference.builder()
											.parent("EXAMPLE-parent-Value").build()).build())
									.objectStatus(150)
									.name("EXAMPLE-name-Value")
									.description("EXAMPLE-description-Value").build())))
							.key("EXAMPLE-key-Value")
							.modelVersion("EXAMPLE-modelVersion-Value")
							.parentRef(ParentReference.builder()
								.parent("EXAMPLE-parent-Value").build())
							.configValues(ConfigValues.builder()
								.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
										{
											put("EXAMPLE_KEY_abiUY",ConfigParameterValue.builder()
										.stringValue("EXAMPLE-stringValue-Value")
										.intValue(863)
										.refValue("EXAMPLE-refValue-Value")
										.parameterValue("EXAMPLE-parameterValue-Value").build());
										}
 									})
								.parentRef(ParentReference.builder()
									.parent("EXAMPLE-parent-Value").build()).build())
							.objectStatus(178)
							.name("EXAMPLE-name-Value")
							.description("EXAMPLE-description-Value").build())))
					.objectStatus(801)
					.identifier("EXAMPLE-identifier-Value")
					.parameters(new ArrayList<>(Arrays.asList(Parameter.builder()
							.type(DynamicType.builder()
								.typeHandler(RuleTypeConfig.builder()
									.key("EXAMPLE-key-Value")
									.modelVersion("EXAMPLE-modelVersion-Value")
									.parentRef(ParentReference.builder()
										.parent("EXAMPLE-parent-Value").build())
									.scope("EXAMPLE-scope-Value")
									.isOrderByRule(true)
									.projectionRules(new ArrayList<>(Arrays.asList(NameListRule.builder()
											.isSkipRemainingRulesOnMatch(true)
											.scope("EXAMPLE-scope-Value")
											.isCascade(true)
											.matchingStrategy(NameListRule.MatchingStrategy.NameOrTags)
											.isCaseSensitive(false)
											.ruleType(NameListRule.RuleType.Include)
											.names(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
											.key("EXAMPLE-key-Value")
											.modelVersion("EXAMPLE-modelVersion-Value")
											.parentRef(ParentReference.builder()
												.parent("EXAMPLE-parent-Value").build())
											.isJavaRegexSyntax(true)
											.configValues(ConfigValues.builder()
												.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
														{
															put("EXAMPLE_KEY_0uWJW",ConfigParameterValue.builder()
														.stringValue("EXAMPLE-stringValue-Value")
														.intValue(261)
														.refValue("EXAMPLE-refValue-Value")
														.parameterValue("EXAMPLE-parameterValue-Value").build());
														}
 													})
												.parentRef(ParentReference.builder()
													.parent("EXAMPLE-parent-Value").build()).build())
											.objectStatus(96)
											.description("EXAMPLE-description-Value").build())))
									.configValues(ConfigValues.builder()
										.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
												{
													put("EXAMPLE_KEY_AfQZj",ConfigParameterValue.builder()
												.stringValue("EXAMPLE-stringValue-Value")
												.intValue(426)
												.refValue("EXAMPLE-refValue-Value")
												.parameterValue("EXAMPLE-parameterValue-Value").build());
												}
 											})
										.parentRef(ParentReference.builder()
											.parent("EXAMPLE-parent-Value").build()).build())
									.objectStatus(624).build())
								.configDefinition(ConfigDefinition.builder()
									.key("EXAMPLE-key-Value")
									.modelType("EXAMPLE-modelType-Value")
									.modelVersion("EXAMPLE-modelVersion-Value")
									.parentRef(ParentReference.builder()
										.parent("EXAMPLE-parent-Value").build())
									.name("EXAMPLE-name-Value")
									.isContained(false)
									.objectStatus(854)
									.configParameterDefinitions(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterDefinition>() {
											{
												put("EXAMPLE_KEY_g0eYK",ConfigParameterDefinition.builder()
											.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").build())
								.name("EXAMPLE-name-Value")
								.objectStatus(246)
								.description("EXAMPLE-description-Value").build())
							.defaultValue("EXAMPLE-defaultValue-Value")
							.rootObjectDefaultValue("EXAMPLE-rootObjectDefaultValue-Value")
							.isInput(true)
							.isOutput(true)
							.outputAggregationType(Parameter.OutputAggregationType.Max)
							.typeName("EXAMPLE-typeName-Value")
							.key("EXAMPLE-key-Value")
							.modelVersion("EXAMPLE-modelVersion-Value")
							.parentRef(ParentReference.builder()
								.parent("EXAMPLE-parent-Value").build())
							.configValues(ConfigValues.builder()
								.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
										{
											put("EXAMPLE_KEY_qWdN7",ConfigParameterValue.builder()
										.stringValue("EXAMPLE-stringValue-Value")
										.intValue(16)
										.refValue("EXAMPLE-refValue-Value")
										.parameterValue("EXAMPLE-parameterValue-Value").build());
										}
 									})
								.parentRef(ParentReference.builder()
									.parent("EXAMPLE-parent-Value").build()).build())
							.objectStatus(155)
							.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_csl7H",ConfigParameterValue.builder()
								.stringValue("EXAMPLE-stringValue-Value")
								.intValue(850)
								.refValue("EXAMPLE-refValue-Value")
								.parameterValue("EXAMPLE-parameterValue-Value").build());
								}
 							})
						.parentRef(ParentReference.builder()
							.parent("EXAMPLE-parent-Value").build()).build()).build())
				.uiProperties(UIProperties.builder()
					.coordinateX(new BigDecimal("2394.4348"))
					.coordinateY(new BigDecimal("3748.0664")).build())
				.objectStatus(784).build())))
		.parameters(new ArrayList<>(Arrays.asList(Parameter.builder()
				.type(DynamicType.builder()
					.typeHandler(RuleTypeConfig.builder()
						.key("EXAMPLE-key-Value")
						.modelVersion("EXAMPLE-modelVersion-Value")
						.parentRef(ParentReference.builder()
							.parent("EXAMPLE-parent-Value").build())
						.scope("EXAMPLE-scope-Value")
						.isOrderByRule(false)
						.projectionRules(new ArrayList<>(Arrays.asList(TypeListRule.builder()
								.isSkipRemainingRulesOnMatch(false)
								.scope("EXAMPLE-scope-Value")
								.isCascade(false)
								.matchingStrategy(TypeListRule.MatchingStrategy.TagsOnly)
								.isCaseSensitive(false)
								.ruleType(TypeListRule.RuleType.Exclude)
								.types(new ArrayList<>(Arrays.asList("EXAMPLE-types-Value")))
								.key("EXAMPLE-key-Value")
								.modelVersion("EXAMPLE-modelVersion-Value")
								.parentRef(ParentReference.builder()
									.parent("EXAMPLE-parent-Value").build())
								.isJavaRegexSyntax(false)
								.configValues(ConfigValues.builder()
									.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
											{
												put("EXAMPLE_KEY_82bxa",ConfigParameterValue.builder()
											.stringValue("EXAMPLE-stringValue-Value")
											.intValue(30)
											.refValue("EXAMPLE-refValue-Value")
											.parameterValue("EXAMPLE-parameterValue-Value").build());
											}
 										})
									.parentRef(ParentReference.builder()
										.parent("EXAMPLE-parent-Value").build()).build())
								.objectStatus(41)
								.description("EXAMPLE-description-Value").build())))
						.configValues(ConfigValues.builder()
							.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
									{
										put("EXAMPLE_KEY_lt3wY",ConfigParameterValue.builder()
									.stringValue("EXAMPLE-stringValue-Value")
									.intValue(132)
									.refValue("EXAMPLE-refValue-Value")
									.parameterValue("EXAMPLE-parameterValue-Value").build());
									}
 								})
							.parentRef(ParentReference.builder()
								.parent("EXAMPLE-parent-Value").build()).build())
						.objectStatus(817).build())
					.configDefinition(ConfigDefinition.builder()
						.key("EXAMPLE-key-Value")
						.modelType("EXAMPLE-modelType-Value")
						.modelVersion("EXAMPLE-modelVersion-Value")
						.parentRef(ParentReference.builder()
							.parent("EXAMPLE-parent-Value").build())
						.name("EXAMPLE-name-Value")
						.isContained(false)
						.objectStatus(618)
						.configParameterDefinitions(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterDefinition>() {
								{
									put("EXAMPLE_KEY_GcKYh",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").build())
					.name("EXAMPLE-name-Value")
					.objectStatus(170)
					.description("EXAMPLE-description-Value").build())
				.defaultValue("EXAMPLE-defaultValue-Value")
				.rootObjectDefaultValue("EXAMPLE-rootObjectDefaultValue-Value")
				.isInput(true)
				.isOutput(true)
				.outputAggregationType(Parameter.OutputAggregationType.Count)
				.typeName("EXAMPLE-typeName-Value")
				.key("EXAMPLE-key-Value")
				.modelVersion("EXAMPLE-modelVersion-Value")
				.parentRef(ParentReference.builder()
					.parent("EXAMPLE-parent-Value").build())
				.configValues(ConfigValues.builder()
					.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
							{
								put("EXAMPLE_KEY_OkP98",ConfigParameterValue.builder()
							.stringValue("EXAMPLE-stringValue-Value")
							.intValue(581)
							.refValue("EXAMPLE-refValue-Value")
							.parameterValue("EXAMPLE-parameterValue-Value").build());
							}
 						})
					.parentRef(ParentReference.builder()
						.parent("EXAMPLE-parent-Value").build()).build())
				.objectStatus(868)
				.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_ode0o",ConfigParameterValue.builder()
					.stringValue("EXAMPLE-stringValue-Value")
					.intValue(84)
					.refValue("EXAMPLE-refValue-Value")
					.parameterValue("EXAMPLE-parameterValue-Value").build());
					}
 				})
			.parentRef(ParentReference.builder()
				.parent("EXAMPLE-parent-Value").build()).build())
		.objectStatus(620)
		.registryMetadata(RegistryMetadata.builder()
			.aggregatorKey("EXAMPLE-aggregatorKey-Value")
			.labels(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
			.registryVersion(603)
			.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("AC8JQZAKI8LX6I0XIYD1/OpcRequestIdExample/<unique_ID>").build();

        /* Send request to the Client */
        CreateDataFlowResponse response = client.createDataFlow(createDataFlowRequest);
    }

    
}