KeyIn
- type of the input keyValueIn
- type of the input valuepublic class ClientMapReduceRequest<KeyIn,ValueIn> extends InvocationClientRequest
Modifier and Type | Field and Description |
---|---|
protected int |
chunkSize |
protected CombinerFactory |
combinerFactory |
protected String |
jobId |
protected Collection |
keys |
protected KeyValueSource |
keyValueSource |
protected Mapper |
mapper |
protected String |
name |
protected KeyPredicate |
predicate |
protected ReducerFactory |
reducerFactory |
protected TopologyChangedStrategy |
topologyChangedStrategy |
callId, clientEngine, endpoint, operationService, serializationService, service
Constructor and Description |
---|
ClientMapReduceRequest() |
ClientMapReduceRequest(String name,
String jobId,
Collection keys,
KeyPredicate predicate,
Mapper mapper,
CombinerFactory combinerFactory,
ReducerFactory reducerFactory,
KeyValueSource keyValueSource,
int chunkSize,
TopologyChangedStrategy topologyChangedStrategy) |
Modifier and Type | Method and Description |
---|---|
int |
getClassId()
Returns class identifier for this portable class.
|
int |
getFactoryId()
Returns PortableFactory id for this portable class
|
Permission |
getRequiredPermission() |
String |
getServiceName() |
protected void |
invoke() |
void |
read(PortableReader reader) |
void |
write(PortableWriter writer) |
createInvocationBuilder, createInvocationBuilder, process
getCallId, getClassVersion, getClientEngine, getDistributedObjectName, getDistributedObjectType, getEndpoint, getMethodName, getParameters, getService, readPortable, setCallId, setClientEngine, setEndpoint, setOperationService, setSerializationService, setService, writePortable
protected String name
protected String jobId
protected Collection keys
protected KeyPredicate predicate
protected Mapper mapper
protected CombinerFactory combinerFactory
protected ReducerFactory reducerFactory
protected KeyValueSource keyValueSource
protected int chunkSize
protected TopologyChangedStrategy topologyChangedStrategy
public ClientMapReduceRequest()
public ClientMapReduceRequest(String name, String jobId, Collection keys, KeyPredicate predicate, Mapper mapper, CombinerFactory combinerFactory, ReducerFactory reducerFactory, KeyValueSource keyValueSource, int chunkSize, TopologyChangedStrategy topologyChangedStrategy)
protected void invoke()
invoke
in class InvocationClientRequest
public void write(PortableWriter writer) throws IOException
write
in class ClientRequest
IOException
public void read(PortableReader reader) throws IOException
read
in class ClientRequest
IOException
public String getServiceName()
getServiceName
in class ClientRequest
public int getFactoryId()
Portable
public int getClassId()
Portable
public Permission getRequiredPermission()
Copyright © 2016 Hazelcast, Inc.. All Rights Reserved.