Merge pull request #363 from cognitedata/add-instances-type-to-transf…

…ormation-jobs transformations: add support for data model destination type
cognitedata · Feb 19, 2024 · 4ba0f3c · 4ba0f3c
2 parents 2d9f95c + 23551b3
commit 4ba0f3c
Show file tree

Hide file tree

Showing 5 changed files with 48 additions and 2 deletions.
diff --git a/README.md b/README.md
@@ -40,7 +40,7 @@ SDK v2
 <dependency>    
     <groupId>com.cognite</groupId>
     <artifactId>cdf-sdk-java</artifactId>
-    <version>2.2.1</version>
+    <version>2.3.0</version>
 </dependency>
 ```
 

diff --git a/pom.xml b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>com.cognite</groupId>
     <artifactId>cdf-sdk-java</artifactId>
-    <version>2.2.1</version>
+    <version>2.3.0</version>
     <licenses>
         <license>
             <name>Apache 2</name>

diff --git a/releases.md b/releases.md
@@ -19,6 +19,12 @@ Changes are grouped as follows:
 - Extraction pipelines configuration
 - Data models
 
+## [2.3.0] 2024-02-13
+
+### Added
+
+- Added support for returning data model destination type when retrieving transformation jobs.
+
 ## [2.2.1] 2023-11-16
 
 ### Added

diff --git a/src/main/java/com/cognite/client/servicesV1/parser/TransformationJobsParser.java b/src/main/java/com/cognite/client/servicesV1/parser/TransformationJobsParser.java
@@ -74,6 +74,35 @@ public static void extractNodes(Transformation.Job.Builder tmBuilder, JsonNode r
                         builderDest.setExternalId(sequenceRowDataSourceNode.path("externalId").textValue());
                     }
                     tmBuilder.setDestination(builderDest.build());
+                } else if (root.path("destination").path("type").textValue().equals("instances")) {
+                    JsonNode instanceDataSourceNode = root.path("destination");
+                    Transformation.Destination.Builder builderDest = Transformation.Destination.newBuilder();
+
+                    builderDest.setType(instanceDataSourceNode.path("type").textValue());
+
+                    if (instanceDataSourceNode.path("dataModel").isObject()) {
+                        JsonNode dataModelSourceNode = instanceDataSourceNode.path("dataModel");
+                        Transformation.Destination.Datamodel.Builder dataModelBuilderDest = Transformation.Destination.Datamodel.newBuilder();
+                        JsonNode space = dataModelSourceNode.path("space");
+                        JsonNode externalId = dataModelSourceNode.path("externalId");
+                        JsonNode version = dataModelSourceNode.path("version");
+                        JsonNode destinationType = dataModelSourceNode.path("destinationType");
+                        if (space.isTextual())
+                            dataModelBuilderDest.setSpace(space.textValue());
+                        if (externalId.isTextual())
+                            dataModelBuilderDest.setExternalId(externalId.textValue());
+                        if (version.isTextual())
+                            dataModelBuilderDest.setVersion(version.textValue());
+                        if (destinationType.isTextual())
+                            dataModelBuilderDest.setDestinationType(destinationType.textValue());
+
+                        builderDest.setDataModel(dataModelBuilderDest.build());
+                    }
+                    JsonNode instanceSpace = instanceDataSourceNode.path("instanceSpace");
+                    if (instanceSpace.isTextual())
+                        builderDest.setInstanceSpace(instanceSpace.textValue());
+
+                    tmBuilder.setDestination(builderDest.build());
                 }
             }
         }

diff --git a/src/main/proto/transformation.proto b/src/main/proto/transformation.proto
@@ -11,6 +11,14 @@ message Transformation {
 
   message Destination {
 
+    message Datamodel {
+      string space = 1;
+      string external_id = 2;
+      string version = 3;
+      string destination_type = 4;
+      string destination_relationship_from_type = 5;
+    }
+
     enum DataSourceType {
       ASSETS = 0;
       TIMESERIES = 1;
@@ -24,12 +32,15 @@ message Transformation {
       LABELS = 9;
       RELATIONSHIPS = 10;
       DATA_SETS = 11;
+      INSTANCES = 12;
     }
 
     optional string type = 2;
     optional string database = 3;
     optional string table = 4;
     string external_id = 5;
+    optional Datamodel data_model = 6;
+    optional string instance_space = 7;
   }
 
   message FlatOidcCredentials {