Package | Description |
---|---|
com.basho.riak.client.query |
Classes and interfaces for running map/reduce and link walk operations on
Riak.
|
Modifier and Type | Class and Description |
---|---|
class |
BucketKeyMapReduce
Map/Reduce over a set of bucket/key/keydata inputs.
|
class |
BucketMapReduce
Map/Reduce over a bucket, optionally add Key Filters to narrow the inputs.
|
class |
IndexMapReduce
A
MapReduce operation that takes a 2i index query as input |
class |
SearchMapReduce
A
MapReduce operation that uses a Riak Search query as input. |
Modifier and Type | Method and Description |
---|---|
MapReduce |
MapReduce.addLinkPhase(String bucket,
String tag)
Create a Link Phase that points to
bucket / tag
keep will be false |
MapReduce |
MapReduce.addLinkPhase(String bucket,
String tag,
boolean keep)
Add a Link Phase that points to
bucket / tag
. |
MapReduce |
MapReduce.addMapPhase(Function phaseFunction)
Add a MapPhase
|
MapReduce |
MapReduce.addMapPhase(Function phaseFunction,
boolean keep)
Add
MapPhase to the query |
MapReduce |
MapReduce.addMapPhase(Function phaseFunction,
Object arg)
Add a MapPhase
|
MapReduce |
MapReduce.addMapPhase(Function phaseFunction,
Object arg,
boolean keep)
Add a MapPhase
|
MapReduce |
MapReduce.addReducePhase(Function phaseFunction)
Add a
ReducePhase |
MapReduce |
MapReduce.addReducePhase(Function phaseFunction,
boolean keep)
Add
ReducePhase to the query |
MapReduce |
MapReduce.addReducePhase(Function phaseFunction,
Object arg)
Add a
ReducePhase |
MapReduce |
MapReduce.addReducePhase(Function phaseFunction,
Object arg,
boolean keep)
Add a
ReducePhase |
MapReduce |
MapReduce.timeout(long timeout)
Set the operations timeout
|
Copyright © 2014. All Rights Reserved.