Add Attribute Type Checking for Sentiment, Aggregation, Hash Join Operators in Front-End

core/amber/src/main/scala/edu/uci/ics/texera/workflow/operators/aggregate/AggregationOperation.scala

@@ -1,7 +1,7 @@
 package edu.uci.ics.texera.workflow.operators.aggregate
 
 import com.fasterxml.jackson.annotation.{JsonIgnore, JsonProperty, JsonPropertyDescription}
-import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaTitle
+import com.kjetland.jackson.jsonSchema.annotations.{JsonSchemaInject, JsonSchemaTitle}
 import edu.uci.ics.texera.workflow.common.metadata.annotations.AutofillAttributeName
 import edu.uci.ics.texera.workflow.common.operators.aggregate.DistributedAggregation
 import edu.uci.ics.texera.workflow.common.tuple.Tuple
@@ -10,8 +10,38 @@ import edu.uci.ics.texera.workflow.common.tuple.schema.{Attribute, AttributeType
 
 import java.sql.Timestamp
 
+@JsonSchemaInject(json =
+  """
+{
+  "attributeType": {
+    "0:attribute": {
+      "allOf": [
+        {
+          "if": {
+            "aggFunction": {
+              "valEnum": ["sum", "average", "min", "max"]
+            }
+          },
+          "then": {
+            "enum": ["integer", "long", "double"]
+          }
+        },
+        {
+          "if": {
+            "aggFunction": {
+              "valEnum": ["concat"]
+            }
+          },
+          "then": {
+            "enum": ["string"]
+          }
+        }
+      ]
+    }
+  }
+}
+""")
 class AggregationOperation() {
-
   @JsonProperty(required = true)
   @JsonSchemaTitle("Aggregation Function")
   @JsonPropertyDescription("sum, count, average, min, max, or concat")

core/amber/src/main/scala/edu/uci/ics/texera/workflow/operators/hashJoin/HashJoinOpDesc.scala

@@ -2,24 +2,29 @@ package edu.uci.ics.texera.workflow.operators.hashJoin
 
 import com.fasterxml.jackson.annotation.{JsonProperty, JsonPropertyDescription}
 import com.google.common.base.Preconditions
-import com.kjetland.jackson.jsonSchema.annotations.JsonSchemaTitle
+import com.kjetland.jackson.jsonSchema.annotations.{JsonSchemaInject, JsonSchemaTitle}
 import edu.uci.ics.amber.engine.architecture.deploysemantics.layer.OpExecConfig
-import edu.uci.ics.texera.workflow.common.metadata.annotations.{
-  AutofillAttributeName,
-  AutofillAttributeNameOnPort1
-}
-import edu.uci.ics.texera.workflow.common.metadata.{
-  InputPort,
-  OperatorGroupConstants,
-  OperatorInfo,
-  OutputPort
-}
+import edu.uci.ics.texera.workflow.common.metadata.annotations.{AutofillAttributeName, AutofillAttributeNameOnPort1}
+import edu.uci.ics.texera.workflow.common.metadata.{InputPort, OperatorGroupConstants, OperatorInfo, OutputPort}
 import edu.uci.ics.texera.workflow.common.operators.OperatorDescriptor
 import edu.uci.ics.texera.workflow.common.tuple.schema.{Attribute, OperatorSchemaInfo, Schema}
 import edu.uci.ics.texera.workflow.common.workflow.{HashPartition, PartitionInfo}
 
 import scala.collection.convert.ImplicitConversions.`collection AsScalaIterable`
 
+@JsonSchemaInject(json =
+"""
+{
+  "attributeType": {
+    "0:buildAttributeName": {
+      "const": {
+        "$data": "1:probeAttributeName"
+      }
+    }
+  }
+}
+"""
+)
 class HashJoinOpDesc[K] extends OperatorDescriptor {
 
   @JsonProperty(required = true)

core/amber/src/main/scala/edu/uci/ics/texera/workflow/operators/sentiment/SentimentAnalysisOpDesc.scala

@@ -1,15 +1,11 @@
 package edu.uci.ics.texera.workflow.operators.sentiment
 
-import com.fasterxml.jackson.annotation.{JsonProperty, JsonPropertyDescription}
+import com.fasterxml.jackson.annotation.{JacksonAnnotationsInside, JsonProperty, JsonPropertyDescription}
 import com.google.common.base.Preconditions
+import com.kjetland.jackson.jsonSchema.annotations.{JsonSchemaInject, JsonSchemaString}
 import edu.uci.ics.amber.engine.architecture.deploysemantics.layer.OpExecConfig
 import edu.uci.ics.amber.engine.common.Constants
-import edu.uci.ics.texera.workflow.common.metadata.{
-  InputPort,
-  OperatorGroupConstants,
-  OperatorInfo,
-  OutputPort
-}
+import edu.uci.ics.texera.workflow.common.metadata.{InputPort, OperatorGroupConstants, OperatorInfo, OutputPort}
 import edu.uci.ics.texera.workflow.common.metadata.annotations.AutofillAttributeName
 import edu.uci.ics.texera.workflow.common.operators.map.MapOpDesc
 import edu.uci.ics.texera.workflow.common.tuple.schema.{AttributeType, OperatorSchemaInfo, Schema}
@@ -18,6 +14,17 @@ import java.util.Collections
 import java.util.Collections.singletonList
 import scala.collection.JavaConverters.{asScalaBuffer, mapAsScalaMap}
 
+@JsonSchemaInject(json =
+"""
+{
+  "attributeType": {
+    "0:attribute": {
+      "enum": ["string"]
+    }
+  }
+}
+"""
+)
 class SentimentAnalysisOpDesc extends MapOpDesc {
   @JsonProperty(value = "attribute", required = true)
   @JsonPropertyDescription("column to perform sentiment analysis on")

core/new-gui/src/app/common/formly/formly-utils.ts

@@ -1,6 +1,9 @@
 import { FormlyFieldConfig } from "@ngx-formly/core";
 import { isDefined } from "../util/predicate";
-import { SchemaAttribute } from "../../workspace/service/dynamic-schema/schema-propagation/schema-propagation.service";
+import {
+  PortInputSchema,
+  SchemaAttribute
+} from "../../workspace/service/dynamic-schema/schema-propagation/schema-propagation.service";
 import { Observable } from "rxjs";
 import { FORM_DEBOUNCE_TIME_MS } from "../../workspace/service/execute-workflow/execute-workflow.service";
 import { debounceTime, distinctUntilChanged, filter, share } from "rxjs/operators";
@@ -53,7 +56,7 @@ export function createShouldHideFieldFunc(
 }
 
 export function setChildTypeDependency(
-  attributes: ReadonlyArray<ReadonlyArray<SchemaAttribute> | null> | undefined,
+  attributes: ReadonlyArray<PortInputSchema | undefined> | undefined,
   parentName: string,
   fields: FormlyFieldConfig[],
   childName: string

core/new-gui/src/app/workspace/component/property-editor/operator-property-edit-frame/operator-property-edit-frame.component.scss

@@ -21,3 +21,14 @@
   font-size: 0.5em;
   color: gray;
 }
+
+::ng-deep {
+  // overwrite the color of the error message box
+  .texera-workspace-property-editor-form {
+    [role="alert"] {
+        color: #0c5460;
+        background-color: #d1ecf1;
+        border-color: #bee5eb;
+    }
+  }
+}