Modifier and Type | Method and Description |
---|---|
void |
HadoopCombine.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
void |
HadoopReduce.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
HadoopCombine.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
void |
HadoopReduce.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
Modifier and Type | Method and Description |
---|---|
static <A> ObjectWritable<A> |
ObjectWritable.empty() |
static ObjectWritable<MapReduce.NullObject> |
ObjectWritable.getNullObjectWritable() |
Modifier and Type | Method and Description |
---|---|
int |
ObjectWritableComparator.compare(ObjectWritable objectWritable1,
ObjectWritable objectWritable2) |
int |
ObjectWritableComparator.compare(ObjectWritable objectWritable1,
ObjectWritable objectWritable2) |
int |
ObjectWritable.compareTo(ObjectWritable objectWritable) |
Modifier and Type | Method and Description |
---|---|
ObjectWritable<A> |
MemoryAccumulator.addAccumulator(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.addInPlace(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.zero(ObjectWritable<A> a) |
Modifier and Type | Method and Description |
---|---|
ObjectWritable<A> |
MemoryAccumulator.addAccumulator(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.addAccumulator(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.addInPlace(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.addInPlace(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.zero(ObjectWritable<A> a) |
Modifier and Type | Method and Description |
---|---|
<I extends InputShim> |
ObjectWritableSerializer.read(KryoShim<I,?> kryo,
I input,
Class<ObjectWritable<T>> clazz) |
Modifier and Type | Method and Description |
---|---|
<O extends OutputShim> |
ObjectWritableSerializer.write(KryoShim<?,O> kryo,
O output,
ObjectWritable<T> starGraph) |
Modifier and Type | Method and Description |
---|---|
<I extends InputShim> |
ObjectWritableSerializer.read(KryoShim<I,?> kryo,
I input,
Class<ObjectWritable<T>> clazz) |
Copyright © 2013–2020 Apache Software Foundation. All rights reserved.