Package org.redisson.mapreduce

Class RedissonCollectionMapReduce<VIn,KOut,VOut>

org.redisson.mapreduce.RedissonCollectionMapReduce<VIn,KOut,VOut>

Type Parameters:

VIn - input value type

KOut - output key type

VOut - output value type

All Implemented Interfaces:

RCollectionMapReduce<VIn,KOut,VOut>, RMapReduceExecutor<VIn,KOut,VOut>

public class RedissonCollectionMapReduce<VIn,KOut,VOut>
extends 
implements RCollectionMapReduce<VIn,KOut,VOut>

Author:

Nikita Koksharov

Constructor Summary

Constructors

Constructor	Description
RedissonCollectionMapReduce(RObject object, RedissonClient redisson, CommandAsyncExecutor commandExecutor)

Method Summary

Modifier and Type	Method	Description
protected void	task)
protected <>	resultMapName, > collator)
<KOut,VOut>	execute()	Executes MapReduce process across Redisson Nodes
void	resultMapName)	Executes MapReduce process across Redisson Nodes and stores result in map with resultMapName
<R> R	execute(RCollator<KOut,VOut,R> collator)	Executes MapReduce process across Redisson Nodes and collides result using defined collator
<KOut,VOut>>	executeAsync()	Executes MapReduce process across Redisson Nodes in asynchronous mode
>	resultMapName)	Executes MapReduce process across Redisson Nodes in asynchronous mode and stores result in map with resultMapName
<R> RFuture<R>	executeAsync(RCollator<KOut,VOut,R> collator)	Executes MapReduce process across Redisson Nodes in asynchronous mode and collides result using defined collator
RCollectionMapReduce<VIn,KOut,VOut>	mapper(RCollectionMapper<VIn,KOut,VOut> mapper)	Setup Mapper object
RCollectionMapReduce<VIn,KOut,VOut>	reducer(RReducer<KOut,VOut> reducer)	Setup Reducer object
RCollectionMapReduce<VIn,KOut,VOut>	timeout(long timeout, unit)	Defines timeout for MapReduce process

Methods inherited from class java.lang.

, , , , , , , , , ,

Methods inherited from interface org.redisson.api.mapreduce.RMapReduceExecutor

execute, execute, execute, executeAsync, executeAsync, executeAsync

Constructor Detail

RedissonCollectionMapReduce

public RedissonCollectionMapReduce(RObject object,
                                   RedissonClient redisson,
                                   CommandAsyncExecutor commandExecutor)

Method Detail

timeout

public RCollectionMapReduce<VIn,KOut,VOut> timeout(long timeout,
                                                                unit)

Description copied from interface: RCollectionMapReduce

Defines timeout for MapReduce process

Specified by:

timeout in interface RCollectionMapReduce<VIn,KOut,VOut>

Parameters:

timeout - for process

unit - of timeout

Returns:

self instance

mapper

public RCollectionMapReduce<VIn,KOut,VOut> mapper(RCollectionMapper<VIn,KOut,VOut> mapper)

Description copied from interface: RCollectionMapReduce

Setup Mapper object

Specified by:

mapper in interface RCollectionMapReduce<VIn,KOut,VOut>

Parameters:

mapper - used during MapReduce

Returns:

self instance

reducer

public RCollectionMapReduce<VIn,KOut,VOut> reducer(RReducer<KOut,VOut> reducer)

Description copied from interface: RCollectionMapReduce

Setup Reducer object

Specified by:

reducer in interface RCollectionMapReduce<VIn,KOut,VOut>

Parameters:

reducer - used during MapReduce

Returns:

self instance

createTask

protected <> createTask( resultMapName,
                                      > collator)

check

protected void check( task)

execute

public <KOut,VOut> execute()

Description copied from interface: RMapReduceExecutor

Executes MapReduce process across Redisson Nodes

Specified by:

execute in interface RMapReduceExecutor<M,VIn,KOut>

Returns:

map containing reduced keys and values

executeAsync

public <KOut,VOut>> executeAsync()

Description copied from interface: RMapReduceExecutor

Executes MapReduce process across Redisson Nodes in asynchronous mode

Specified by:

executeAsync in interface RMapReduceExecutor<M,VIn,KOut>

Returns:

map containing reduced keys and values

execute

public void execute( resultMapName)

Description copied from interface: RMapReduceExecutor

Executes MapReduce process across Redisson Nodes and stores result in map with resultMapName

Specified by:

execute in interface RMapReduceExecutor<M,VIn,KOut>

Parameters:

resultMapName - - destination map name

executeAsync

public > executeAsync( resultMapName)

Description copied from interface: RMapReduceExecutor

Executes MapReduce process across Redisson Nodes in asynchronous mode and stores result in map with resultMapName

Specified by:

executeAsync in interface RMapReduceExecutor<M,VIn,KOut>

Parameters:

resultMapName - - destination map name

Returns:

void

execute

public <R> R execute(RCollator<KOut,VOut,R> collator)

Description copied from interface: RMapReduceExecutor

Executes MapReduce process across Redisson Nodes and collides result using defined collator

Specified by:

execute in interface RMapReduceExecutor<M,VIn,KOut>

Type Parameters:

R - result type

Parameters:

collator - applied to result

Returns:

collated result

executeAsync

public <R> RFuture<R> executeAsync(RCollator<KOut,VOut,R> collator)

Description copied from interface: RMapReduceExecutor

Executes MapReduce process across Redisson Nodes in asynchronous mode and collides result using defined collator

Specified by:

executeAsync in interface RMapReduceExecutor<M,VIn,KOut>

Type Parameters:

R - result type

Parameters:

collator - applied to result

Returns:

collated result