Uses of Class
com.google.appengine.tools.mapreduce.KeyValue

Packages that use KeyValue

Package	Description
com.google.appengine.tools.mapreduce
com.google.appengine.tools.mapreduce.impl
com.google.appengine.tools.mapreduce.impl.sort
com.google.appengine.tools.mapreduce.mappers
com.google.appengine.tools.mapreduce.outputs

Uses of KeyValue in com.google.appengine.tools.mapreduce

Methods in com.google.appengine.tools.mapreduce that return KeyValue

Modifier and Type	Method and Description
static <K,V> KeyValue<K,V>	KeyValue.of(K k, V v)

Methods in com.google.appengine.tools.mapreduce that return types with arguments of type KeyValue

Modifier and Type	Method and Description
static <K,V> Marshaller<KeyValue<K,V>>	Marshallers.getKeyValueMarshaller(Marshaller<K> keyMarshaller, Marshaller<V> valueMarshaller) Returns a Marshaller for key-value pairs based on keyMarshaller and valueMarshaller.
static <K,V> Marshaller<KeyValue<K,? extends Iterable<V>>>	Marshallers.getKeyValuesMarshaller(Marshaller<K> keyMarshaller, Marshaller<V> valueMarshaller) Returns a Marshaller for key-values pairs based on keyMarshaller and valueMarshaller.

Uses of KeyValue in com.google.appengine.tools.mapreduce.impl

Methods in com.google.appengine.tools.mapreduce.impl that return KeyValue

Modifier and Type	Method and Description
KeyValue<K,V>	KeyValueMarshaller.fromBytes(ByteBuffer input)
KeyValue<K,Iterable<V>>	KeyValuesMarshaller.fromBytes(ByteBuffer input)

Methods in com.google.appengine.tools.mapreduce.impl that return types with arguments of type KeyValue

Modifier and Type	Method and Description
List<? extends InputReader<KeyValue<ByteBuffer,Iterator<ByteBuffer>>>>	GoogleCloudStorageMergeInput.createReaders() Creates multiple merging readers for each shard using GoogleCloudStorageMergeInput.createReaderForShard(com.google.appengine.tools.mapreduce.Marshaller<com.google.appengine.tools.mapreduce.KeyValue<java.nio.ByteBuffer, ? extends java.lang.Iterable<java.nio.ByteBuffer>>>, com.google.appengine.tools.mapreduce.GoogleCloudStorageFileSet) below.
List<? extends InputReader<KeyValue<ByteBuffer,ByteBuffer>>>	GoogleCloudStorageSortInput.createReaders()
List<? extends InputReader<KeyValue<K,Iterator<V>>>>	GoogleCloudStorageReduceInput.createReaders()
List<? extends OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>>>	GoogleCloudStorageSortOutput.createWriters(int shards)
List<? extends OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>>>	GoogleCloudStorageMergeOutput.createWriters(int shards) Returns a writer that writes the data the same way that the sort does, splitting the output every time the key goes backwards in sequence.
List<? extends OutputWriter<KeyValue<K,V>>>	GoogleCloudStorageMapOutput.createWriters(int shards)
InputReader<KeyValue<K,Iterator<V>>>	ReduceShardTask.getInputReader()
OutputWriter<KeyValue<K,V>>	MapShardTask.getOutputWriter()

Methods in com.google.appengine.tools.mapreduce.impl with parameters of type KeyValue

Modifier and Type	Method and Description
protected void	ReduceShardTask.callWorker(KeyValue<K,Iterator<V>> input)
protected String	ReduceShardTask.formatLastWorkItem(KeyValue<K,Iterator<V>> item)
ByteBuffer	KeyValuesMarshaller.toBytes(KeyValue<K,? extends Iterable<V>> keyValues)
ByteBuffer	KeyValueMarshaller.toBytes(KeyValue<K,V> keyValues)

Method parameters in com.google.appengine.tools.mapreduce.impl with type arguments of type KeyValue

Modifier and Type	Method and Description
FilesByShard	GoogleCloudStorageSortOutput.finish(Collection<? extends OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>>> writers)
FilesByShard	GoogleCloudStorageMergeOutput.finish(Collection<? extends OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>>> writers)
FilesByShard	GoogleCloudStorageMapOutput.finish(Collection<? extends OutputWriter<KeyValue<K,V>>> outputWriters)

Constructor parameters in com.google.appengine.tools.mapreduce.impl with type arguments of type KeyValue

Constructor and Description
MapShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<I> in, Mapper<I,K,V> mapper, OutputWriter<KeyValue<K,V>> out, long millisPerSlice)
ReduceShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<KeyValue<K,Iterator<V>>> in, Reducer<K,V,O> reducer, OutputWriter<O> out, long millisPerSlice)

Uses of KeyValue in com.google.appengine.tools.mapreduce.impl.sort

Methods in com.google.appengine.tools.mapreduce.impl.sort that return types with arguments of type KeyValue

Modifier and Type	Method and Description
InputReader<KeyValue<ByteBuffer,Iterator<ByteBuffer>>>	MergeShardTask.getInputReader()
InputReader<KeyValue<ByteBuffer,ByteBuffer>>	SortShardTask.getInputReader()
OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>>	MergeShardTask.getOutputWriter()
OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>>	SortShardTask.getOutputWriter()

Methods in com.google.appengine.tools.mapreduce.impl.sort with parameters of type KeyValue

Modifier and Type	Method and Description
protected void	SortShardTask.callWorker(KeyValue<ByteBuffer,ByteBuffer> input)
protected void	MergeShardTask.callWorker(KeyValue<ByteBuffer,Iterator<ByteBuffer>> input)
protected String	SortShardTask.formatLastWorkItem(KeyValue<ByteBuffer,ByteBuffer> item)
protected String	MergeShardTask.formatLastWorkItem(KeyValue<ByteBuffer,Iterator<ByteBuffer>> item)

Constructor parameters in com.google.appengine.tools.mapreduce.impl.sort with type arguments of type KeyValue

Constructor and Description
MergeShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<KeyValue<ByteBuffer,Iterator<ByteBuffer>>> in, OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>> out, int sortReadTimeMillis)
MergeShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<KeyValue<ByteBuffer,Iterator<ByteBuffer>>> in, OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>> out, int sortReadTimeMillis)
SortShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<KeyValue<ByteBuffer,ByteBuffer>> in, SortWorker worker, OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>> out, int sortReadTimeMillis)
SortShardTask(String mrJobId, int shardNumber, int shardCount, InputReader<KeyValue<ByteBuffer,ByteBuffer>> in, SortWorker worker, OutputWriter<KeyValue<ByteBuffer,List<ByteBuffer>>> out, int sortReadTimeMillis)

Uses of KeyValue in com.google.appengine.tools.mapreduce.mappers

Methods in com.google.appengine.tools.mapreduce.mappers with parameters of type KeyValue

Modifier and Type	Method and Description
void	IdentityMapper.map(KeyValue<K,V> input)

Uses of KeyValue in com.google.appengine.tools.mapreduce.outputs

Classes in com.google.appengine.tools.mapreduce.outputs with type parameters of type KeyValue

Modifier and Type	Class and Description
class	ShardingOutputWriter<K,V,WriterT extends OutputWriter<KeyValue<K,V>>> Writes KeyValues out to a number of output writers each corresponding to a different shard A sharder and an Output object are provided in the constructor.

Methods in com.google.appengine.tools.mapreduce.outputs with parameters of type KeyValue

Modifier and Type	Method and Description
void	ShardingOutputWriter.write(KeyValue<K,V> value)