in src/main/java/com/netflix/bdp/s3mper/metastore/impl/DynamoDBMetastore.java [405:421]
public UpdateItemResult call() throws Exception {
UpdateItemRequest update = new UpdateItemRequest();
update.setTableName(tableName);
update.setKey(new Key(new AttributeValue(normalize(path.getParent())), new AttributeValue(path.getName())));
Map<String, AttributeValueUpdate> items = new HashMap<String, AttributeValueUpdate>();
items.put(DELETE_MARKER, new AttributeValueUpdate().withValue(new AttributeValue().withS(Boolean.TRUE.toString())));
items.put(EPOCH_VALUE, new AttributeValueUpdate().withValue(new AttributeValue().withN(System.currentTimeMillis()+"")));
update.setAttributeUpdates(items);
if(log.isDebugEnabled()) {
log.debug("Marking DynamoDB path deleted: " + path.toUri());
}
return db.updateItem(update);
}