Uses of Interface
org.redisson.api.mapreduce.RCollator
-
Packages that use RCollator Package Description org.redisson.api.mapreduce org.redisson.mapreduce -
-
Uses of RCollator in org.redisson.api.mapreduce
Methods in org.redisson.api.mapreduce with parameters of type RCollator Modifier and Type Method Description <R> R
RMapReduceExecutor. execute(RCollator<KOut,VOut,R> collator)
Executes MapReduce process across Redisson Nodes and collides result using definedcollator
<R> RFuture<R>
RMapReduceExecutor. executeAsync(RCollator<KOut,VOut,R> collator)
Executes MapReduce process across Redisson Nodes in asynchronous mode and collides result using definedcollator
-
Uses of RCollator in org.redisson.mapreduce
Methods in org.redisson.mapreduce with parameters of type RCollator Modifier and Type Method Description protected Callable<Object>
RedissonCollectionMapReduce. createTask(String resultMapName, RCollator<KOut,VOut,Object> collator)
protected Callable<Object>
RedissonMapReduce. createTask(String resultMapName, RCollator<KOut,VOut,Object> collator)
Constructors in org.redisson.mapreduce with parameters of type RCollator Constructor Description CollatorTask(RedissonClient redisson, RCollator<KOut,VOut,R> collator, String resultMapName, Class<?> codecClass)
CoordinatorTask(BaseMapperTask<KOut,VOut> mapperTask, RReducer<KOut,VOut> reducer, String mapName, String resultMapName, Class<?> mapCodecClass, Class<?> objectClass, RCollator<KOut,VOut,Object> collator, long timeout, long startTime)
-