public void saveData()

in src/main/java/org/apache/sdap/ningester/writer/CassandraStore.java [43:49]


    public void saveData(List<? extends NexusTile> nexusTiles) {

        String query = "insert into " + this.tableName + " (tile_id, tile_blob) VALUES (?, ?)";
        cassandraTemplate.ingest(query, nexusTiles.stream()
                .map(nexusTile -> getCassandraRowFromTileData(nexusTile.getTile()))
                .collect(Collectors.toList()));
    }