diff --git a/aerospike/src/main/java/com/yahoo/ycsb/db/AerospikeClient.java b/aerospike/src/main/java/com/yahoo/ycsb/db/AerospikeClient.java index f48523b3beec8a014c51195f730bb46a0d0e4010..3678f973be8ab8878dfb0b2d20e346f2b082b4b1 100644 --- a/aerospike/src/main/java/com/yahoo/ycsb/db/AerospikeClient.java +++ b/aerospike/src/main/java/com/yahoo/ycsb/db/AerospikeClient.java @@ -44,6 +44,7 @@ public class AerospikeClient extends com.yahoo.ycsb.DB { private WritePolicy updatePolicy = new WritePolicy(); private WritePolicy deletePolicy = new WritePolicy(); + @Override public void init() throws DBException { insertPolicy.recordExistsAction = RecordExistsAction.CREATE_ONLY; updatePolicy.recordExistsAction = RecordExistsAction.UPDATE_ONLY; @@ -80,6 +81,7 @@ public class AerospikeClient extends com.yahoo.ycsb.DB { } } + @Override public void cleanup() throws DBException { client.close(); }