com.asakusafw.runtime.stage.directio

Class AbstractDirectOutputKey

java.lang.Object

com.asakusafw.runtime.io.util.ShuffleKey<WritableRawComparableUnion,WritableRawComparableUnion>

com.asakusafw.runtime.stage.directio.AbstractDirectOutputKey

All Implemented Interfaces:

WritableRawComparable, Comparable<WritableRawComparable>, org.apache.hadoop.io.Writable, org.apache.hadoop.io.WritableComparable<WritableRawComparable>

public abstract class AbstractDirectOutputKey
extends ShuffleKey<WritableRawComparableUnion,WritableRawComparableUnion>

An abstract implementation of key object in direct output stages.

Since:

0.2.5

Nested Class Summary

Nested classes/interfaces inherited from class com.asakusafw.runtime.io.util.ShuffleKey

ShuffleKey.AbstractGroupComparator, ShuffleKey.AbstractOrderComparator, ShuffleKey.Partitioner

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractDirectOutputKey(DirectOutputSpec... specs) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	setObject(Object value) Sets an object for the current position.
void	setPosition(int position) Sets new position.

Methods inherited from class com.asakusafw.runtime.io.util.ShuffleKey

compareInBytes, compareTo, equals, getGroupObject, getOrderObject, getSizeInBytes, hashCode, readFields, toString, write

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

AbstractDirectOutputKey

protected AbstractDirectOutputKey(DirectOutputSpec... specs)

Creates a new instance.

Parameters:

specs - spec objects

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

setPosition

public void setPosition(int position)

Sets new position.

Parameters:

position - the new position

setObject

public void setObject(Object value)

Sets an object for the current position.

Parameters:

value - the object