public class ExecMapReduce<T> extends Object
Modifier and Type | Class and Description |
---|---|
class |
ExecMapReduce.RunThread
use StoreConfig.IsUrl to determine which (MRStore or ServerStore) tp create
MRStore assume that all records are physical consective
|
Modifier and Type | Field and Description |
---|---|
protected Serializer |
colSerialize |
static String |
COLUMN |
static String |
SCAN |
Constructor and Description |
---|
ExecMapReduce(Map<String,RemoteStore> remoteStoreMap,
Class<T> tClass,
MapReduce<T> mapReduce) |
ExecMapReduce(Map<String,RemoteStore> remoteStoreMap,
Class<T> tClass,
MapReduce<T> mapReduce,
Serializer serializer) |
ExecMapReduce(Map<String,RemoteStore> remoteStoreMap,
Class<T> tClass,
MapReduce<T> mapReduce,
Serializer serializer,
String predicateQuery,
Filter.Impl impl) |
Modifier and Type | Method and Description |
---|---|
Object |
execute(String store,
int noOfThread) |
Object |
execute(String store,
int noOfThread,
int begin,
int end)
each thread will process 3 of record (end -begin) /noOfThread
|
Object |
execute(String store,
int noOfThread,
String partition) |
void |
setTimeout(long timeout) |
public static final String SCAN
public static final String COLUMN
protected Serializer colSerialize
public ExecMapReduce(Map<String,RemoteStore> remoteStoreMap, Class<T> tClass, MapReduce<T> mapReduce)
remoteStoreMap
- tClass
- for AggregationmapReduce
- public ExecMapReduce(Map<String,RemoteStore> remoteStoreMap, Class<T> tClass, MapReduce<T> mapReduce, Serializer serializer)
remoteStoreMap
- tClass
- mapReduce
- serializer
- public ExecMapReduce(Map<String,RemoteStore> remoteStoreMap, Class<T> tClass, MapReduce<T> mapReduce, Serializer serializer, String predicateQuery, Filter.Impl impl)
public void setTimeout(long timeout)
public Object execute(String store, int noOfThread, String partition)
store
- noOfThread
- partition
- has format nodeNo, totalNodes which enable all node to participate the mapreduce
examples, two nodes in 1,2 and 2,2Copyright © 2016. All rights reserved.