com.google.appengine.tools.mapreduce.inputs

Class ConsecutiveLongInput

java.lang.Object

com.google.appengine.tools.mapreduce.Input<Long>

com.google.appengine.tools.mapreduce.inputs.ConsecutiveLongInput

All Implemented Interfaces:

Serializable

public final class ConsecutiveLongInput
extends Input<Long>

Produces all longs in a given interval.

Author:

ohler@google.com (Christian Ohler)

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ConsecutiveLongInput(long start, long limit, int shardCount) Produces longs from (inclusive) to limit (exclusive).

Method Summary

Methods

Modifier and Type	Method and Description
List<? extends InputReader<Long>>	createReaders() Returns a list of readers for this input.
String	toString()

Methods inherited from class com.google.appengine.tools.mapreduce.Input

getContext

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsecutiveLongInput

public ConsecutiveLongInput(long start,
                    long limit,
                    int shardCount)

Produces longs from (inclusive) to limit (exclusive). The interval is partitioned into shardCount subintervals of roughly equal size, one for each shard. Each shard produces its longs in ascending order.

Method Detail

toString

public String toString()

Overrides:

toString in class Object

createReaders

public List<? extends InputReader<Long>> createReaders()

Description copied from class: Input

Returns a list of readers for this input. It is the Input's responsibility to determine an appropriate number of readers to split into. This could be specified by the user or determined algorithmically. The number of input readers returned determines the number of map shards.

Specified by:

createReaders in class Input<Long>