Relocate packages to better organize sources

Signed-off-by: Marvin Froeder <marvin@datasqrl.com>

Author: velo

connectors/postgresql-connector/src/main/java/com/datasqrl/vector/PostgresVectorTypeSerializer.java renamed to connectors/postgresql-connector/src/main/java/com/datasqrl/connector/postgresql/type/PostgresVectorTypeSerializer.java

@@ -13,9 +13,8 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.connector.postgresql.type;
 
-import com.datasqrl.connector.postgresql.type.JdbcTypeSerializer;
 import com.datasqrl.connector.postgresql.type.JdbcTypeSerializer.GenericDeserializationConverter;
 import com.datasqrl.connector.postgresql.type.JdbcTypeSerializer.GenericSerializationConverter;
 import com.datasqrl.types.vector.FlinkVectorType;

connectors/postgresql-connector/src/main/resources/META-INF/services/com.datasqrl.connector.postgresql.type.JdbcTypeSerializer

@@ -1,2 +1,3 @@
 com.datasqrl.connector.postgresql.type.PostgresRowTypeSerializer
-com.datasqrl.connector.postgresql.type.PostgresJsonTypeSerializer
+com.datasqrl.connector.postgresql.type.PostgresJsonTypeSerializer
+com.datasqrl.connector.postgresql.type.PostgresVectorTypeSerializer

connectors/postgresql-connector/src/test/java/com/datasqrl/connector/postgresql/jdbc/FlinkJdbcTest.java

@@ -102,7 +102,7 @@ public void testFlinkWithPostgres() throws Exception {
 
       // Register tables in the environment
       tableEnv.executeSql(
-          "CREATE TEMPORARY FUNCTION IF NOT EXISTS `tojson` AS 'com.datasqrl.json.ToJson' LANGUAGE JAVA");
+          "CREATE TEMPORARY FUNCTION IF NOT EXISTS `tojson` AS 'com.datasqrl.types.json.functions.ToJson' LANGUAGE JAVA");
       tableEnv.executeSql(createSourceTable);
       tableEnv.executeSql(createSinkTable);
 

types/json-type/src/main/java/com/datasqrl/json/ArrayAgg.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/ArrayAgg.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import java.util.List;
 import lombok.Value;

types/json-type/src/main/java/com/datasqrl/json/JsonArray.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonArray.java

@@ -13,10 +13,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
-import static com.datasqrl.json.JsonFunctions.createJsonArgumentTypeStrategy;
-import static com.datasqrl.json.JsonFunctions.createJsonType;
+import static com.datasqrl.types.json.functions.JsonFunctions.createJsonArgumentTypeStrategy;
+import static com.datasqrl.types.json.functions.JsonFunctions.createJsonType;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.json.FlinkJsonType;

types/json-type/src/main/java/com/datasqrl/json/JsonArrayAgg.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonArrayAgg.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.types.json.FlinkJsonType;
 import java.util.ArrayList;

types/json-type/src/main/java/com/datasqrl/json/JsonConcat.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonConcat.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.json.FlinkJsonType;

types/json-type/src/main/java/com/datasqrl/json/JsonExists.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonExists.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.json.FlinkJsonType;

types/json-type/src/main/java/com/datasqrl/json/JsonExtract.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonExtract.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.json.FlinkJsonType;

types/json-type/src/main/java/com/datasqrl/json/JsonFunctions.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonFunctions.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.types.json.FlinkJsonType;
 import org.apache.flink.table.api.DataTypes;

types/json-type/src/main/java/com/datasqrl/json/JsonObject.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonObject.java

@@ -13,9 +13,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
-import static com.datasqrl.json.JsonFunctions.createJsonArgumentTypeStrategy;
+import static com.datasqrl.types.json.functions.JsonFunctions.createJsonArgumentTypeStrategy;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.json.FlinkJsonType;

types/json-type/src/main/java/com/datasqrl/json/JsonObjectAgg.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonObjectAgg.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.types.json.FlinkJsonType;
 import com.datasqrl.types.json.FlinkJsonTypeSerializer;

types/json-type/src/main/java/com/datasqrl/json/JsonQuery.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonQuery.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.json.FlinkJsonType;

types/json-type/src/main/java/com/datasqrl/json/JsonToString.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/JsonToString.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.json.FlinkJsonType;

types/json-type/src/main/java/com/datasqrl/json/ObjectAgg.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/ObjectAgg.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import java.util.Map;
 import lombok.Getter;

types/json-type/src/main/java/com/datasqrl/json/ToJson.java renamed to types/json-type/src/main/java/com/datasqrl/types/json/functions/ToJson.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.json;
+package com.datasqrl.types.json.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.json.FlinkJsonType;

types/json-type/src/test/java/com/datasqrl/json/JsonFunctionsTest.java

@@ -23,6 +23,9 @@
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
 import com.datasqrl.types.json.FlinkJsonType;
+import com.datasqrl.types.json.functions.ArrayAgg;
+import com.datasqrl.types.json.functions.JsonFunctions;
+import com.datasqrl.types.json.functions.ObjectAgg;
 import lombok.SneakyThrows;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.JsonNode;
 import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper;

types/vector-type/src/main/java/com/datasqrl/vector/AsciiTextTestEmbed.java renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/AsciiTextTestEmbed.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.vector.FlinkVectorType;

types/vector-type/src/main/java/com/datasqrl/vector/Center.java renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/Center.java

@@ -13,10 +13,10 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
-import static com.datasqrl.vector.VectorFunctions.VEC_TO_DOUBLE;
-import static com.datasqrl.vector.VectorFunctions.convert;
+import static com.datasqrl.types.vector.functions.VectorFunctions.VEC_TO_DOUBLE;
+import static com.datasqrl.types.vector.functions.VectorFunctions.convert;
 
 import com.datasqrl.types.vector.FlinkVectorType;
 import org.apache.flink.table.functions.AggregateFunction;

types/vector-type/src/main/java/com/datasqrl/vector/CenterAccumulator.java renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/CenterAccumulator.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
 // import com.google.common.base.Preconditions;
 

types/vector-type/src/main/java/com/datasqrl/vector/CosineDistance.java renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/CosineDistance.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
 import com.datasqrl.types.vector.FlinkVectorType;
 

types/vector-type/src/main/java/com/datasqrl/vector/CosineSimilarity.java renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/CosineSimilarity.java

@@ -13,9 +13,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
-import static com.datasqrl.vector.VectorFunctions.VEC_TO_DOUBLE;
+import static com.datasqrl.types.vector.functions.VectorFunctions.VEC_TO_DOUBLE;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.vector.FlinkVectorType;

types/vector-type/src/main/java/com/datasqrl/vector/DoubleToVector.java renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/DoubleToVector.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.vector.FlinkVectorType;

types/vector-type/src/main/java/com/datasqrl/vector/EuclideanDistance.java renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/EuclideanDistance.java

@@ -13,9 +13,9 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
-import static com.datasqrl.vector.VectorFunctions.VEC_TO_DOUBLE;
+import static com.datasqrl.types.vector.functions.VectorFunctions.VEC_TO_DOUBLE;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.vector.FlinkVectorType;

types/vector-type/src/main/java/com/datasqrl/vector/README.md renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/README.md

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
 import com.datasqrl.types.vector.FlinkVectorType;
 import java.util.Set;

types/vector-type/src/main/java/com/datasqrl/vector/VectorFunctions.java renamed to types/vector-type/src/main/java/com/datasqrl/types/vector/functions/VectorFunctions.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package com.datasqrl.vector;
+package com.datasqrl.types.vector.functions;
 
 import com.datasqrl.function.AutoRegisterSystemFunction;
 import com.datasqrl.types.vector.FlinkVectorType;