org.infinispan.distexec.mapreduce

Class MapReduceManagerImpl.DefaultCollector<KOut,VOut>

java.lang.Object

org.infinispan.distexec.mapreduce.MapReduceManagerImpl.DefaultCollector<KOut,VOut>

All Implemented Interfaces:

Collector<KOut,VOut>, MapReduceManagerImpl.CollectableCollector<KOut,VOut>

Enclosing class:

MapReduceManagerImpl

private static final class MapReduceManagerImpl.DefaultCollector<KOut,VOut>
extends java.lang.Object
implements MapReduceManagerImpl.CollectableCollector<KOut,VOut>

Author:

Sanne Grinovero (C) 2011 Red Hat Inc., Dan Berindei, William Burns, Vladimir Blagojevic

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	atomicEmit
private java.util.concurrent.atomic.AtomicInteger	emitCount
private java.util.Map<KOut,java.util.List<VOut>>	store

Constructor Summary

Constructors

Constructor and Description
MapReduceManagerImpl.DefaultCollector(boolean atomicEmit)
MapReduceManagerImpl.DefaultCollector(int size, boolean atomicEmit)

Method Summary

Methods

Modifier and Type	Method and Description
void	emit(KOut key, VOut value) Intermediate key/value callback used by Mapper implementor
protected void	emitHelper(KOut key, VOut value)
java.util.Map<KOut,java.util.List<VOut>>	removeCollectedValues()
java.util.Map<KOut,java.util.List<VOut>>	removeLRUEntry()
int	size()

Methods inherited from class java.lang.Object

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

Field Detail

atomicEmit

private final boolean atomicEmit

store

private java.util.Map<KOut,java.util.List<VOut>> store

emitCount

private final java.util.concurrent.atomic.AtomicInteger emitCount

Constructor Detail

MapReduceManagerImpl.DefaultCollector

public MapReduceManagerImpl.DefaultCollector(int size,
                                     boolean atomicEmit)

MapReduceManagerImpl.DefaultCollector

public MapReduceManagerImpl.DefaultCollector(boolean atomicEmit)

Method Detail

emit

public void emit(KOut key,
        VOut value)

Description copied from interface: Collector

Intermediate key/value callback used by Mapper implementor

Specified by:

emit in interface Collector<KOut,VOut>

Parameters:

key - intermediate key

value - intermediate value

emitHelper

protected void emitHelper(KOut key,
              VOut value)

removeCollectedValues

public java.util.Map<KOut,java.util.List<VOut>> removeCollectedValues()

Specified by:

removeCollectedValues in interface MapReduceManagerImpl.CollectableCollector<KOut,VOut>

removeLRUEntry

public java.util.Map<KOut,java.util.List<VOut>> removeLRUEntry()

Specified by:

removeLRUEntry in interface MapReduceManagerImpl.CollectableCollector<KOut,VOut>

size

public int size()