java.lang.Object
- org.redisson.mapreduce.BaseMapperTask<KOut,VOut>

Type Parameters:

KOut - output key

VOut - output value

All Implemented Interfaces:

Serializable, Runnable

Direct Known Subclasses:

CollectionMapperTask, MapperTask
```
public abstract class BaseMapperTask<KOut,VOut>
extends Object
implements Runnable, Serializable
```
Author:

Nikita Koksharov

See Also:

Serialized Form

Field Summary

Fields
Modifier and Type	Field	Description
`protected String`	`collectorMapName`
`protected Class<?>`	`objectClass`
`protected Class<?>`	`objectCodecClass`
`protected List<String>`	`objectNames`
`protected RedissonClient`	`redisson`
`protected long`	`timeout`
`protected int`	`workersAmount`

Constructor Summary

Constructors
Constructor Description

BaseMapperTask()

BaseMapperTask(Class<?> objectClass, Class<?> objectCodecClass)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addObjectName(String objectName)`
`void`	`clearObjectNames()`
`void`	`setCollectorMapName(String collatorMapName)`
`void`	`setTimeout(long timeout)`
`void`	`setWorkersAmount(int workersAmount)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Runnable
run

Field Detail

redisson
```
protected RedissonClient redisson
```

objectClass
```
protected Class<?> objectClass
```

objectNames
```
protected List<String> objectNames
```

objectCodecClass
```
protected Class<?> objectCodecClass
```

workersAmount
```
protected int workersAmount
```

collectorMapName
```
protected String collectorMapName
```

timeout
```
protected long timeout
```

Constructor Detail

BaseMapperTask
```
public BaseMapperTask()
```

BaseMapperTask

public BaseMapperTask(Class<?> objectClass,
                      Class<?> objectCodecClass)

Method Detail

addObjectName

public void addObjectName(String objectName)

clearObjectNames
```
public void clearObjectNames()
```

setTimeout
```
public void setTimeout(long timeout)
```

setWorkersAmount

public void setWorkersAmount(int workersAmount)

setCollectorMapName

public void setCollectorMapName(String collatorMapName)

Constructor	Description
`BaseMapperTask()`
`BaseMapperTask(Class<?> objectClass, Class<?> objectCodecClass)`

Class BaseMapperTask<KOut,VOut>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface java.lang.Runnable

Field Detail

redisson

objectClass

objectNames

objectCodecClass

workersAmount

collectorMapName

timeout

Constructor Detail

BaseMapperTask

BaseMapperTask

Method Detail

addObjectName

clearObjectNames

setTimeout

setWorkersAmount

setCollectorMapName