Package | Description |
---|---|
org.infinispan.demo.mapreduce | |
org.infinispan.distexec.mapreduce | |
org.infinispan.query.impl.massindex |
Modifier and Type | Method and Description |
---|---|
void |
WordCountMapperEmitPerValue.map(String key,
String value,
Collector<String,Integer> c) |
void |
WordCountMapper.map(String key,
String value,
Collector<String,Integer> c) |
Modifier and Type | Method and Description |
---|---|
void |
Mapper.map(KIn key,
VIn value,
Collector<KOut,VOut> collector)
Invoked once for each input cache entry KIn,VOut pair.
|
Constructor and Description |
---|
MapReduceCacheLoaderTask(Mapper mapper,
Collector collector) |
Modifier and Type | Method and Description |
---|---|
void |
IndexingMapper.map(Object key,
Object value,
Collector<Object,org.hibernate.search.backend.LuceneWork> collector) |
Copyright © 2014 JBoss, a division of Red Hat. All Rights Reserved.