Fixed Twitter demo for App Builder
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/f40ba346 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/f40ba346 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/f40ba346 Branch: refs/heads/feature-AppData Commit: f40ba346ae660e1b89de1ebbb3f8e1f7ba31cad0 Parents: a028069 Author: Timothy Farkas <[email protected]> Authored: Thu Aug 6 16:07:03 2015 -0700 Committer: thomas <[email protected]> Committed: Thu Aug 6 22:14:05 2015 -0700 ---------------------------------------------------------------------- .../contrib/twitter/TwitterSampleInput.java | 32 ++++++++++++++++++++ demos/pom.xml | 4 +-- demos/twitter/pom.xml | 2 +- .../demos/twitter/WindowedTopCounter.java | 5 +++ 4 files changed, 40 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/f40ba346/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java b/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java index 916bea8..9daef7f 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java +++ b/contrib/src/main/java/com/datatorrent/contrib/twitter/TwitterSampleInput.java @@ -293,6 +293,14 @@ public class TwitterSampleInput implements InputOperator, ActivationListener<Ope } /** + * @return the consumerKey + */ + public String getConsumerKey() + { + return consumerKey; + } + + /** * @param consumerKey the consumerKey to set */ public void setConsumerKey(String consumerKey) @@ -301,6 +309,14 @@ public class TwitterSampleInput implements InputOperator, ActivationListener<Ope } /** + * @return the consumerSecret + */ + public String getConsumerSecret() + { + return consumerSecret; + } + + /** * @param consumerSecret the consumerSecret to set */ public void setConsumerSecret(String consumerSecret) @@ -309,6 +325,14 @@ public class TwitterSampleInput implements InputOperator, ActivationListener<Ope } /** + * @return the accessToken + */ + public String getAccessToken() + { + return accessToken; + } + + /** * @param accessToken the accessToken to set */ public void setAccessToken(String accessToken) @@ -317,6 +341,14 @@ public class TwitterSampleInput implements InputOperator, ActivationListener<Ope } /** + * @return the accessTokenSecret + */ + public String getAccessTokenSecret() + { + return accessTokenSecret; + } + + /** * @param accessTokenSecret the accessTokenSecret to set */ public void setAccessTokenSecret(String accessTokenSecret) http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/f40ba346/demos/pom.xml ---------------------------------------------------------------------- diff --git a/demos/pom.xml b/demos/pom.xml index 64c6c4a..c17120f 100644 --- a/demos/pom.xml +++ b/demos/pom.xml @@ -173,7 +173,7 @@ <dependency> <groupId>com.datatorrent</groupId> <artifactId>malhar-library</artifactId> - <version>${datatorrent.version}</version> + <version>${project.version}</version> <exclusions> <exclusion> <groupId>*</groupId> @@ -184,7 +184,7 @@ <dependency> <groupId>com.datatorrent</groupId> <artifactId>malhar-library</artifactId> - <version>${datatorrent.version}</version> + <version>${project.version}</version> <classifier>tests</classifier> <scope>test</scope> <exclusions> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/f40ba346/demos/twitter/pom.xml ---------------------------------------------------------------------- diff --git a/demos/twitter/pom.xml b/demos/twitter/pom.xml index c55ee79..8a0bec9 100644 --- a/demos/twitter/pom.xml +++ b/demos/twitter/pom.xml @@ -54,7 +54,7 @@ <dependency> <groupId>com.datatorrent</groupId> <artifactId>malhar-contrib</artifactId> - <version>${datatorrent.version}</version> + <version>${project.version}</version> <exclusions> <exclusion> <groupId>*</groupId> http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/f40ba346/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java ---------------------------------------------------------------------- diff --git a/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java b/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java index 2edf7fd..3354ed4 100644 --- a/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java +++ b/demos/twitter/src/main/java/com/datatorrent/demos/twitter/WindowedTopCounter.java @@ -179,6 +179,11 @@ public class WindowedTopCounter<T> extends BaseOperator topCount = count; } + public int getTopCount() + { + return topCount; + } + /** * @return the windows */
