Package | Description |
---|---|
org.infinispan.demo.mapreduce | |
org.infinispan.distexec.mapreduce |
Modifier and Type | Class and Description |
---|---|
class |
WordCountCollator
Collates reduced results by grouping them into the top K most frequent words.
|
Modifier and Type | Method and Description |
---|---|
<R> R |
MapReduceTask.execute(Collator<KOut,VOut,R> collator)
Executes this task across Infinispan cluster but the final result is collated using specified
Collator |
<R> Future<R> |
MapReduceTask.executeAsynchronously(Collator<KOut,VOut,R> collator)
Executes this task asynchronously across Infinispan cluster; final result is collated using
specified
Collator and wrapped by Future |
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.