Permalink
Browse files

gh-97 Bug fixes in dynamodb plugin

I have fixed a bug in insert() and delete() methods.There are also
some cosmetic changes to readme and properties files.
  • Loading branch information...
1 parent 3827d9a commit 9fef32a19fb7c9161796b30439d3bd20933f391b @jananin jananin committed with Michi Mutsuzaki Oct 22, 2012
Showing with 11 additions and 8 deletions.
  1. +1 −1 .gitignore
  2. +1 −1 bin/ycsb
  3. +5 −2 dynamodb/README
  4. +1 −1 dynamodb/conf/dynamodb.properties
  5. +3 −3 dynamodb/src/main/java/com/yahoo/ycsb/db/DynamoDBClient.java
View
@@ -1 +1 @@
-/elasticsearch/target/
+/elasticsearch/target/
View
@@ -40,7 +40,7 @@ DATABASES = {
"nosqldb" : "com.yahoo.ycsb.db.NoSqlDbClient",
"orientdb" : "com.yahoo.ycsb.db.OrientDBClient",
"redis" : "com.yahoo.ycsb.db.RedisClient",
- "voldemort" : "com.yahoo.ycsb.db.VoldemortClient",
+ "voldemort" : "com.yahoo.ycsb.db.VoldemortClient",
}
OPTIONS = {
View
@@ -3,10 +3,13 @@ CONFIGURE
YCSB_HOME - YCSB home directory
DYNAMODB_HOME - Amazon DynamoDB package files
+Please refer to https://github.com/brianfrankcooper/YCSB/wiki/Using-the-Database-Libraries
+for more information on setup.
+
BENCHMARK
-$YCSB_HOME/bin/ycsb load dynamodb -P worklaods/workloada -P dynamodb.properties
-$YCSB_HOME/bin/ycsb run dynamodb -P worklaods/workloada -P dynamodb.properties
+$YCSB_HOME/bin/ycsb load dynamodb -P workloads/workloada -P dynamodb.properties
+$YCSB_HOME/bin/ycsb run dynamodb -P workloads/workloada -P dynamodb.properties
PROPERTIES
@@ -17,7 +17,7 @@
#dynamodb.endpoint = http://dynamodb.us-east-1.amazonaws.com
# Strongly recommended to set to uniform.Refer FAQs in README
-#requestdistribution = uniform
+#requestdistribution = uniform
# Enable/disable debug messages.Defaults to false
# "true" or "false"
@@ -200,7 +200,7 @@ public int scan(String table, String startkey, int recordcount,
}
startKey = res.getLastEvaluatedKey();
- }
+ }
return OK;
}
@@ -249,7 +249,7 @@ public int insert(String table, String key,HashMap<String, ByteIterator> values)
logger.error(ex.getMessage());
return CLIENT_ERROR;
}
- return res.getConsumedCapacityUnits().intValue();
+ return OK;
}
@Override
@@ -267,7 +267,7 @@ public int delete(String table, String key) {
logger.error(ex.getMessage());
return CLIENT_ERROR;
}
- return res.getConsumedCapacityUnits().intValue();
+ return OK;
}
private static Map<String, AttributeValue> createAttributes(

0 comments on commit 9fef32a

Please sign in to comment.