Skip to content

Commit aeae6cd

Browse files
committed
added partition to simple generator map
1 parent c2a08c3 commit aeae6cd

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@
1212

1313
<groupId>com.redislabs</groupId>
1414
<artifactId>riot</artifactId>
15-
<version>0.4.5</version>
15+
<version>0.4.6</version>
1616
<packaging>jar</packaging>
1717
<name>RIOT</name>
1818
<description>Redis Input/Output Tool</description>

src/main/java/com/redislabs/riot/generator/SimpleGeneratorReader.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -57,6 +57,7 @@ private long start(long total) {
5757
@Override
5858
protected Map<String, Object> doRead() throws Exception {
5959
Map<String, Object> map = new HashMap<>();
60+
map.put(IndexedPartitioner.PARTITION_KEY, partitionIndex.get());
6061
for (int index = 0; index < fieldCount; index++) {
6162
int fieldIndex = index + 1;
6263
String fieldName = "field" + fieldIndex;

0 commit comments

Comments
 (0)