public interface Mapper<KIn,VIn,KOut,VOut> extends Serializable
Reducer
.Reducer
,
MapReduceTask
,
Cache.entrySet()
,
CacheCollection.stream()
Modifier and Type | Method and Description |
---|---|
void |
map(KIn key,
VIn value,
Collector<KOut,VOut> collector)
Deprecated.
Invoked once for each input cache entry KIn,VOut pair.
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.