Spring Data Key-Value

org.springframework.data.keyvalue.riak.mapreduce
Interface MapReduceJob<T>

All Superinterfaces:
Callable
All Known Implementing Classes:
AbstractRiakMapReduceJob, AsyncRiakMapReduceJob, RiakMapReduceJob

public interface MapReduceJob<T>
extends Callable

A generic interface to representing a Map/Reduce job to a data store that supports that operation.

Author:
J. Brisbin <[email protected]>

Method Summary
<V> MapReduceJob
addInputs(List<V> keys)
          Set the list of inputs for this job.
 MapReduceJob addPhase(MapReducePhase phase)
          Add a phase to this operation.
<V> List<V>
getInputs()
          Get the list of inputs for this job.
 List<MapReducePhase> getPhases()
          Get the list of phases for this job.
 String toJson()
          Convert this job into the appropriate JSON to send to the server.
 
Methods inherited from interface java.util.concurrent.Callable
call
 

Method Detail

getInputs

<V> List<V> getInputs()
Get the list of inputs for this job.

Returns:

addInputs

<V> MapReduceJob addInputs(List<V> keys)
Set the list of inputs for this job.

Type Parameters:
V -
Parameters:
keys -
Returns:

addPhase

MapReduceJob addPhase(MapReducePhase phase)
Add a phase to this operation.

Parameters:
phase -
Returns:

getPhases

List<MapReducePhase> getPhases()
Get the list of phases for this job.

Returns:

toJson

String toJson()
Convert this job into the appropriate JSON to send to the server.

Returns:

Spring Data Key-Value

Copyright © 2010-2011 SpringSource. All Rights Reserved.