raphaeldelio

package valid;

import com.redis.om.spring.annotations.Indexed;
import com.redis.om.spring.annotations.NumericIndexed;
import com.redis.om.spring.annotations.Searchable;
import lombok.Data;
import lombok.NonNull;
import lombok.RequiredArgsConstructor;

@Data

raphaeldelio

import redis.clients.jedis.*;

import java.util.ArrayList;
import java.util.List;

public class RedisStringBenchmarkTest {

    static final int NUM_OBJECTS = 100_000;
    static final int OBJECT_SIZE = 50000; // bytes
    static final int BATCH_SIZE = 10_000; // control how many commands per pipeline execution

raphaeldelio

raphaeldelio

raphaeldelio

package dev.raphaeldelio;
import ai.djl.Model;
import ai.djl.basicdataset.cv.classification.ImageFolder;
import ai.djl.engine.Engine;
import ai.djl.modality.cv.transform.*;
import ai.djl.ndarray.NDList;
import ai.djl.ndarray.types.Shape;
import ai.djl.nn.Block;
import ai.djl.nn.Parameter;
import ai.djl.nn.SequentialBlock;

raphaeldelio

data class Product(
    @Indexed
    val name: String,

    @Indexed
    val price: Double
)

raphaeldelio

@Document
data class Store(
    @Id
    @Indexed
    var id: String? = null,

    @Indexed
    var name: String,

    @Searchable

raphaeldelio

import org.jetbrains.kotlin.gradle.tasks.KotlinCompile

plugins {
    id("org.springframework.boot") version "2.7.1"
    id("io.spring.dependency-management") version "1.0.11.RELEASE"
    kotlin("jvm") version "1.6.21"
    kotlin("plugin.spring") version "1.6.21"
}

group = "com.raphaeldelio"

raphaeldelio

data class Product(
    @Indexed
    val name: String,

    @Indexed
    val price: Double
)

raphaeldelio

spring:
  cloud:
    gcp:
      pubsub:
        emulator-host: "localhost:8085" # Telling Spring to connect to this PubSub host and port
    stream:
      poller:
        fixed-delay: 5000 # limiting the number of messages that will be generated by the supplier to one every five seconds
      function:
        definition: sumNumbers;generateNumbers #functions bound to Spring Cloud Stream