diff options
Diffstat (limited to 'src/main')
-rw-r--r-- | src/main/TweetCounter.java | 7 | ||||
-rw-r--r-- | src/main/TweetShell.java | 14 |
2 files changed, 4 insertions, 17 deletions
diff --git a/src/main/TweetCounter.java b/src/main/TweetCounter.java index 4c348b3..e922c5c 100644 --- a/src/main/TweetCounter.java +++ b/src/main/TweetCounter.java @@ -28,12 +28,9 @@ public class TweetCounter implements ResultListener { @Override public void tweetGenerated(JSONObject obj) { tweetCount++; - } - - @Override - public void profileGenerated(JSONObject obj) { try { - String screen_name = obj.getString("screen_name"); + JSONObject userObj = obj.getJSONObject("user"); + String screen_name = userObj.getString("screen_name"); users.add(screen_name); } catch (JSONException ex) { LOGGER.log(Level.WARNING, "Profile is missing data", ex); diff --git a/src/main/TweetShell.java b/src/main/TweetShell.java index 608a15a..fae4125 100644 --- a/src/main/TweetShell.java +++ b/src/main/TweetShell.java @@ -97,15 +97,6 @@ public class TweetShell implements TwitterApi.PinSupplier { } } - @Override - public void profileGenerated(JSONObject obj) { - try { - System.out.println("Got user: " + obj.getString("name")); - } catch (JSONException ex) { - getLogger().log(Level.SEVERE, "Failed to parse user", ex); - } - } - private Logger getLogger() { return Logger.getLogger(getClass().getName()); } @@ -429,7 +420,6 @@ public class TweetShell implements TwitterApi.PinSupplier { if (DataWriter.class.isAssignableFrom(rlCls)) { Configuration config = Configuration.getConfig(); - String profilesFilename = config.getProperty(DataWriter.CFG_PROFILE_FILENAME); String tweetsFilename = config.getProperty(DataWriter.CFG_TWEETS_FILENAME); try { DataWriter dw; @@ -437,10 +427,10 @@ public class TweetShell implements TwitterApi.PinSupplier { // compressed stream, convert by default (removing orig) boolean convertUncompressed = Boolean.parseBoolean( config.getProperty("convert-uncompressed", "true")); - dw = new CompressableDataWriter(profilesFilename, + dw = new CompressableDataWriter( tweetsFilename, convertUncompressed); } else { - dw = new DataWriter(profilesFilename, tweetsFilename); + dw = new DataWriter(tweetsFilename); } dw.open(); resultListeners.register(dw); |