/** 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 CreatePipelineExample {
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). */
CreatePipelineDetails createPipelineDetails = CreatePipelineDetails.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")
.description("EXAMPLE-description-Value")
.modelType("EXAMPLE-modelType-Value")
.objectVersion(94)
.objectStatus(602)
.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(DirectFieldMap.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_ANciO",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(107)
.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())
.sourceTypedObject("EXAMPLE-sourceTypedObject-Value")
.targetTypedObject("EXAMPLE-targetTypedObject-Value")
.sourceScopeReference(ScopeReference.builder()
.referenceObject("EXAMPLE-referenceObject-Value")
.referenceType(ScopeReference.ReferenceType.BoundEntityShape)
.refObjectName("EXAMPLE-refObjectName-Value").build())
.targetScopeReference(ScopeReference.builder()
.referenceObject("EXAMPLE-referenceObject-Value")
.referenceType(ScopeReference.ReferenceType.BoundEntityShapeField)
.refObjectName("EXAMPLE-refObjectName-Value").build())
.objectStatus(939)
.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(871)
.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(332)
.description("EXAMPLE-description-Value")
.port("EXAMPLE-port-Value").build())))
.operator(Lookup.builder()
.lookupCondition(Expression.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())
.exprString("EXAMPLE-exprString-Value")
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_gflJQ",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(353)
.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(709).build())
.isSkipNoMatch(false)
.multiMatchStrategy(Lookup.MultiMatchStrategy.ReturnError)
.nullFillValues(new HashMap<java.lang.String, java.lang.Object>() {
{
put("EXAMPLE_KEY_RRmqW","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())
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value")
.objectVersion(144)
.inputPorts(new ArrayList<>(Arrays.asList(InputPort.builder()
.portType(InputPort.PortType.Model)
.fields(new ArrayList<>(Arrays.asList(OutputField.builder()
.type(DerivedType.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")
.objectStatus(119)
.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_hKjb5",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(45)
.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(444)
.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_sKfXu",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(64)
.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(363)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())))
.outputPorts(new ArrayList<>(Arrays.asList(DynamicInputField.builder()
.type(MapType.builder()
.keyElementType("EXAMPLE-keyElementType-Value")
.valueElementType("EXAMPLE-valueElementType-Value")
.containsNull(true)
.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(822)
.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_YBkIO",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(807)
.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(813)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())))
.objectStatus(98)
.identifier("EXAMPLE-identifier-Value")
.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_4JDO0",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(603)
.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(309)
.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_KuXNG",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(807)
.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("1105.032"))
.coordinateY(new BigDecimal("1169.9135")).build())
.objectStatus(62).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.Count)
.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_MOnRQ",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(546)
.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(354)
.name("EXAMPLE-name-Value")
.description("EXAMPLE-description-Value").build())))
.flowConfigValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_cRqxo",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(914)
.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())
.variables(new ArrayList<>(Arrays.asList(Variable.builder()
.key("EXAMPLE-key-Value")
.modelVersion("EXAMPLE-modelVersion-Value")
.modelType("EXAMPLE-modelType-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(318)
.objectStatus(408)
.identifier("EXAMPLE-identifier-Value")
.type(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(692)
.description("EXAMPLE-description-Value").build())
.configValues(ConfigValues.builder()
.configParamValues(new HashMap<java.lang.String, com.oracle.bmc.dataintegration.model.ConfigParameterValue>() {
{
put("EXAMPLE_KEY_o0t7s",ConfigParameterValue.builder()
.stringValue("EXAMPLE-stringValue-Value")
.intValue(50)
.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())
.defaultValue("EXAMPLE-defaultValue-Value")
.rootObjectDefaultValue(RootObject.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())
.objectStatus(871).build()).build())))
.registryMetadata(RegistryMetadata.builder()
.aggregatorKey("EXAMPLE-aggregatorKey-Value")
.labels(new ArrayList<>(Arrays.asList("EXAMPLE--Value")))
.registryVersion(728)
.key("EXAMPLE-key-Value")
.isFavorite(true).build()).build();
CreatePipelineRequest createPipelineRequest = CreatePipelineRequest.builder()
.workspaceId("ocid1.test.oc1..<unique_ID>EXAMPLE-workspaceId-Value")
.createPipelineDetails(createPipelineDetails)
.opcRetryToken("EXAMPLE-opcRetryToken-Value")
.opcRequestId("IN752HYIHBDEAP78D31I<unique_ID>").build();
/* Send request to the Client */
CreatePipelineResponse response = client.createPipeline(createPipelineRequest);
}
}