Merge branch 'main' into my-astra-schema-examples

.github/workflows/preview.yml

@@ -79,7 +79,7 @@ jobs:
           password: ${{ secrets.DOCKER_PASSWORD }}
 
       - name: docker test build
-        uses: docker/build-push-action@v5.3.0
+        uses: docker/build-push-action@v6.2.0
         with:
           context: .
           file: Dockerfile
@@ -130,7 +130,7 @@ jobs:
           scripts/bump-minor-version
 
       - name: docker push to hub
-        uses: docker/build-push-action@v5.3.0
+        uses: docker/build-push-action@v6.2.0
         with:
           context: .
           platforms: linux/amd64,linux/arm64
@@ -141,7 +141,7 @@ jobs:
 
       #  https://github.com/softprops/action-gh-release
       - name: create github release
-        uses: softprops/action-gh-release@v2.0.5
+        uses: softprops/action-gh-release@v2.0.6
         if: startsWith(github.ref, 'refs/tags/')
         with:
 #          body: ${{ steps.prepare_summary.outputs.release_summary }}

.github/workflows/release.yml

@@ -74,7 +74,7 @@ jobs:
           password: ${{ secrets.DOCKER_PASSWORD }}
 
       - name: docker test build
-        uses: docker/build-push-action@v5.3.0
+        uses: docker/build-push-action@v6.2.0
         with:
           context: .
           file: Dockerfile
@@ -115,7 +115,7 @@ jobs:
           scripts/bump-minor-version
 
       - name: docker push to hub
-        uses: docker/build-push-action@v5.3.0
+        uses: docker/build-push-action@v6.2.0
         with:
           context: .
           platforms: linux/amd64,linux/arm64
@@ -126,7 +126,7 @@ jobs:
 
       #  https://github.com/softprops/action-gh-release
       - name: create github release
-        uses: softprops/action-gh-release@v2.0.5
+        uses: softprops/action-gh-release@v2.0.6
         if: startsWith(github.ref, 'refs/tags/')
         with:
           #          body: ${{ steps.prepare_summary.outputs.release_summary }}

nb-adapters/adapter-cqld4/src/main/java/io/nosqlbench/datamappers/functions/to_cqlvector/from_string/CSVToCqlFloatVector.java

@@ -0,0 +1,42 @@
+package io.nosqlbench.datamappers.functions.to_cqlvector.from_string;
+
+/*
+ * Copyright (c) 2022 nosqlbench
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+import com.datastax.oss.driver.api.core.data.CqlVector;
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.function.Function;
+
+@ThreadSafeMapper
+@Categories(Category.conversion)
+public class CSVToCqlFloatVector implements Function<String, CqlVector<Float>> {
+    @Override
+    public CqlVector<Float> apply(String s) {
+        String[] split = s.split(",");
+        List<Float> floats = new ArrayList<>(split.length);
+        for (String string : split) {
+            floats.add(Float.parseFloat(string));
+        }
+        return com.datastax.oss.driver.api.core.data.CqlVector.newInstance(floats);
+    }
+}

nb-virtdata/virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/conversions/from_string/FromCSVToBoxedDoubleArray.java

@@ -0,0 +1,40 @@
+package io.nosqlbench.virtdata.library.basics.shared.conversions.from_string;
+
+/*
+ * Copyright (c) 2022 nosqlbench
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+
+import java.util.function.Function;
+
+@ThreadSafeMapper
+@Categories(Category.conversion)
+public class FromCSVToBoxedDoubleArray implements Function<String,Double[]> {
+
+    @Override
+    public Double[] apply(String s) {
+        String[] split = s.split(",");
+        Double[] doubles = new Double[split.length];
+        for (int i = 0; i < split.length; i++) {
+            doubles[i] = Double.parseDouble(split[i]);
+        }
+        return doubles;
+    }
+}

nb-virtdata/virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/conversions/from_string/FromCSVToBoxedFloatArray.java

@@ -0,0 +1,40 @@
+package io.nosqlbench.virtdata.library.basics.shared.conversions.from_string;
+
+/*
+ * Copyright (c) 2022 nosqlbench
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+
+import java.util.function.Function;
+
+@ThreadSafeMapper
+@Categories(Category.conversion)
+public class FromCSVToBoxedFloatArray implements Function<String,Float[]> {
+
+    @Override
+    public Float[] apply(String s) {
+        String[] split = s.split(",");
+        Float[] floats = new Float[split.length];
+        for (int i = 0; i < split.length; i++) {
+            floats[i] = Float.parseFloat(split[i]);
+        }
+        return floats;
+    }
+}

nb-virtdata/virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/conversions/from_string/FromCSVToPrimitiveDoubleArray.java

@@ -0,0 +1,40 @@
+package io.nosqlbench.virtdata.library.basics.shared.conversions.from_string;
+
+/*
+ * Copyright (c) 2022 nosqlbench
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+
+import java.util.function.Function;
+
+@ThreadSafeMapper
+@Categories(Category.conversion)
+public class FromCSVToPrimitiveDoubleArray implements Function<String,double[]> {
+
+    @Override
+    public double[] apply(String s) {
+        String[] split = s.split(",");
+        double[] doubles = new double[split.length];
+        for (int i = 0; i < split.length; i++) {
+            doubles[i] = Double.parseDouble(split[i]);
+        }
+        return doubles;
+    }
+}

nb-virtdata/virtdata-lib-basics/src/main/java/io/nosqlbench/virtdata/library/basics/shared/conversions/from_string/FromCSVToPrimitiveFloatArray.java

@@ -0,0 +1,40 @@
+package io.nosqlbench.virtdata.library.basics.shared.conversions.from_string;
+
+/*
+ * Copyright (c) 2022 nosqlbench
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+import io.nosqlbench.virtdata.api.annotations.Categories;
+import io.nosqlbench.virtdata.api.annotations.Category;
+import io.nosqlbench.virtdata.api.annotations.ThreadSafeMapper;
+
+import java.util.function.Function;
+
+@ThreadSafeMapper
+@Categories(Category.conversion)
+public class FromCSVToPrimitiveFloatArray implements Function<String,float[]> {
+
+    @Override
+    public float[] apply(String s) {
+        String[] split = s.split(",");
+        float[] floats = new float[split.length];
+        for (int i = 0; i < split.length; i++) {
+            floats[i] = Float.parseFloat(split[i]);
+        }
+        return floats;
+    }
+}