public void saveData()

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);
            }
        }
    }