com.hazelcast.mapreduce.impl
Class MapReduceDataSerializerHook

java.lang.Object
  com.hazelcast.mapreduce.impl.MapReduceDataSerializerHook

All Implemented Interfaces:

DataSerializerHook

public class MapReduceDataSerializerHook
extends Object
implements DataSerializerHook

This class contains all the ID hooks for IdentifiedDataSerializable classes used inside the MR framework.

Field Summary

static int	CANCEL_JOB_SUPERVISOR_OPERATION
static int	COMBINER_RESULT_LIST
static int	F_ID
static int	FIRE_NOTIFICATION_OPERATION
static int	GET_RESULT_OPERATION
static int	HASH_MAP_ADAPTER
static int	KEY_VALUE_SOURCE_LIST
static int	KEY_VALUE_SOURCE_MAP
static int	KEY_VALUE_SOURCE_MULTIMAP
static int	KEY_VALUE_SOURCE_SET
static int	KEYS_ASSIGNMENT_OPERATION
static int	KEYS_ASSIGNMENT_RESULT
static int	NOTIFY_REMOTE_EXCEPTION_OPERATION
static int	POSTPONE_PARTITION_PROCESSING_OPERATION
static int	PROCESS_STATS_UPDATE_OPERATION
static int	REDUCER_CHUNK_MESSAGE
static int	REDUCER_LAST_CHUNK_MESSAGE
static int	REDUCING_FINISHED_MESSAGE
static int	REQUEST_MEMBERID_ASSIGNMENT
static int	REQUEST_PARTITION_MAPPING
static int	REQUEST_PARTITION_PROCESSED
static int	REQUEST_PARTITION_REDUCING
static int	REQUEST_PARTITION_RESULT
static int	START_PROCESSING_OPERATION
static int	TRACKED_JOB_OPERATION

Fields inherited from interface com.hazelcast.nio.serialization.DataSerializerHook

F_ID_OFFSET_WEBMODULE

Constructor Summary

MapReduceDataSerializerHook()

Method Summary

DataSerializableFactory	createFactory()
int	getFactoryId()

Methods inherited from class java.lang.Object

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

Field Detail

F_ID

public static final int F_ID

KEY_VALUE_SOURCE_MAP

public static final int KEY_VALUE_SOURCE_MAP

See Also:

Constant Field Values

KEY_VALUE_SOURCE_MULTIMAP

public static final int KEY_VALUE_SOURCE_MULTIMAP

See Also:

Constant Field Values

REDUCER_CHUNK_MESSAGE

public static final int REDUCER_CHUNK_MESSAGE

See Also:

Constant Field Values

REDUCER_LAST_CHUNK_MESSAGE

public static final int REDUCER_LAST_CHUNK_MESSAGE

See Also:

Constant Field Values

TRACKED_JOB_OPERATION

public static final int TRACKED_JOB_OPERATION

See Also:

Constant Field Values

REQUEST_PARTITION_MAPPING

public static final int REQUEST_PARTITION_MAPPING

See Also:

Constant Field Values

REQUEST_PARTITION_REDUCING

public static final int REQUEST_PARTITION_REDUCING

See Also:

Constant Field Values

REQUEST_PARTITION_PROCESSED

public static final int REQUEST_PARTITION_PROCESSED

See Also:

Constant Field Values

GET_RESULT_OPERATION

public static final int GET_RESULT_OPERATION

See Also:

Constant Field Values

START_PROCESSING_OPERATION

public static final int START_PROCESSING_OPERATION

See Also:

Constant Field Values

REQUEST_PARTITION_RESULT

public static final int REQUEST_PARTITION_RESULT

See Also:

Constant Field Values

REDUCING_FINISHED_MESSAGE

public static final int REDUCING_FINISHED_MESSAGE

See Also:

Constant Field Values

FIRE_NOTIFICATION_OPERATION

public static final int FIRE_NOTIFICATION_OPERATION

See Also:

Constant Field Values

REQUEST_MEMBERID_ASSIGNMENT

public static final int REQUEST_MEMBERID_ASSIGNMENT

See Also:

Constant Field Values

PROCESS_STATS_UPDATE_OPERATION

public static final int PROCESS_STATS_UPDATE_OPERATION

See Also:

Constant Field Values

NOTIFY_REMOTE_EXCEPTION_OPERATION

public static final int NOTIFY_REMOTE_EXCEPTION_OPERATION

See Also:

Constant Field Values

CANCEL_JOB_SUPERVISOR_OPERATION

public static final int CANCEL_JOB_SUPERVISOR_OPERATION

See Also:

Constant Field Values

POSTPONE_PARTITION_PROCESSING_OPERATION

public static final int POSTPONE_PARTITION_PROCESSING_OPERATION

See Also:

Constant Field Values

KEY_VALUE_SOURCE_LIST

public static final int KEY_VALUE_SOURCE_LIST

See Also:

Constant Field Values

KEY_VALUE_SOURCE_SET

public static final int KEY_VALUE_SOURCE_SET

See Also:

Constant Field Values

KEYS_ASSIGNMENT_RESULT

public static final int KEYS_ASSIGNMENT_RESULT

See Also:

Constant Field Values

KEYS_ASSIGNMENT_OPERATION

public static final int KEYS_ASSIGNMENT_OPERATION

See Also:

Constant Field Values

HASH_MAP_ADAPTER

public static final int HASH_MAP_ADAPTER

See Also:

Constant Field Values

COMBINER_RESULT_LIST

public static final int COMBINER_RESULT_LIST

See Also:

Constant Field Values

Constructor Detail

MapReduceDataSerializerHook

public MapReduceDataSerializerHook()

Method Detail

getFactoryId

public int getFactoryId()

Specified by:

getFactoryId in interface DataSerializerHook

createFactory

public DataSerializableFactory createFactory()

Specified by:

createFactory in interface DataSerializerHook