Introduce type-parameterized array and map APIs; replace wrapper primitive types with Java primitive types

transportable-udfs-annotation-processor/src/main/java/com/linkedin/transport/processor/TransportProcessor.java

@@ -130,10 +130,19 @@ private void processUDFClass(TypeElement udfClassElement) {
           udfClassElement
       );
     } else {
-      String topLevelStdUdfClassName =
-          elementsOverridingTopLevelStdUDFMethods.iterator().next().getQualifiedName().toString();
+      TypeElement topLevelStdUdfTypeElement = elementsOverridingTopLevelStdUDFMethods.iterator().next();
+      String topLevelStdUdfClassName = topLevelStdUdfTypeElement.getQualifiedName().toString();
       debug(String.format("TopLevelStdUDF class found: %s", topLevelStdUdfClassName));
+      String udfClassName = udfClassElement.getQualifiedName().toString();
       _transportUdfMetadata.addUDF(topLevelStdUdfClassName, udfClassElement.getQualifiedName().toString());
+      _transportUdfMetadata.setClassNumberOfTypeParameters(
+          topLevelStdUdfClassName,
+          topLevelStdUdfTypeElement.getTypeParameters().size()
+      );
+      _transportUdfMetadata.setClassNumberOfTypeParameters(
+          udfClassName,
+          udfClassElement.getTypeParameters().size()
+      );
     }
   }
 

transportable-udfs-annotation-processor/src/test/java/com/linkedin/transport/processor/TransportProcessorTest.java

@@ -81,7 +81,7 @@ public void shouldNotContainMultipleOverridingsOfTopLevelStdUDFMethods1() throws
         .withErrorCount(1)
         .withErrorContaining(Constants.MORE_THAN_ONE_TYPE_OVERRIDING_ERROR)
         .in(forResource("udfs/UDFWithMultipleInterfaces1.java"))
-        .onLine(14)
+        .onLine(13)
         .atColumn(8);
   }
 
@@ -96,7 +96,7 @@ public void shouldNotContainMultipleOverridingsOfTopLevelStdUDFMethods2() throws
         .withErrorCount(1)
         .withErrorContaining(Constants.MORE_THAN_ONE_TYPE_OVERRIDING_ERROR)
         .in(forResource("udfs/UDFWithMultipleInterfaces2.java"))
-        .onLine(13)
+        .onLine(12)
         .atColumn(8);
   }
 
@@ -110,7 +110,7 @@ public void udfShouldNotOverrideInterfaceMethods() throws IOException {
         .withErrorCount(1)
         .withErrorContaining(Constants.MORE_THAN_ONE_TYPE_OVERRIDING_ERROR)
         .in(forResource("udfs/UDFOverridingInterfaceMethod.java"))
-        .onLine(14)
+        .onLine(13)
         .atColumn(8);
   }
 
@@ -123,7 +123,7 @@ public void udfShouldImplementTopLevelStdUDF() throws IOException {
         .withErrorCount(1)
         .withErrorContaining(Constants.INTERFACE_NOT_IMPLEMENTED_ERROR)
         .in(forResource("udfs/UDFNotImplementingTopLevelStdUDF.java"))
-        .onLine(14)
+        .onLine(13)
         .atColumn(8);
   }
 

transportable-udfs-annotation-processor/src/test/resources/outputs/empty.json

@@ -1,3 +1,4 @@
 {
-  "udfs": []
+  "udfs": {},
+  "classToNumberOfTypeParameters": {}
 }

transportable-udfs-annotation-processor/src/test/resources/outputs/overloadedUDF.json

@@ -1,11 +1,13 @@
 {
-  "udfs": [
-    {
-      "topLevelClass": "udfs.OverloadedUDF1",
-      "stdUDFImplementations": [
-        "udfs.OverloadedUDFInt",
-        "udfs.OverloadedUDFString"
-      ]
-    }
-  ]
+  "udfs": {
+    "udfs.OverloadedUDF1": [
+      "udfs.OverloadedUDFInt",
+      "udfs.OverloadedUDFString"
+    ]
+  },
+  "classToNumberOfTypeParameters": {
+    "udfs.OverloadedUDFString": 0,
+    "udfs.OverloadedUDF1": 0,
+    "udfs.OverloadedUDFInt": 0
+  }
 }

transportable-udfs-annotation-processor/src/test/resources/outputs/simpleUDF.json

@@ -1,10 +1,10 @@
 {
-  "udfs": [
-    {
-      "topLevelClass": "udfs.SimpleUDF",
-      "stdUDFImplementations": [
-        "udfs.SimpleUDF"
-      ]
-    }
-  ]
+  "udfs": {
+    "udfs.SimpleUDF": [
+      "udfs.SimpleUDF"
+    ]
+  },
+  "classToNumberOfTypeParameters": {
+    "udfs.SimpleUDF": 0
+  }
 }

transportable-udfs-annotation-processor/src/test/resources/outputs/udfExtendingAbstractUDF.json

@@ -1,10 +1,10 @@
 {
-  "udfs": [
-    {
-      "topLevelClass": "udfs.UDFExtendingAbstractUDF",
-      "stdUDFImplementations": [
-        "udfs.UDFExtendingAbstractUDF"
-      ]
-    }
-  ]
+  "udfs": {
+    "udfs.UDFExtendingAbstractUDF": [
+      "udfs.UDFExtendingAbstractUDF"
+    ]
+  },
+  "classToNumberOfTypeParameters": {
+    "udfs.UDFExtendingAbstractUDF": 0
+  }
 }

transportable-udfs-annotation-processor/src/test/resources/outputs/udfExtendingAbstractUDFImplementingInterface.json

@@ -1,10 +1,11 @@
 {
-  "udfs": [
-    {
-      "topLevelClass": "udfs.AbstractUDFImplementingInterface",
-      "stdUDFImplementations": [
-        "udfs.UDFExtendingAbstractUDFImplementingInterface"
-      ]
-    }
-  ]
+  "udfs": {
+    "udfs.AbstractUDFImplementingInterface": [
+      "udfs.UDFExtendingAbstractUDFImplementingInterface"
+    ]
+  },
+  "classToNumberOfTypeParameters": {
+    "udfs.UDFExtendingAbstractUDFImplementingInterface": 0,
+    "udfs.AbstractUDFImplementingInterface": 0
+  }
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/AbstractUDF.java

@@ -5,11 +5,10 @@
  */
 package udfs;
 
-import com.linkedin.transport.api.data.StdString;
 import com.linkedin.transport.api.udf.StdUDF0;
 import com.linkedin.transport.api.udf.TopLevelStdUDF;
 
 
-public abstract class AbstractUDF extends StdUDF0<StdString> implements TopLevelStdUDF {
+public abstract class AbstractUDF extends StdUDF0<String> implements TopLevelStdUDF {
 
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/AbstractUDFImplementingInterface.java

@@ -5,12 +5,11 @@
  */
 package udfs;
 
-import com.linkedin.transport.api.data.StdString;
 import com.linkedin.transport.api.udf.StdUDF0;
 import com.linkedin.transport.api.udf.TopLevelStdUDF;
 
 
-public abstract class AbstractUDFImplementingInterface extends StdUDF0<StdString> implements TopLevelStdUDF {
+public abstract class AbstractUDFImplementingInterface extends StdUDF0<String> implements TopLevelStdUDF {
 
   @Override
   public String getFunctionName() {

transportable-udfs-annotation-processor/src/test/resources/udfs/OuterClassForInnerUDF.java

@@ -6,14 +6,13 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdString;
 import com.linkedin.transport.api.udf.StdUDF0;
 import com.linkedin.transport.api.udf.TopLevelStdUDF;
 import java.util.List;
 
 
 public class OuterClassForInnerUDF {
-  public class InnerUDF extends StdUDF0<StdString> implements TopLevelStdUDF {
+  public class InnerUDF extends StdUDF0<String> implements TopLevelStdUDF {
 
     @Override
     public String getFunctionName() {
@@ -36,7 +35,7 @@ public String getOutputParameterSignature() {
     }
 
     @Override
-    public StdString eval() {
+    public String eval() {
       return null;
     }
   }

transportable-udfs-annotation-processor/src/test/resources/udfs/OverloadedUDFInt.java

@@ -6,12 +6,11 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdInteger;
 import com.linkedin.transport.api.udf.StdUDF0;
 import java.util.List;
 
 
-public class OverloadedUDFInt extends StdUDF0<StdInteger> implements OverloadedUDF1 {
+public class OverloadedUDFInt extends StdUDF0<Integer> implements OverloadedUDF1 {
 
   @Override
   public List<String> getInputParameterSignatures() {
@@ -24,7 +23,7 @@ public String getOutputParameterSignature() {
   }
 
   @Override
-  public StdInteger eval() {
+  public Integer eval() {
     return null;
   }
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/OverloadedUDFString.java

@@ -6,12 +6,11 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdString;
 import com.linkedin.transport.api.udf.StdUDF0;
 import java.util.List;
 
 
-public class OverloadedUDFString extends StdUDF0<StdString> implements OverloadedUDF1 {
+public class OverloadedUDFString extends StdUDF0<String> implements OverloadedUDF1 {
 
   @Override
   public List<String> getInputParameterSignatures() {
@@ -24,7 +23,7 @@ public String getOutputParameterSignature() {
   }
 
   @Override
-  public StdString eval() {
+  public String eval() {
     return null;
   }
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/SimpleUDF.java

@@ -6,13 +6,12 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdString;
 import com.linkedin.transport.api.udf.StdUDF0;
 import com.linkedin.transport.api.udf.TopLevelStdUDF;
 import java.util.List;
 
 
-public class SimpleUDF extends StdUDF0<StdString> implements TopLevelStdUDF {
+public class SimpleUDF extends StdUDF0<String> implements TopLevelStdUDF {
 
   @Override
   public String getFunctionName() {
@@ -35,7 +34,7 @@ public String getOutputParameterSignature() {
   }
 
   @Override
-  public StdString eval() {
+  public String eval() {
     return null;
   }
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/UDFExtendingAbstractUDF.java

@@ -6,7 +6,6 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdString;
 import com.linkedin.transport.api.udf.TopLevelStdUDF;
 import java.util.List;
 
@@ -34,7 +33,7 @@ public String getOutputParameterSignature() {
   }
 
   @Override
-  public StdString eval() {
+  public String eval() {
     return null;
   }
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/UDFExtendingAbstractUDFImplementingInterface.java

@@ -6,7 +6,6 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdString;
 import java.util.List;
 
 
@@ -23,7 +22,7 @@ public String getOutputParameterSignature() {
   }
 
   @Override
-  public StdString eval() {
+  public String eval() {
     return null;
   }
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/UDFNotImplementingTopLevelStdUDF.java

@@ -6,12 +6,11 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdString;
 import com.linkedin.transport.api.udf.StdUDF0;
 import java.util.List;
 
 
-public class UDFNotImplementingTopLevelStdUDF extends StdUDF0<StdString> {
+public class UDFNotImplementingTopLevelStdUDF extends StdUDF0<String> {
 
   @Override
   public List<String> getInputParameterSignatures() {
@@ -24,7 +23,7 @@ public String getOutputParameterSignature() {
   }
 
   @Override
-  public StdString eval() {
+  public String eval() {
     return null;
   }
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/UDFOverridingInterfaceMethod.java

@@ -6,12 +6,11 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdBoolean;
 import com.linkedin.transport.api.udf.StdUDF0;
 import java.util.List;
 
 
-public class UDFOverridingInterfaceMethod extends StdUDF0<StdBoolean> implements OverloadedUDF1 {
+public class UDFOverridingInterfaceMethod extends StdUDF0<Boolean> implements OverloadedUDF1 {
 
   @Override
   public String getFunctionName() {
@@ -29,7 +28,7 @@ public String getOutputParameterSignature() {
   }
 
   @Override
-  public StdBoolean eval() {
+  public Boolean eval() {
     return null;
   }
 }

transportable-udfs-annotation-processor/src/test/resources/udfs/UDFWithMultipleInterfaces1.java

@@ -6,12 +6,11 @@
 package udfs;
 
 import com.google.common.collect.ImmutableList;
-import com.linkedin.transport.api.data.StdBoolean;
 import com.linkedin.transport.api.udf.StdUDF0;
 import java.util.List;
 
 
-public class UDFWithMultipleInterfaces1 extends StdUDF0<StdBoolean> implements OverloadedUDF1, OverloadedUDF2 {
+public class UDFWithMultipleInterfaces1 extends StdUDF0<Boolean> implements OverloadedUDF1, OverloadedUDF2 {
 
   @Override
   public String getFunctionName() {
@@ -34,7 +33,7 @@ public String getOutputParameterSignature() {
   }
 
   @Override
-  public StdBoolean eval() {
+  public Boolean eval() {
     return null;
   }
 }