com.basho.riak.client.api.commands.mapreduce

Class BucketInput

java.lang.Object

com.basho.riak.client.api.commands.mapreduce.BucketInput

All Implemented Interfaces:

MapReduceInput

public class BucketInput
extends Object
implements MapReduceInput

MapReduce Input that provides a whole bucket's contents as input for the MapReduce job.

Constructor Summary

Constructors

Constructor and Description
BucketInput(Namespace namespace, Collection<KeyFilter> filters) Creates a BucketInput from the provided namespace, and applicable keyfilters.

Method Summary

Modifier and Type	Method and Description
Collection<KeyFilter>	getFilters() Gets the keyfilter collection of the input.
Namespace	getNamespace() Gets the namespace of the input.
boolean	hasFilters() Indicates whether the input has any keyfilters to apply.

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketInput

public BucketInput(Namespace namespace,
                   Collection<KeyFilter> filters)

Creates a BucketInput from the provided namespace, and applicable keyfilters.

Parameters:

namespace - the namespace to keylist over

filters - a collection of KeyFilters to filter the namespace's keys by

Method Detail

getNamespace

public Namespace getNamespace()

Gets the namespace of the input.

Returns:

the namespace of the input.

hasFilters

public boolean hasFilters()

Indicates whether the input has any keyfilters to apply.

Returns:

whether the input includes any keyfilters

getFilters

public Collection<KeyFilter> getFilters()

Gets the keyfilter collection of the input.

Returns:

the keyfilter collection of the input.