Revision 56964
Added by Antonis Lempesis over 4 years ago
PiwikStatsDB.java | ||
---|---|---|
145 | 145 |
PreparedStatement prepStatem = conn.prepareStatement("INSERT INTO piwiklog (source, id_visit, country, action, url, entity_id, source_item_type, timestamp, referrer_name, agent) VALUES (?,?,?,?,?,?,?,?,?,?)"); |
146 | 146 |
int batch_size = 0; |
147 | 147 |
for (String jsonFile : jsonFiles) { |
148 |
|
|
149 |
log.debug("Processing log file: " + jsonFile); |
|
150 |
|
|
148 | 151 |
JSONParser parser = new JSONParser(); |
149 | 152 |
JSONArray jsonArray = (JSONArray) parser.parse(readHDFSFile(jsonFile)); |
150 | 153 |
|
Also available in: Unified diff
reduced the size of each repository log file to avoid heap space errors