Package org.redisson.mapreduce

Class CoordinatorTask<KOut,VOut>

org.redisson.mapreduce.CoordinatorTask<KOut,VOut>

Type Parameters:

KOut - output key

VOut - output value

All Implemented Interfaces:

, <>

public class CoordinatorTask<KOut,VOut>
extends 
implements <>, 

Author:

Nikita Koksharov

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected Codec	codec
protected <?>	objectClass
protected	objectName
protected RedissonClient	redisson

Constructor Summary

Constructors

Constructor	Description
CoordinatorTask()
CoordinatorTask(BaseMapperTask<KOut,VOut> mapperTask, RReducer<KOut,VOut> reducer, mapName, resultMapName, <?> mapCodecClass, <?> objectClass, > collator, long timeout, long startTime)

Method Summary

Modifier and Type	Method	Description
	call()

Methods inherited from class java.lang.

, , , , , , , , , ,

Field Detail

redisson

protected RedissonClient redisson

objectName

protected  objectName

objectClass

protected <?> objectClass

codec

protected Codec codec

Constructor Detail

CoordinatorTask

public CoordinatorTask()

CoordinatorTask

public CoordinatorTask(BaseMapperTask<KOut,VOut> mapperTask,
                       RReducer<KOut,VOut> reducer,
                        mapName,
                        resultMapName,
                       <?> mapCodecClass,
                       <?> objectClass,
                       > collator,
                       long timeout,
                       long startTime)

Method Detail

call

public  call()
            throws 

Specified by:

in interface <KOut>

Throws: