in src/main/java/org/apache/sdap/ningester/writer/DynamoStore.java [43:57]
public void saveData(List<? extends NexusTile> nexusTiles) {
Table table = dynamoDB.getTable(tableName);
for (NexusTile tile : nexusTiles) {
String tileId = getTileId(tile);
byte[] tileData = getTileData(tile);
try {
table.putItem(new Item().withPrimaryKey(primaryKey, tileId).withBinary("data", tileData));
} catch (Exception e) {
throw new DataStoreException("Unable to add item: " + tileId, e);
}
}
}