Refactor TypedFunction, ObjectProcessor, and ObjectProcessorFunctions

Util/function/build.gradle

@@ -0,0 +1,19 @@
+plugins {
+    id 'java-library'
+    id 'io.deephaven.project.register'
+}
+
+dependencies {
+    api project(':qst-type')
+
+    compileOnly depAnnotations
+
+    Classpaths.inheritJUnitPlatform(project)
+    Classpaths.inheritAssertJ(project)
+    testImplementation 'org.junit.jupiter:junit-jupiter'
+    testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine'
+}
+
+test {
+    useJUnitPlatform()
+}

Util/function/gradle.properties

@@ -0,0 +1 @@
+io.deephaven.project.ProjectType=JAVA_PUBLIC

extensions/protobuf/src/main/java/io/deephaven/functions/BooleanFunctions.java → Util/function/src/main/java/io/deephaven/function/BooleanFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.jetbrains.annotations.NotNull;
 

extensions/protobuf/src/main/java/io/deephaven/functions/ByteFunctions.java → Util/function/src/main/java/io/deephaven/function/ByteFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 import java.util.function.Function;

extensions/protobuf/src/main/java/io/deephaven/functions/CharFunctions.java → Util/function/src/main/java/io/deephaven/function/CharFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 import java.util.function.Function;

extensions/protobuf/src/main/java/io/deephaven/functions/DoubleFunctions.java → Util/function/src/main/java/io/deephaven/function/DoubleFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 import java.util.function.Function;

extensions/protobuf/src/main/java/io/deephaven/functions/FloatFunctions.java → Util/function/src/main/java/io/deephaven/function/FloatFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 import java.util.function.Function;

extensions/protobuf/src/main/java/io/deephaven/functions/IntFunctions.java → Util/function/src/main/java/io/deephaven/function/IntFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 import java.util.function.Function;

extensions/protobuf/src/main/java/io/deephaven/functions/LongFunctions.java → Util/function/src/main/java/io/deephaven/function/LongFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 import java.util.function.Function;

extensions/protobuf/src/main/java/io/deephaven/functions/ObjectFunctions.java → Util/function/src/main/java/io/deephaven/function/ObjectFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.CustomType;
 import io.deephaven.qst.type.GenericType;

extensions/protobuf/src/main/java/io/deephaven/functions/PrimitiveFunctions.java → Util/function/src/main/java/io/deephaven/function/PrimitiveFunctions.java

@@ -1,4 +1,4 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 

extensions/protobuf/src/main/java/io/deephaven/functions/ShortFunctions.java → Util/function/src/main/java/io/deephaven/function/ShortFunctions.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 import java.util.function.Function;

extensions/protobuf/src/main/java/io/deephaven/functions/ToBooleanFunction.java → Util/function/src/main/java/io/deephaven/function/ToBooleanFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.BooleanType;
 import io.deephaven.qst.type.Type;

extensions/protobuf/src/main/java/io/deephaven/functions/ToByteFunction.java → Util/function/src/main/java/io/deephaven/function/ToByteFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.ByteType;
 import io.deephaven.qst.type.Type;

extensions/protobuf/src/main/java/io/deephaven/functions/ToCharFunction.java → Util/function/src/main/java/io/deephaven/function/ToCharFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.CharType;
 import io.deephaven.qst.type.Type;

extensions/protobuf/src/main/java/io/deephaven/functions/ToDoubleFunction.java → Util/function/src/main/java/io/deephaven/function/ToDoubleFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.DoubleType;
 import io.deephaven.qst.type.Type;

extensions/protobuf/src/main/java/io/deephaven/functions/ToFloatFunction.java → Util/function/src/main/java/io/deephaven/function/ToFloatFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.FloatType;
 import io.deephaven.qst.type.Type;

extensions/protobuf/src/main/java/io/deephaven/functions/ToIntFunction.java → Util/function/src/main/java/io/deephaven/function/ToIntFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.IntType;
 import io.deephaven.qst.type.Type;

extensions/protobuf/src/main/java/io/deephaven/functions/ToLongFunction.java → Util/function/src/main/java/io/deephaven/function/ToLongFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.LongType;
 import io.deephaven.qst.type.Type;

extensions/protobuf/src/main/java/io/deephaven/functions/ToObjectFunction.java → Util/function/src/main/java/io/deephaven/function/ToObjectFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.GenericType;
 

extensions/protobuf/src/main/java/io/deephaven/functions/ToPrimitiveFunction.java → Util/function/src/main/java/io/deephaven/function/ToPrimitiveFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.PrimitiveType;
 

extensions/protobuf/src/main/java/io/deephaven/functions/ToShortFunction.java → Util/function/src/main/java/io/deephaven/function/ToShortFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.ShortType;
 import io.deephaven.qst.type.Type;

extensions/protobuf/src/main/java/io/deephaven/functions/TypedFunction.java → Util/function/src/main/java/io/deephaven/function/TypedFunction.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.Type;
 

extensions/protobuf/src/main/java/io/deephaven/functions/TypedFunctions.java → Util/function/src/main/java/io/deephaven/function/TypedFunctions.java

@@ -1,4 +1,4 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import java.util.Objects;
 

extensions/protobuf/src/test/java/io/deephaven/functions/ToBooleanFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToBooleanFunctionTest.java

@@ -1,15 +1,15 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.junit.jupiter.api.Test;
 
 import java.util.List;
 
-import static io.deephaven.functions.ToBooleanFunction.and;
-import static io.deephaven.functions.ToBooleanFunction.map;
-import static io.deephaven.functions.ToBooleanFunction.not;
-import static io.deephaven.functions.ToBooleanFunction.ofFalse;
-import static io.deephaven.functions.ToBooleanFunction.ofTrue;
-import static io.deephaven.functions.ToBooleanFunction.or;
+import static io.deephaven.function.ToBooleanFunction.and;
+import static io.deephaven.function.ToBooleanFunction.map;
+import static io.deephaven.function.ToBooleanFunction.not;
+import static io.deephaven.function.ToBooleanFunction.ofFalse;
+import static io.deephaven.function.ToBooleanFunction.ofTrue;
+import static io.deephaven.function.ToBooleanFunction.or;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToBooleanFunctionTest {

extensions/protobuf/src/test/java/io/deephaven/functions/ToByteFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToByteFunctionTest.java

@@ -1,8 +1,8 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.junit.jupiter.api.Test;
 
-import static io.deephaven.functions.ToByteFunction.map;
+import static io.deephaven.function.ToByteFunction.map;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToByteFunctionTest {

extensions/protobuf/src/test/java/io/deephaven/functions/ToCharFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToCharFunctionTest.java

@@ -1,8 +1,8 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.junit.jupiter.api.Test;
 
-import static io.deephaven.functions.ToCharFunction.map;
+import static io.deephaven.function.ToCharFunction.map;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToCharFunctionTest {

extensions/protobuf/src/test/java/io/deephaven/functions/ToDoubleFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToDoubleFunctionTest.java

@@ -1,8 +1,8 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.junit.jupiter.api.Test;
 
-import static io.deephaven.functions.ToDoubleFunction.map;
+import static io.deephaven.function.ToDoubleFunction.map;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToDoubleFunctionTest {

extensions/protobuf/src/test/java/io/deephaven/functions/ToFloatFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToFloatFunctionTest.java

@@ -1,8 +1,8 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.junit.jupiter.api.Test;
 
-import static io.deephaven.functions.ToFloatFunction.map;
+import static io.deephaven.function.ToFloatFunction.map;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToFloatFunctionTest {

extensions/protobuf/src/test/java/io/deephaven/functions/ToIntFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToIntFunctionTest.java

@@ -1,8 +1,8 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.junit.jupiter.api.Test;
 
-import static io.deephaven.functions.ToIntFunction.map;
+import static io.deephaven.function.ToIntFunction.map;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToIntFunctionTest {

extensions/protobuf/src/test/java/io/deephaven/functions/ToLongFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToLongFunctionTest.java

@@ -1,8 +1,8 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.junit.jupiter.api.Test;
 
-import static io.deephaven.functions.ToLongFunction.map;
+import static io.deephaven.function.ToLongFunction.map;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToLongFunctionTest {

extensions/protobuf/src/test/java/io/deephaven/functions/ToObjectFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToObjectFunctionTest.java

@@ -1,9 +1,9 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import io.deephaven.qst.type.Type;
 import org.junit.jupiter.api.Test;
 
-import static io.deephaven.functions.ToObjectFunction.map;
+import static io.deephaven.function.ToObjectFunction.map;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToObjectFunctionTest {

extensions/protobuf/src/test/java/io/deephaven/functions/ToShortFunctionTest.java → Util/function/src/test/java/io/deephaven/function/ToShortFunctionTest.java

@@ -1,8 +1,8 @@
-package io.deephaven.functions;
+package io.deephaven.function;
 
 import org.junit.jupiter.api.Test;
 
-import static io.deephaven.functions.ToShortFunction.map;
+import static io.deephaven.function.ToShortFunction.map;
 import static org.assertj.core.api.Assertions.assertThat;
 
 public class ToShortFunctionTest {

engine/processor-function/build.gradle

@@ -0,0 +1,21 @@
+plugins {
+    id 'java-library'
+    id 'io.deephaven.project.register'
+}
+
+
+dependencies {
+    api project(':engine-processor')
+    api project(':util-function')
+
+    implementation project(':engine-time')
+
+    Classpaths.inheritJUnitPlatform(project)
+    Classpaths.inheritAssertJ(project)
+    testImplementation 'org.junit.jupiter:junit-jupiter'
+    testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine'
+}
+
+test {
+    useJUnitPlatform()
+}

engine/processor-function/gradle.properties

@@ -0,0 +1 @@
+io.deephaven.project.ProjectType=JAVA_PUBLIC

extensions/kafka/src/main/java/io/deephaven/kafka/ingest/ChunkUtils.java → engine/processor-function/src/main/java/io/deephaven/processor/function/ChunkUtils.java

@@ -1,7 +1,7 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.kafka.ingest;
+package io.deephaven.processor.function;
 
 import io.deephaven.chunk.ObjectChunk;
 import io.deephaven.chunk.WritableBooleanChunk;
@@ -13,18 +13,18 @@
 import io.deephaven.chunk.WritableLongChunk;
 import io.deephaven.chunk.WritableObjectChunk;
 import io.deephaven.chunk.WritableShortChunk;
-import io.deephaven.functions.ToByteFunction;
-import io.deephaven.functions.ToCharFunction;
-import io.deephaven.functions.ToFloatFunction;
-import io.deephaven.functions.ToShortFunction;
+import io.deephaven.function.ToByteFunction;
+import io.deephaven.function.ToCharFunction;
+import io.deephaven.function.ToFloatFunction;
+import io.deephaven.function.ToShortFunction;
 
 import java.util.function.Function;
 import java.util.function.Predicate;
 import java.util.function.ToDoubleFunction;
 import java.util.function.ToIntFunction;
 import java.util.function.ToLongFunction;
 
-public class ChunkUtils {
+final class ChunkUtils {
 
     public static <T> void applyInto(
             Predicate<? super T> booleanFunction,

extensions/kafka/src/main/java/io/deephaven/processor/functions/ObjectProcessorFunctions.java → engine/processor-function/src/main/java/io/deephaven/processor/function/ObjectProcessorFunctions.java

@@ -1,10 +1,10 @@
 /**
  * Copyright (c) 2016-2023 Deephaven Data Labs and Patent Pending
  */
-package io.deephaven.processor.functions;
+package io.deephaven.processor.function;
 
 import io.deephaven.chunk.ObjectChunk;
-import io.deephaven.functions.TypedFunction;
+import io.deephaven.function.TypedFunction;
 import io.deephaven.processor.ObjectProcessor;
 
 import java.util.List;