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

Fields

Modifier and Type	Field and Description
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

Constructors

Constructor and Description
MapReduceDataSerializerHook()

Method Summary

Methods

Modifier and Type	Method and Description
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