per PR feedback, donât use import .*;
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/f1540b15 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/f1540b15 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/f1540b15 Branch: refs/heads/master Commit: f1540b15c2dcbb6c99cd9be90cbe2626b8ef49fc Parents: 9495cf5 Author: Steve Blackmon @steveblackmon <[email protected]> Authored: Wed Oct 5 18:06:00 2016 -0500 Committer: Steve Blackmon @steveblackmon <[email protected]> Committed: Wed Oct 5 18:06:00 2016 -0500 ---------------------------------------------------------------------- .../TwitterJsonDeleteActivityConverter.java | 2 +- .../TwitterJsonRetweetActivityConverter.java | 2 +- .../TwitterJsonTweetActivityConverter.java | 2 +- ...terJsonUserstreameventActivityConverter.java | 3 ++- .../FetchAndReplaceTwitterProcessor.java | 11 ++++++--- .../processor/TwitterEventProcessor.java | 13 +---------- .../twitter/provider/TwitterConfigurator.java | 8 +++---- .../provider/TwitterEventClassifier.java | 7 +++++- .../twitter/provider/TwitterStreamProvider.java | 24 +++++++++++++++----- .../provider/TwitterTimelineProvider.java | 16 +++++++++---- .../provider/TwitterTimelineProviderTask.java | 6 +++-- .../TwitterUserInformationProvider.java | 7 ++++-- .../test/TwitterDocumentClassifierTest.java | 6 ++++- .../twitter/test/TwitterObjectMapperIT.java | 5 ++-- 14 files changed, 69 insertions(+), 43 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonDeleteActivityConverter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonDeleteActivityConverter.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonDeleteActivityConverter.java index eb35b71..3e61ef9 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonDeleteActivityConverter.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonDeleteActivityConverter.java @@ -30,7 +30,7 @@ import org.apache.streams.twitter.pojo.Tweet; import java.io.Serializable; import java.util.List; -import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.*; +import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.updateActivity; /** http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonRetweetActivityConverter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonRetweetActivityConverter.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonRetweetActivityConverter.java index 22a4a58..30a1916 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonRetweetActivityConverter.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonRetweetActivityConverter.java @@ -28,7 +28,7 @@ import org.apache.streams.twitter.pojo.Retweet; import java.io.Serializable; import java.util.List; -import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.*; +import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.updateActivity; public class TwitterJsonRetweetActivityConverter implements ActivityConverter<Retweet>, Serializable { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonTweetActivityConverter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonTweetActivityConverter.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonTweetActivityConverter.java index 0b9f0ec..0997a7f 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonTweetActivityConverter.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonTweetActivityConverter.java @@ -28,7 +28,7 @@ import org.apache.streams.twitter.pojo.Tweet; import java.io.Serializable; import java.util.List; -import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.*; +import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.updateActivity; public class TwitterJsonTweetActivityConverter implements ActivityConverter<Tweet>, Serializable { http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonUserstreameventActivityConverter.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonUserstreameventActivityConverter.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonUserstreameventActivityConverter.java index 357c41c..b3647fa 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonUserstreameventActivityConverter.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/TwitterJsonUserstreameventActivityConverter.java @@ -30,7 +30,8 @@ import org.apache.streams.twitter.pojo.UserstreamEvent; import java.util.List; -import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.*; +import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.formatId; +import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.getProvider; /** http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java index 8c5f55b..8330167 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java @@ -28,21 +28,26 @@ import org.apache.streams.exceptions.ActivityConversionException; import org.apache.streams.pojo.json.Activity; import org.apache.streams.twitter.TwitterConfiguration; import org.apache.streams.twitter.TwitterStreamConfiguration; +import org.apache.streams.twitter.converter.StreamsTwitterMapper; import org.apache.streams.twitter.pojo.Delete; import org.apache.streams.twitter.pojo.Retweet; import org.apache.streams.twitter.pojo.Tweet; import org.apache.streams.twitter.provider.TwitterConfigurator; import org.apache.streams.twitter.provider.TwitterEventClassifier; -import org.apache.streams.twitter.converter.StreamsTwitterMapper; import org.apache.streams.twitter.provider.TwitterProviderUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import twitter4j.*; +import twitter4j.Status; +import twitter4j.Twitter; +import twitter4j.TwitterException; +import twitter4j.TwitterFactory; +import twitter4j.TwitterObjectFactory; import twitter4j.conf.ConfigurationBuilder; import java.util.List; -import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.*; +import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.getProvider; +import static org.apache.streams.twitter.converter.util.TwitterActivityUtil.updateActivity; /** * Given an Activity, fetches the tweet by the activity object id and replaces the existing activity with the converted activity http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java index 45f84ff..ed6b90a 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterEventProcessor.java @@ -18,27 +18,16 @@ package org.apache.streams.twitter.processor; -import com.fasterxml.jackson.core.JsonParseException; -import com.fasterxml.jackson.core.JsonParser; -import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.node.ObjectNode; -import com.google.common.base.Preconditions; import com.google.common.collect.Lists; -import org.apache.commons.lang3.StringUtils; import org.apache.streams.core.StreamsDatum; import org.apache.streams.core.StreamsProcessor; -import org.apache.streams.exceptions.ActivityConversionException; import org.apache.streams.jackson.StreamsJacksonMapper; -import org.apache.streams.twitter.converter.*; +import org.apache.streams.twitter.converter.StreamsTwitterMapper; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import java.io.IOException; import java.util.List; -import java.util.Queue; -import java.util.concurrent.BlockingQueue; -import java.util.concurrent.Callable; /** * This class performs conversion of a twitter event to a specified outClass http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java index 370960b..4b7b3ef 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterConfigurator.java @@ -19,17 +19,15 @@ package org.apache.streams.twitter.provider; import com.fasterxml.jackson.databind.ObjectMapper; -import com.google.common.collect.Lists; import com.typesafe.config.Config; -import com.typesafe.config.ConfigException; import com.typesafe.config.ConfigRenderOptions; -import org.apache.streams.config.StreamsConfigurator; -import org.apache.streams.twitter.*; +import org.apache.streams.twitter.TwitterConfiguration; +import org.apache.streams.twitter.TwitterStreamConfiguration; +import org.apache.streams.twitter.TwitterUserInformationConfiguration; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.io.IOException; -import java.util.List; /** * This class resolves TwitterConfiguration from typesafe config http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEventClassifier.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEventClassifier.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEventClassifier.java index f54dd0a..9466c2e 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEventClassifier.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEventClassifier.java @@ -24,8 +24,13 @@ import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import org.apache.commons.lang.StringUtils; import org.apache.streams.jackson.StreamsJacksonMapper; -import org.apache.streams.twitter.pojo.*; import org.apache.streams.twitter.converter.TwitterDateTimeFormat; +import org.apache.streams.twitter.pojo.Delete; +import org.apache.streams.twitter.pojo.FriendList; +import org.apache.streams.twitter.pojo.Retweet; +import org.apache.streams.twitter.pojo.Tweet; +import org.apache.streams.twitter.pojo.User; +import org.apache.streams.twitter.pojo.UserstreamEvent; import java.io.IOException; import java.io.Serializable; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java index 30e2b56..f584950 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java @@ -18,7 +18,6 @@ package org.apache.streams.twitter.provider; -import com.google.common.base.Optional; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; import com.google.common.collect.Queues; @@ -26,7 +25,11 @@ import com.twitter.hbc.ClientBuilder; import com.twitter.hbc.core.Constants; import com.twitter.hbc.core.Hosts; import com.twitter.hbc.core.HttpHosts; -import com.twitter.hbc.core.endpoint.*; +import com.twitter.hbc.core.endpoint.StatusesFilterEndpoint; +import com.twitter.hbc.core.endpoint.StatusesFirehoseEndpoint; +import com.twitter.hbc.core.endpoint.StatusesSampleEndpoint; +import com.twitter.hbc.core.endpoint.StreamingEndpoint; +import com.twitter.hbc.core.endpoint.UserstreamEndpoint; import com.twitter.hbc.httpclient.BasicClient; import com.twitter.hbc.httpclient.auth.Authentication; import com.twitter.hbc.httpclient.auth.BasicAuth; @@ -34,7 +37,12 @@ import com.twitter.hbc.httpclient.auth.OAuth1; import com.typesafe.config.Config; import org.apache.commons.lang.NotImplementedException; import org.apache.streams.config.StreamsConfigurator; -import org.apache.streams.core.*; +import org.apache.streams.core.DatumStatus; +import org.apache.streams.core.DatumStatusCountable; +import org.apache.streams.core.DatumStatusCounter; +import org.apache.streams.core.StreamsDatum; +import org.apache.streams.core.StreamsProvider; +import org.apache.streams.core.StreamsResultSet; import org.apache.streams.twitter.TwitterStreamConfiguration; import org.apache.streams.util.ComponentUtils; import org.joda.time.DateTime; @@ -45,10 +53,14 @@ import java.io.Serializable; import java.math.BigInteger; import java.util.List; import java.util.Queue; -import java.util.concurrent.*; +import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Future; +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; -import java.util.concurrent.locks.ReadWriteLock; -import java.util.concurrent.locks.ReentrantReadWriteLock; /** * TwitterStreamProvider wraps a hosebird client and passes recieved documents http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java index 61cddaf..2924623 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java @@ -22,7 +22,6 @@ import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; -import com.google.common.collect.Queues; import com.google.common.util.concurrent.Uninterruptibles; import com.typesafe.config.Config; import com.typesafe.config.ConfigFactory; @@ -38,22 +37,29 @@ import org.apache.streams.core.StreamsResultSet; import org.apache.streams.jackson.StreamsJacksonMapper; import org.apache.streams.twitter.TwitterUserInformationConfiguration; import org.apache.streams.twitter.converter.TwitterDateTimeFormat; -import org.apache.streams.twitter.pojo.Tweet; import org.apache.streams.util.ComponentUtils; import org.joda.time.DateTime; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import twitter4j.*; +import twitter4j.Status; +import twitter4j.Twitter; +import twitter4j.TwitterException; +import twitter4j.TwitterFactory; +import twitter4j.User; import twitter4j.conf.ConfigurationBuilder; import java.io.BufferedOutputStream; import java.io.File; -import java.io.FileNotFoundException; import java.io.FileOutputStream; import java.io.PrintStream; import java.io.Serializable; import java.math.BigInteger; -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Iterator; +import java.util.List; +import java.util.Objects; +import java.util.Queue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.LinkedBlockingQueue; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProviderTask.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProviderTask.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProviderTask.java index b8d5e1d..111d213 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProviderTask.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProviderTask.java @@ -23,12 +23,14 @@ import com.google.common.collect.Lists; import org.apache.streams.core.StreamsDatum; import org.apache.streams.jackson.StreamsJacksonMapper; import org.apache.streams.twitter.converter.TwitterDateTimeFormat; -import org.apache.streams.twitter.pojo.*; import org.apache.streams.util.ComponentUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import twitter4j.*; +import twitter4j.Paging; import twitter4j.Status; +import twitter4j.Twitter; +import twitter4j.TwitterException; +import twitter4j.TwitterObjectFactory; import java.util.List; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java index 4231f56..44f8a24 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterUserInformationProvider.java @@ -21,7 +21,6 @@ package org.apache.streams.twitter.provider; import com.fasterxml.jackson.databind.ObjectMapper; import com.google.common.base.Preconditions; import com.google.common.collect.Lists; -import com.google.common.collect.Queues; import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.MoreExecutors; import org.apache.commons.lang.NotImplementedException; @@ -52,7 +51,11 @@ import java.util.ArrayList; import java.util.Iterator; import java.util.List; import java.util.Queue; -import java.util.concurrent.*; +import java.util.concurrent.ArrayBlockingQueue; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterDocumentClassifierTest.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterDocumentClassifierTest.java b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterDocumentClassifierTest.java index 1bf3691..044fe3c 100644 --- a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterDocumentClassifierTest.java +++ b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterDocumentClassifierTest.java @@ -19,7 +19,11 @@ package org.apache.streams.twitter.test; import org.apache.streams.twitter.converter.TwitterDocumentClassifier; -import org.apache.streams.twitter.pojo.*; +import org.apache.streams.twitter.pojo.Delete; +import org.apache.streams.twitter.pojo.Follow; +import org.apache.streams.twitter.pojo.Retweet; +import org.apache.streams.twitter.pojo.Tweet; +import org.apache.streams.twitter.pojo.User; import org.junit.Assert; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/f1540b15/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterObjectMapperIT.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterObjectMapperIT.java b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterObjectMapperIT.java index 4da2af2..e8bbf49 100644 --- a/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterObjectMapperIT.java +++ b/streams-contrib/streams-provider-twitter/src/test/java/org/apache/streams/twitter/test/TwitterObjectMapperIT.java @@ -31,7 +31,6 @@ import org.apache.streams.twitter.pojo.Delete; import org.apache.streams.twitter.pojo.Retweet; import org.apache.streams.twitter.pojo.Tweet; import org.junit.Assert; -import org.junit.Ignore; import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -40,7 +39,9 @@ import java.io.BufferedReader; import java.io.InputStream; import java.io.InputStreamReader; -import static org.hamcrest.CoreMatchers.*; +import static org.hamcrest.CoreMatchers.is; +import static org.hamcrest.CoreMatchers.not; +import static org.hamcrest.CoreMatchers.nullValue; import static org.hamcrest.Matchers.greaterThan; import static org.junit.Assert.assertThat;
