Using bulk APIs/calls on entities during saveAll (#552)

* Using bulk APIs/calls on entities during saveAll

* Cleaning up DefaultEmbedder

* Adding batch size prop

Author: raphaeldelio

redis-om-spring/src/main/java/com/redis/om/spring/RedisOMAiProperties.java

@@ -14,6 +14,7 @@
 )
 public class RedisOMAiProperties {
   private boolean enabled = false;
+  private int embeddingBatchSize = 1000;
   private final Djl djl = new Djl();
   private final Transformers transformers = new Transformers();
   private final OpenAi openAi = new OpenAi();
@@ -63,7 +64,15 @@ public Ollama getOllama() {
     return ollama;
   }
 
-  // Transformer properties
+    public int getEmbeddingBatchSize() {
+        return embeddingBatchSize;
+    }
+
+    public void setEmbeddingBatchSize(int embeddingBatchSize) {
+        this.embeddingBatchSize = embeddingBatchSize;
+    }
+
+    // Transformer properties
   public static class Transformers {
     private String tokenizerResource;
     private String modelResource;
@@ -87,7 +96,6 @@ public Map<String, String> getTokenizerOptions() {
     }
   }
 
-  // DJL properties
   public static class Djl {
     private static final String DEFAULT_ENGINE = "PyTorch";
     // image embedding settings

redis-om-spring/src/main/java/com/redis/om/spring/repository/support/SimpleRedisDocumentRepository.java

@@ -185,6 +185,8 @@ public <S extends T> List<S> saveAll(Iterable<S> entities) {
     List<S> saved = new ArrayList<>();
     List<Object> entityIds = new ArrayList<>();
 
+    embedder.processEntities(entities);
+
     try (Jedis jedis = modulesOperations.client().getJedis().get()) {
       Pipeline pipeline = jedis.pipelined();
       Gson gson = gsonBuilder.create();
@@ -209,7 +211,6 @@ public <S extends T> List<S> saveAll(Iterable<S> entities) {
 
         // process entity pre-save mutation
         auditor.processEntity(entity, isNew);
-        embedder.processEntity(entity);
 
         Optional<Long> maybeTtl = getTTLForEntity(entity);
 

redis-om-spring/src/main/java/com/redis/om/spring/repository/support/SimpleRedisEnhancedRepository.java

@@ -360,6 +360,8 @@ public <S extends T> List<S> saveAll(Iterable<S> entities) {
     Assert.notNull(entities, "The given Iterable of entities must not be null!");
     List<S> saved = new ArrayList<>();
 
+    embedder.processEntities(entities);
+
     try (Jedis jedis = modulesOperations.client().getJedis().get()) {
       Pipeline pipeline = jedis.pipelined();
 
@@ -380,7 +382,6 @@ public <S extends T> List<S> saveAll(Iterable<S> entities) {
 
         // process entity pre-save mutation
         auditor.processEntity(entity, isNew);
-        embedder.processEntity(entity);
 
         RedisData rdo = new RedisData();
         mappingConverter.write(entity, rdo);