Package org.redisson.mapreduce

Class CollectionMapperTask<VIn,KOut,VOut>

java.lang.Object

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

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

Type Parameters:

VIn - input value type

KOut - output key type

VOut - output value type

All Implemented Interfaces:

Serializable, Runnable

public class CollectionMapperTask<VIn,KOut,VOut>
extends BaseMapperTask<KOut,VOut>

Author:

Nikita Koksharov

See Also:

Serialized Form

Field Summary

Fields inherited from class org.redisson.mapreduce.BaseMapperTask

collectorMapName, objectClass, objectCodecClass, objectNames, redisson, timeout, workersAmount

Constructor Summary

Constructors

Constructor	Description
CollectionMapperTask()
CollectionMapperTask(RCollectionMapper<VIn,KOut,VOut> mapper, Class<?> objectClass, Class<?> objectCodecClass)

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class org.redisson.mapreduce.BaseMapperTask

addObjectName, clearObjectNames, setCollectorMapName, setTimeout, setWorkersAmount

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CollectionMapperTask

public CollectionMapperTask()

CollectionMapperTask

public CollectionMapperTask(RCollectionMapper<VIn,KOut,VOut> mapper,
                            Class<?> objectClass,
                            Class<?> objectCodecClass)

Method Detail

run

public void run()