Package org.redisson.mapreduce

Class BaseMapperTask<KOut,​VOut>

  • Type Parameters:
    KOut - output key
    VOut - output value
    All Implemented Interfaces:
    ,
    Direct Known Subclasses:
    CollectionMapperTask, MapperTask
    public abstract class BaseMapperTask<KOut,​VOut>
extends 
implements ,
    Author:
    Nikita Koksharov
    See Also:
    Serialized Form

    • Field Detail

      • objectClass

        protected <?> objectClass

      • objectNames

        protected <> objectNames

      • objectCodecClass

        protected <?> objectCodecClass

      • workersAmount

        protected int workersAmount

      • collectorMapName

        protected  collectorMapName

      • timeout

        protected long timeout

    • Constructor Detail

      • BaseMapperTask

        public BaseMapperTask()

      • BaseMapperTask

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

    • Method Detail

      • addObjectName

        public void addObjectName​( objectName)

      • clearObjectNames

        public void clearObjectNames()

      • setTimeout

        public void setTimeout​(long timeout)

      • setWorkersAmount

        public void setWorkersAmount​(int workersAmount)

      • setCollectorMapName

        public void setCollectorMapName​( collatorMapName)