com.scaleoutsoftware.soss.hserver.interop

Class RunMapContext<K,V>

java.lang.Object

com.scaleoutsoftware.soss.hserver.interop.RunMapContext<K,V>

Type Parameters:

K - mapper key type

V - mapper value type

public abstract class RunMapContext<K,V>
extends Object

An immutable context of job properties which is passed to all mapper tasks.

Constructor Summary

Constructors

Constructor and Description
RunMapContext(int[] partitionMapping, int invocationId, int outputChunkSizeKb, int hashTableSize, int maxMemoryKb, Class<K> keyClass, Class<V> valueClass, boolean valuesAreFixedLength, int fixedValueLength)

Method Summary

Modifier and Type	Method and Description
int	getFixedValueLength()
int	getHashTableSize()
int	getInvocationId()
Class<K>	getKeyClass()
int	getMaxMemoryKb()
int	getOutputChunkSizeKb()
int[]	getPartitionMapping()
Class<V>	getValueClass()
boolean	getValuesAreFixedLength()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RunMapContext

public RunMapContext(int[] partitionMapping,
                     int invocationId,
                     int outputChunkSizeKb,
                     int hashTableSize,
                     int maxMemoryKb,
                     Class<K> keyClass,
                     Class<V> valueClass,
                     boolean valuesAreFixedLength,
                     int fixedValueLength)

Method Detail

getPartitionMapping

public int[] getPartitionMapping()

getInvocationId

public int getInvocationId()

getOutputChunkSizeKb

public int getOutputChunkSizeKb()

getHashTableSize

public int getHashTableSize()

getKeyClass

public Class<K> getKeyClass()

getValueClass

public Class<V> getValueClass()

getValuesAreFixedLength

public boolean getValuesAreFixedLength()

getFixedValueLength

public int getFixedValueLength()

getMaxMemoryKb

public int getMaxMemoryKb()