Skip to content

Commit

Permalink
Add RediSearch Pipeline Commands (#2770)
Browse files Browse the repository at this point in the history
  • Loading branch information
@AvitalFineRedis @sazzad16
AvitalFineRedis authored and sazzad16 committed Dec 27, 2021
1 parent a9394b6 commit db53e13
Show file tree
Hide file tree
Showing 4 changed files with 321 additions and 0 deletions.
92 changes: 92 additions & 0 deletions src/main/java/redis/clients/jedis/MultiNodePipelineBase.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,8 @@
import redis.clients.jedis.params.*;
import redis.clients.jedis.resps.*;
import redis.clients.jedis.search.*;
import redis.clients.jedis.search.aggr.AggregationBuilder;
import redis.clients.jedis.search.aggr.AggregationResult;

public abstract class MultiNodePipelineBase implements PipelineCommands, PipelineBinaryCommands,
RedisModulePipelineCommands, Closeable {
Expand Down Expand Up @@ -3012,6 +3014,11 @@ public Response<String> ftCreate(String indexName, IndexOptions indexOptions, Sc
return appendCommand(commandObjects.ftCreate(indexName, indexOptions, schema));
}

@Override
public Response<String> ftAlter(String indexName, Schema schema) {
return appendCommand(commandObjects.ftAlter(indexName, schema));
}

@Override
public Response<SearchResult> ftSearch(String indexName, Query query) {
return appendCommand(commandObjects.ftSearch(indexName, query));
Expand All @@ -3022,6 +3029,91 @@ public Response<SearchResult> ftSearch(byte[] indexName, Query query) {
return appendCommand(commandObjects.ftSearch(indexName, query));
}

@Override
public Response<String> ftExplain(String indexName, Query query) {
return appendCommand(commandObjects.ftExplain(indexName, query));
}

@Override
public Response<List<String>> ftExplainCLI(String indexName, Query query) {
return appendCommand(commandObjects.ftExplainCLI(indexName, query));
}

@Override
public Response<AggregationResult> ftAggregate(String indexName, AggregationBuilder aggr) {
return appendCommand(commandObjects.ftAggregate(indexName, aggr));
}

@Override
public Response<AggregationResult> ftCursorRead(String indexName, long cursorId, int count) {
return appendCommand(commandObjects.ftCursorRead(indexName, cursorId, count));
}

@Override
public Response<String> ftCursorDel(String indexName, long cursorId) {
return appendCommand(commandObjects.ftCursorDel(indexName, cursorId));
}

@Override
public Response<String> ftDropIndex(String indexName) {
return appendCommand(commandObjects.ftDropIndex(indexName));
}

@Override
public Response<String> ftDropIndexDD(String indexName) {
return appendCommand(commandObjects.ftDropIndexDD(indexName));
}

@Override
public Response<String> ftSynUpdate(String indexName, String synonymGroupId, String... terms) {
return appendCommand(commandObjects.ftSynUpdate(indexName, synonymGroupId, terms));
}

@Override
public Response<Map<String, List<String>>> ftSynDump(String indexName) {
return appendCommand(commandObjects.ftSynDump(indexName));
}

@Override
public Response<Map<String, Object>> ftInfo(String indexName) {
return appendCommand(commandObjects.ftInfo(indexName));
}

@Override
public Response<String> ftAliasAdd(String aliasName, String indexName) {
return appendCommand(commandObjects.ftAliasAdd(aliasName, indexName));
}

@Override
public Response<String> ftAliasUpdate(String aliasName, String indexName) {
return appendCommand(commandObjects.ftAliasUpdate(aliasName, indexName));
}

@Override
public Response<String> ftAliasDel(String aliasName) {
return appendCommand(commandObjects.ftAliasDel(aliasName));
}

@Override
public Response<Map<String, String>> ftConfigGet(String option) {
return appendCommand(commandObjects.ftConfigGet(option));
}

@Override
public Response<Map<String, String>> ftConfigGet(String indexName, String option) {
return appendCommand(commandObjects.ftConfigGet(indexName, option));
}

@Override
public Response<String> ftConfigSet(String option, String value) {
return appendCommand(commandObjects.ftConfigSet(option, value));
}

@Override
public Response<String> ftConfigSet(String indexName, String option, String value) {
return appendCommand(commandObjects.ftConfigSet(indexName, option, value));
}

public Response<Long> waitReplicas(int replicas, long timeout) {
return appendCommand(commandObjects.waitReplicas(replicas, timeout));
}
Expand Down
92 changes: 92 additions & 0 deletions src/main/java/redis/clients/jedis/Pipeline.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,8 @@
import redis.clients.jedis.search.Query;
import redis.clients.jedis.search.Schema;
import redis.clients.jedis.search.SearchResult;
import redis.clients.jedis.search.aggr.AggregationBuilder;
import redis.clients.jedis.search.aggr.AggregationResult;

public class Pipeline extends Queable implements PipelineCommands, PipelineBinaryCommands,
RedisModulePipelineCommands, Closeable {
Expand Down Expand Up @@ -3022,6 +3024,11 @@ public Response<String> ftCreate(String indexName, IndexOptions indexOptions, Sc
return appendCommand(commandObjects.ftCreate(indexName, indexOptions, schema));
}

@Override
public Response<String> ftAlter(String indexName, Schema schema) {
return appendCommand(commandObjects.ftAlter(indexName, schema));
}

@Override
public Response<SearchResult> ftSearch(String indexName, Query query) {
return appendCommand(commandObjects.ftSearch(indexName, query));
Expand All @@ -3032,6 +3039,91 @@ public Response<SearchResult> ftSearch(byte[] indexName, Query query) {
return appendCommand(commandObjects.ftSearch(indexName, query));
}

@Override
public Response<String> ftExplain(String indexName, Query query) {
return appendCommand(commandObjects.ftExplain(indexName, query));
}

@Override
public Response<List<String>> ftExplainCLI(String indexName, Query query) {
return appendCommand(commandObjects.ftExplainCLI(indexName, query));
}

@Override
public Response<AggregationResult> ftAggregate(String indexName, AggregationBuilder aggr) {
return appendCommand(commandObjects.ftAggregate(indexName, aggr));
}

@Override
public Response<AggregationResult> ftCursorRead(String indexName, long cursorId, int count) {
return appendCommand(commandObjects.ftCursorRead(indexName, cursorId, count));
}

@Override
public Response<String> ftCursorDel(String indexName, long cursorId) {
return appendCommand(commandObjects.ftCursorDel(indexName, cursorId));
}

@Override
public Response<String> ftDropIndex(String indexName) {
return appendCommand(commandObjects.ftDropIndex(indexName));
}

@Override
public Response<String> ftDropIndexDD(String indexName) {
return appendCommand(commandObjects.ftDropIndexDD(indexName));
}

@Override
public Response<String> ftSynUpdate(String indexName, String synonymGroupId, String... terms) {
return appendCommand(commandObjects.ftSynUpdate(indexName, synonymGroupId, terms));
}

@Override
public Response<Map<String, List<String>>> ftSynDump(String indexName) {
return appendCommand(commandObjects.ftSynDump(indexName));
}

@Override
public Response<Map<String, Object>> ftInfo(String indexName) {
return appendCommand(commandObjects.ftInfo(indexName));
}

@Override
public Response<String> ftAliasAdd(String aliasName, String indexName) {
return appendCommand(commandObjects.ftAliasAdd(aliasName, indexName));
}

@Override
public Response<String> ftAliasUpdate(String aliasName, String indexName) {
return appendCommand(commandObjects.ftAliasUpdate(aliasName, indexName));
}

@Override
public Response<String> ftAliasDel(String aliasName) {
return appendCommand(commandObjects.ftAliasDel(aliasName));
}

@Override
public Response<Map<String, String>> ftConfigGet(String option) {
return appendCommand(commandObjects.ftConfigGet(option));
}

@Override
public Response<Map<String, String>> ftConfigGet(String indexName, String option) {
return appendCommand(commandObjects.ftConfigGet(indexName, option));
}

@Override
public Response<String> ftConfigSet(String option, String value) {
return appendCommand(commandObjects.ftConfigSet(option, value));
}

@Override
public Response<String> ftConfigSet(String indexName, String option, String value) {
return appendCommand(commandObjects.ftConfigSet(indexName, option, value));
}

public Response<Long> waitReplicas(int replicas, long timeout) {
return appendCommand(commandObjects.waitReplicas(replicas, timeout));
}
Expand Down
92 changes: 92 additions & 0 deletions src/main/java/redis/clients/jedis/TransactionBase.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,6 +25,8 @@
import redis.clients.jedis.params.*;
import redis.clients.jedis.resps.*;
import redis.clients.jedis.search.*;
import redis.clients.jedis.search.aggr.AggregationBuilder;
import redis.clients.jedis.search.aggr.AggregationResult;

public abstract class TransactionBase extends Queable implements PipelineCommands,
PipelineBinaryCommands, RedisModulePipelineCommands, Closeable {
Expand Down Expand Up @@ -3066,6 +3068,11 @@ public Response<String> ftCreate(String indexName, IndexOptions indexOptions, Sc
return appendCommand(commandObjects.ftCreate(indexName, indexOptions, schema));
}

@Override
public Response<String> ftAlter(String indexName, Schema schema) {
return appendCommand(commandObjects.ftAlter(indexName, schema));
}

@Override
public Response<SearchResult> ftSearch(String indexName, Query query) {
return appendCommand(commandObjects.ftSearch(indexName, query));
Expand All @@ -3076,6 +3083,91 @@ public Response<SearchResult> ftSearch(byte[] indexName, Query query) {
return appendCommand(commandObjects.ftSearch(indexName, query));
}

@Override
public Response<String> ftExplain(String indexName, Query query) {
return appendCommand(commandObjects.ftExplain(indexName, query));
}

@Override
public Response<List<String>> ftExplainCLI(String indexName, Query query) {
return appendCommand(commandObjects.ftExplainCLI(indexName, query));
}

@Override
public Response<AggregationResult> ftAggregate(String indexName, AggregationBuilder aggr) {
return appendCommand(commandObjects.ftAggregate(indexName, aggr));
}

@Override
public Response<AggregationResult> ftCursorRead(String indexName, long cursorId, int count) {
return appendCommand(commandObjects.ftCursorRead(indexName, cursorId, count));
}

@Override
public Response<String> ftCursorDel(String indexName, long cursorId) {
return appendCommand(commandObjects.ftCursorDel(indexName, cursorId));
}

@Override
public Response<String> ftDropIndex(String indexName) {
return appendCommand(commandObjects.ftDropIndex(indexName));
}

@Override
public Response<String> ftDropIndexDD(String indexName) {
return appendCommand(commandObjects.ftDropIndexDD(indexName));
}

@Override
public Response<String> ftSynUpdate(String indexName, String synonymGroupId, String... terms) {
return appendCommand(commandObjects.ftSynUpdate(indexName, synonymGroupId, terms));
}

@Override
public Response<Map<String, List<String>>> ftSynDump(String indexName) {
return appendCommand(commandObjects.ftSynDump(indexName));
}

@Override
public Response<Map<String, Object>> ftInfo(String indexName) {
return appendCommand(commandObjects.ftInfo(indexName));
}

@Override
public Response<String> ftAliasAdd(String aliasName, String indexName) {
return appendCommand(commandObjects.ftAliasAdd(aliasName, indexName));
}

@Override
public Response<String> ftAliasUpdate(String aliasName, String indexName) {
return appendCommand(commandObjects.ftAliasUpdate(aliasName, indexName));
}

@Override
public Response<String> ftAliasDel(String aliasName) {
return appendCommand(commandObjects.ftAliasDel(aliasName));
}

@Override
public Response<Map<String, String>> ftConfigGet(String option) {
return appendCommand(commandObjects.ftConfigGet(option));
}

@Override
public Response<Map<String, String>> ftConfigGet(String indexName, String option) {
return appendCommand(commandObjects.ftConfigGet(indexName, option));
}

@Override
public Response<String> ftConfigSet(String option, String value) {
return appendCommand(commandObjects.ftConfigSet(option, value));
}

@Override
public Response<String> ftConfigSet(String indexName, String option, String value) {
return appendCommand(commandObjects.ftConfigSet(indexName, option, value));
}

public Response<Long> waitReplicas(int replicas, long timeout) {
return appendCommand(commandObjects.waitReplicas(replicas, timeout));
}
Expand Down
45 changes: 45 additions & 0 deletions src/main/java/redis/clients/jedis/search/RediSearchPipelineCommands.java
View file
Original file line number Diff line number Diff line change
@@ -1,12 +1,57 @@
package redis.clients.jedis.search;

import redis.clients.jedis.Response;
import redis.clients.jedis.search.aggr.AggregationBuilder;
import redis.clients.jedis.search.aggr.AggregationResult;

import java.util.List;
import java.util.Map;

public interface RediSearchPipelineCommands {

Response<String> ftCreate(String indexName, IndexOptions indexOptions, Schema schema);

default Response<String> ftAlter(String indexName, Schema.Field... fields) {
return ftAlter(indexName, Schema.from(fields));
}

Response<String> ftAlter(String indexName, Schema schema);

Response<SearchResult> ftSearch(String indexName, Query query);

Response<SearchResult> ftSearch(byte[] indexName, Query query);

Response<String> ftExplain(String indexName, Query query);

Response<List<String>> ftExplainCLI(String indexName, Query query);

Response<AggregationResult> ftAggregate(String indexName, AggregationBuilder aggr);

Response<AggregationResult> ftCursorRead(String indexName, long cursorId, int count);

Response<String> ftCursorDel(String indexName, long cursorId);

Response<String> ftDropIndex(String indexName);

Response<String> ftDropIndexDD(String indexName);

Response<String> ftSynUpdate(String indexName, String synonymGroupId, String... terms);

Response<Map<String, List<String>>> ftSynDump(String indexName);

Response<Map<String, Object>> ftInfo(String indexName);

Response<String> ftAliasAdd(String aliasName, String indexName);

Response<String> ftAliasUpdate(String aliasName, String indexName);

Response<String> ftAliasDel(String aliasName);

Response<Map<String, String>> ftConfigGet(String option);

Response<Map<String, String>> ftConfigGet(String indexName, String option);

Response<String> ftConfigSet(String option, String value);

Response<String> ftConfigSet(String indexName, String option, String value);
}

0 comments on commit db53e13

Please sign in to comment.