com.hazelcast.mapreduce.impl
Class MapReduceDataSerializerHook

java.lang.Object
  extended by 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


Copyright © 2015 Hazelcast, Inc.. All Rights Reserved.