Bug fix, added setWithMetaData()
This commit is contained in:
@@ -14,9 +14,9 @@
|
||||
<!-- versions for commonly-used dependencies -->
|
||||
<junit.version>4.8.1</junit.version>
|
||||
<log4j.version>1.2.15</log4j.version>
|
||||
<org.codehaus.jackson.version>1.5.6</org.codehaus.jackson.version>
|
||||
<org.codehaus.jackson.version>1.6.1</org.codehaus.jackson.version>
|
||||
<org.mockito.version>1.8.4</org.mockito.version>
|
||||
<org.slf4j.version>1.5.10</org.slf4j.version>
|
||||
<org.slf4j.version>1.5.8</org.slf4j.version>
|
||||
<org.springframework.version>3.0.5.RELEASE</org.springframework.version>
|
||||
<!-- dist.* properties are used by the antrun tasks below -->
|
||||
<dist.id>spring-datastore-keyvalue</dist.id>
|
||||
|
||||
@@ -50,16 +50,17 @@
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>slf4j-api</artifactId>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>jcl-over-slf4j</artifactId>
|
||||
<scope>compile</scope>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>slf4j-log4j12</artifactId>
|
||||
<scope>runtime</scope>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>log4j</groupId>
|
||||
@@ -82,7 +83,7 @@
|
||||
<artifactId>jmxri</artifactId>
|
||||
</exclusion>
|
||||
</exclusions>
|
||||
<scope>runtime</scope>
|
||||
<scope>provided</scope>
|
||||
</dependency>
|
||||
|
||||
<dependency>
|
||||
|
||||
@@ -12,6 +12,14 @@ public class ErlangMapReduceOperation implements MapReduceOperation {
|
||||
protected String language = "erlang";
|
||||
protected Map moduleFunction = new LinkedHashMap();
|
||||
|
||||
public ErlangMapReduceOperation() {
|
||||
}
|
||||
|
||||
public ErlangMapReduceOperation(String module, String function) {
|
||||
setModule(module);
|
||||
setFunction(function);
|
||||
}
|
||||
|
||||
public void setModule(String module) {
|
||||
moduleFunction.put("module", module);
|
||||
}
|
||||
|
||||
@@ -21,7 +21,7 @@ package org.springframework.datastore.riak.mapreduce;
|
||||
*/
|
||||
public interface MapReducePhase {
|
||||
|
||||
public enum Phase {
|
||||
public static enum Phase {
|
||||
MAP, REDUCE
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user