This is an automated email from the ASF dual-hosted git repository. sblackmon pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/streams.git
commit 76a9f922f68efd9633c3a7eab5af3d7424797bbc Author: sblackmon <[email protected]> AuthorDate: Wed Mar 11 19:39:48 2020 -0500 STREAMS-657 fix javadoc error during release process resolves STREAMS-657 --- .../streams/converter/ActivityConverterProcessor.java | 4 ++-- .../apache/streams/converter/ActivityConverterUtil.java | 6 +++--- .../converter/ActivityObjectConverterProcessor.java | 4 ++-- .../streams/converter/ActivityObjectConverterUtil.java | 6 +++--- .../apache/streams/converter/BaseDocumentClassifier.java | 2 +- .../streams/converter/BaseObjectNodeActivityConverter.java | 2 +- .../converter/BaseObjectNodeActivityObjectConverter.java | 2 +- .../streams/converter/BaseStringActivityConverter.java | 2 +- .../converter/BaseStringActivityObjectConverter.java | 2 +- .../apache/streams/converter/HoconConverterProcessor.java | 2 +- .../apache/streams/converter/TypeConverterProcessor.java | 4 ++-- .../org/apache/streams/config/ComponentConfigurator.java | 4 ++-- .../org/apache/streams/s3/S3ObjectInputStreamWrapper.java | 4 ++-- .../processor/DocumentToMetadataProcessor.java | 2 +- .../streams/fullcontact/FullContactSocialGraph.scala | 8 ++++---- .../streams/fullcontact/PersonEnrichmentProcessor.scala | 14 +++++++------- .../jackson/CleanAdditionalPropertiesProcessor.java | 2 +- .../main/java/org/apache/streams/urls/LinkResolver.java | 4 ++-- .../facebook/provider/page/FacebookPageProvider.java | 8 ++++---- .../streams/gplus/provider/GPlusUserActivityProvider.java | 10 +++++----- .../streams/gplus/provider/GPlusUserDataProvider.java | 10 +++++----- .../gplus/providers/TestGPlusUserActivityCollector.java | 6 +++--- .../instagram/provider/InstagramCommentsProvider.java | 8 ++++---- .../streams/instagram/provider/InstagramDataCollector.java | 2 +- .../recentmedia/InstagramRecentMediaCollector.java | 2 +- .../provider/recentmedia/InstagramRecentMediaProvider.java | 10 +++++----- .../provider/userinfo/InstagramUserInfoProvider.java | 10 +++++----- .../java/org/apache/streams/moreover/MoreoverProvider.java | 6 +++--- .../org/apache/streams/rss/provider/RssStreamProvider.java | 6 +++--- .../apache/streams/rss/provider/RssStreamProviderTask.java | 6 +++--- .../apache/streams/sysomos/provider/RequestBuilder.java | 2 +- .../apache/streams/sysomos/provider/SysomosProvider.java | 8 ++++---- .../streams/twitter/converter/StreamsTwitterMapper.java | 2 +- .../streams/twitter/processor/TwitterTypeConverter.java | 2 +- .../streams/twitter/provider/SevenDaySearchProvider.java | 8 ++++---- .../streams/twitter/provider/ThirtyDaySearchProvider.java | 8 ++++---- .../streams/twitter/provider/TwitterEngagersProvider.java | 8 ++++---- .../streams/twitter/provider/TwitterFollowingProvider.java | 8 ++++---- .../streams/twitter/provider/TwitterStreamProvider.java | 8 ++++---- .../streams/twitter/provider/TwitterTimelineProvider.java | 8 ++++---- .../twitter/provider/TwitterUserInformationProvider.java | 8 ++++---- .../streams/youtube/provider/YoutubeChannelProvider.java | 8 ++++---- .../youtube/provider/YoutubeUserActivityProvider.java | 8 ++++---- .../cassandra/StreamsCassandraResourceGenerator.java | 2 +- .../cassandra/StreamsCassandraResourceGeneratorMojo.java | 2 +- .../StreamsElasticsearchResourceGenerator.java | 2 +- .../plugins/hbase/StreamsHbaseResourceGenerator.java | 2 +- .../streams/plugins/hive/StreamsHiveResourceGenerator.java | 2 +- .../streams/plugins/pig/StreamsPigResourceGenerator.java | 4 ++-- .../apache/streams/plugins/StreamsPojoSourceGenerator.java | 4 ++-- .../streams/plugins/StreamsScalaSourceGenerator.java | 4 ++-- .../java/org/apache/streams/data/ActivityConverter.java | 12 ++++++------ .../org/apache/streams/data/ActivityObjectConverter.java | 2 +- .../java/org/apache/streams/data/ActivitySerializer.java | 2 +- .../java/org/apache/streams/data/util/ActivityUtil.java | 2 +- .../streams/jackson/StreamsDateTimeDeserializer.java | 2 +- .../org/apache/streams/jackson/StreamsDateTimeFormat.java | 2 +- .../org/apache/streams/jackson/StreamsJacksonMapper.java | 4 ++-- .../org/apache/streams/jackson/StreamsJacksonModule.java | 2 +- .../org/apache/streams/local/queues/ThroughputQueue.java | 2 +- .../java/org/apache/streams/util/SerializationUtil.java | 4 ++-- .../streams/util/api/requests/backoff/BackOffStrategy.java | 2 +- .../oauth/tokens/tokenmanager/impl/BasicTokenManager.java | 2 +- .../java/org/apache/streams/util/schema/SchemaStore.java | 2 +- 64 files changed, 153 insertions(+), 153 deletions(-) diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterProcessor.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterProcessor.java index b116998..db7dac5 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterProcessor.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterProcessor.java @@ -34,12 +34,12 @@ import java.util.List; * ActivityConverterProcessor is a utility processor for converting any datum document * to an Activity. * - * <p/> + * <p></p> * By default it will handle string json and objectnode representation of existing Activities, * translating them into the POJO representation(s) preferred by each registered/detected * ActivityConverter. * - * <p/> + * <p></p> * To use this capability without a dedicated stream processor, just use ActivityConverterUtil. */ public class ActivityConverterProcessor implements StreamsProcessor { diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterUtil.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterUtil.java index c535710..2b77337 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterUtil.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityConverterUtil.java @@ -47,16 +47,16 @@ import java.util.concurrent.ConcurrentHashMap; * ActivityConverterUtil converts document into all possible Activity * representations based on registered DocumentClassifiers and ActivityConverters. * - * <p/> + * <p></p> * Implementations and contributed modules may implement DocumentClassifiers * and ActivityConverters to translate additional document types into desired * Activity formats. * - * <p/> + * <p></p> * A DocumentClassifier's reponsibility is to recognize document formats and label them, * using a jackson-compatible POJO class. * - * <p/> + * <p></p> * An ActivityConverter's reponsibility is to converting a raw document associated with an * incoming POJO class into an activity. * diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityObjectConverterProcessor.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityObjectConverterProcessor.java index bb348b6..bcc0c6f 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityObjectConverterProcessor.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityObjectConverterProcessor.java @@ -34,12 +34,12 @@ import java.util.List; * ActivityObjectConverterProcessor is a utility processor for converting any datum document * to an Activity. * - * <p/> + * <p></p> * By default it will handle string json and objectnode representation of existing Activities, * translating them into the POJO representation(s) preferred by each registered/detected * ActivityConverter. * - * <p/> + * <p></p> * To use this capability without a dedicated stream processor, just use ActivityConverterUtil. */ public class ActivityObjectConverterProcessor implements StreamsProcessor { diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityObjectConverterUtil.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityObjectConverterUtil.java index 49cdfcb..23c7396 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityObjectConverterUtil.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/ActivityObjectConverterUtil.java @@ -45,16 +45,16 @@ import java.util.concurrent.ConcurrentHashMap; * ActivityObjectConverterUtil converts document into all possible ActivityObject * representations based on registered DocumentClassifiers and ActivityObjectConverters. * - * <p/> + * <p></p> * Implementations and contributed modules may implement DocumentClassifiers * and ActivityObjectConverters to translate additional document types into desired * ActivityObject formats. * - * <p/> + * <p></p> * A DocumentClassifier's reponsibility is to recognize document formats and label them, * using a jackson-compatible POJO class. * - * <p/> + * <p></p> * An ActivityObjectConverter's reponsibility is to converting a raw document associated with an * incoming POJO class into an activity object. * diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseDocumentClassifier.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseDocumentClassifier.java index cd99b2f..2373b0f 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseDocumentClassifier.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseDocumentClassifier.java @@ -36,7 +36,7 @@ import java.util.List; /** * Ensures generic String and ObjectNode documents can be converted to Activity * - * <p/> + * <p></p> * BaseDocumentClassifier is included by default in all * @see org.apache.streams.converter.ActivityConverterProcessor * diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java index 6808256..1b75e70 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityConverter.java @@ -36,7 +36,7 @@ import java.util.List; /** * Ensures generic ObjectNode representation of an Activity can be converted to Activity * - * <p/> + * <p></p> * BaseObjectNodeActivityConverter is included by default in all * @see org.apache.streams.converter.ActivityConverterProcessor * diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityObjectConverter.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityObjectConverter.java index a38585e..d938fad 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityObjectConverter.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseObjectNodeActivityObjectConverter.java @@ -30,7 +30,7 @@ import com.fasterxml.jackson.databind.node.ObjectNode; /** * Ensures generic ObjectNode representation of an Activity can be converted to Activity. * - * <p/> + * <p></p> * BaseObjectNodeActivityConverter is included by default in all * @see {@link ActivityConverterProcessor} * diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java index 74d5177..a1677a2 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityConverter.java @@ -36,7 +36,7 @@ import java.util.List; /** * Ensures generic String Json representation of an Activity can be converted to Activity * - * <p/> + * <p></p> * BaseObjectNodeActivityConverter is included by default in all * {@link org.apache.streams.converter.ActivityConverterProcessor} * diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityObjectConverter.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityObjectConverter.java index 5434c7d..6ae9e82 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityObjectConverter.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/BaseStringActivityObjectConverter.java @@ -29,7 +29,7 @@ import com.fasterxml.jackson.databind.ObjectMapper; /** * Ensures generic ObjectNode representation of an Activity can be converted to Activity. * - * <p/> + * <p></p> * BaseObjectNodeActivityConverter is included by default in all * {@link ActivityConverterProcessor} * diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/HoconConverterProcessor.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/HoconConverterProcessor.java index 41de6c5..0af137a 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/HoconConverterProcessor.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/HoconConverterProcessor.java @@ -33,7 +33,7 @@ import java.util.List; * HoconConverterProcessor is a utility processor for converting any datum document * with translation rules expressed as HOCON in the classpath or at a URL. * - * <p/> + * <p></p> * To use this capability without a dedicated stream processor, just use HoconConverterUtil. */ public class HoconConverterProcessor implements StreamsProcessor { diff --git a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/TypeConverterProcessor.java b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/TypeConverterProcessor.java index bd0b304..a7720be 100644 --- a/streams-components/streams-converters/src/main/java/org/apache/streams/converter/TypeConverterProcessor.java +++ b/streams-components/streams-converters/src/main/java/org/apache/streams/converter/TypeConverterProcessor.java @@ -35,11 +35,11 @@ import java.util.List; /** * TypeConverterProcessor converts between String json and jackson-compatible POJO objects. * - * <p/> + * <p></p> * Activity is one supported jackson-compatible POJO, so JSON String and objects with structual similarities * to Activity can be converted to Activity objects. * - * <p/> + * <p></p> * However, conversion to Activity should probably use {@link org.apache.streams.converter.ActivityConverterProcessor} * */ diff --git a/streams-config/src/main/java/org/apache/streams/config/ComponentConfigurator.java b/streams-config/src/main/java/org/apache/streams/config/ComponentConfigurator.java index dcacb4a..e6a92f1 100644 --- a/streams-config/src/main/java/org/apache/streams/config/ComponentConfigurator.java +++ b/streams-config/src/main/java/org/apache/streams/config/ComponentConfigurator.java @@ -37,10 +37,10 @@ import java.util.List; /** * ComponentConfigurator supplies serializable configuration beans derived from a specified typesafe path or object. * - * <p/> + * <p></p> * Typically a component will select a 'default' typesafe path to be used if no other path or object is provided. * - * <p/> + * <p></p> * For example, streams-persist-elasticsearch will use 'elasticsearch' by default, but an implementation * such as github.com/apache/streams-examples/local/elasticsearch-reindex * can resolve a reader from elasticsearch.source diff --git a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java index e70c361..7ca3b90 100644 --- a/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java +++ b/streams-contrib/streams-amazon-aws/streams-persist-s3/src/main/java/org/apache/streams/s3/S3ObjectInputStreamWrapper.java @@ -35,10 +35,10 @@ import java.io.InputStream; * and transfer the entire file. If you are only reading the first 50 lines of a 5,000,000 line file * this becomes problematic. * - * <p/> + * <p></p> * This class operates as a wrapper to fix the aforementioned nuances. * - * <p/> + * <p></p> * Reference: * http://stackoverflow.com/questions/17782937/connectionpooltimeoutexception-when-iterating-objects-in-s3 */ diff --git a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DocumentToMetadataProcessor.java b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DocumentToMetadataProcessor.java index f1dc04a..5d2f95c 100644 --- a/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DocumentToMetadataProcessor.java +++ b/streams-contrib/streams-persist-elasticsearch/src/main/java/org/apache/streams/elasticsearch/processor/DocumentToMetadataProcessor.java @@ -36,7 +36,7 @@ import java.util.Map; /** * Moves a json representation of metadata out of the document to the metadata field. * - * <p/> + * <p></p> * This is useful if you have a list of document metadata references in the document field, * for example loaded from a file, and need them in the metadata field. */ diff --git a/streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/FullContactSocialGraph.scala b/streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/FullContactSocialGraph.scala index 4d5e1af..dc1bc62 100644 --- a/streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/FullContactSocialGraph.scala +++ b/streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/FullContactSocialGraph.scala @@ -48,16 +48,16 @@ object FullContactSocialGraph { /** * To use from command line: * - * <p/> + * <p></p> * java -cp streams-dist-jar-with-dependencies.jar -Dconfig.file=application.conf org.apache.streams.fullcontact.SocialGraphCli * - * <p/> + * <p></p> * Input stream should contain a series of json-serialized `PersonSummary` objects. * - * <p/> + * <p></p> * Output stream will contain a TTL-serialized social graph. * - * <p/> + * <p></p> * Input to the process is: * A file if application.conf contains an 'input' key * A file if -Dinput= is specified diff --git a/streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/PersonEnrichmentProcessor.scala b/streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/PersonEnrichmentProcessor.scala index d984ea6..beb6c30 100644 --- a/streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/PersonEnrichmentProcessor.scala +++ b/streams-contrib/streams-processor-fullcontact/src/main/scala/org/apache/streams/fullcontact/PersonEnrichmentProcessor.scala @@ -51,25 +51,25 @@ object PersonEnrichmentProcessor { /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * org.apache.streams.fullcontact.config.FullContactConfiguration.token = "" * - * <p/> + * <p></p> * Launch syntax: * - * <p/> + * <p></p> * java -cp streams-dist-jar-with-dependencies.jar -Dconfig.file=./application.conf org.apache.streams.fullcontact.provider.PersonEnrichmentProcessor * - * <p/> + * <p></p> * Input stream should contain a series of new-line-seperated json-serialized `EnrichPersonRequest` objects. * - * <p/> + * <p></p> * Output stream will contain a series of new-line-seperated json-serialized `PersonSummary` objects. * - * <p/> + * <p></p> * Input to the process is: * A file if application.conf contains an 'input' key * A file if -Dinput= is specified diff --git a/streams-contrib/streams-processor-jackson/src/main/java/org/apache/streams/jackson/CleanAdditionalPropertiesProcessor.java b/streams-contrib/streams-processor-jackson/src/main/java/org/apache/streams/jackson/CleanAdditionalPropertiesProcessor.java index 21a1d49..60ba25e 100644 --- a/streams-contrib/streams-processor-jackson/src/main/java/org/apache/streams/jackson/CleanAdditionalPropertiesProcessor.java +++ b/streams-contrib/streams-processor-jackson/src/main/java/org/apache/streams/jackson/CleanAdditionalPropertiesProcessor.java @@ -37,7 +37,7 @@ import java.util.Map; * This processor walks an input objectnode and corrects any artifacts * that may have occured from improper serialization of jackson beans. * - * <p/> + * <p></p> * The logic is also available for inclusion in other module via static import. */ public class CleanAdditionalPropertiesProcessor implements StreamsProcessor { diff --git a/streams-contrib/streams-processor-urls/src/main/java/org/apache/streams/urls/LinkResolver.java b/streams-contrib/streams-processor-urls/src/main/java/org/apache/streams/urls/LinkResolver.java index cefac6f..8f174db 100644 --- a/streams-contrib/streams-processor-urls/src/main/java/org/apache/streams/urls/LinkResolver.java +++ b/streams-contrib/streams-processor-urls/src/main/java/org/apache/streams/urls/LinkResolver.java @@ -46,7 +46,7 @@ public class LinkResolver implements Serializable { * can happen. If you notice a redirect that was not followed to the proper place please * submit a bug at : * https://issues.apache.org/jira/browse/STREAMS - * <p/> + * <p></p> * Purpose URL * ------------- ---------------------------------------------------------------- * [Status Codes] http://www.w3.org/Protocols/rfc2616/rfc2616-sec10.html @@ -408,7 +408,7 @@ public class LinkResolver implements Serializable { /** * Goal is to get the different parts of the URL path. This can be used * in a classifier to help us determine if we are working with - * <p/> + * <p></p> * Reference: * http://stackoverflow.com/questions/10046178/pattern-matching-for-url-classification * diff --git a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/page/FacebookPageProvider.java b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/page/FacebookPageProvider.java index 998e0b6..20041bc 100644 --- a/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/page/FacebookPageProvider.java +++ b/streams-contrib/streams-provider-facebook/src/main/java/org/apache/streams/facebook/provider/page/FacebookPageProvider.java @@ -51,16 +51,16 @@ import java.util.concurrent.TimeUnit; * Streams Provider which collects Page Profiles in the ID List contained in the * FacebookConfiguration object * - * <p/> + * <p></p> * To use from command line, * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.facebook.provider.page.FacebookPageProvider -Dexec.args="application.conf pages.json" * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * * <p> diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserActivityProvider.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserActivityProvider.java index d2fafbd..f6cf403 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserActivityProvider.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserActivityProvider.java @@ -45,22 +45,22 @@ import java.util.concurrent.TimeUnit; /** * Retrieve recent activity from a list of accounts. * - * <p/> + * <p></p> * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * gplus.oauth.pathToP12KeyFile * gplus.oauth.serviceAccountEmailAddress * gplus.apiKey * gplus.googlePlusUsers * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.gplus.provider.GPlusUserActivityProvider -Dexec.args="application.conf activity.json" */ public class GPlusUserActivityProvider extends AbstractGPlusProvider { diff --git a/streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserDataProvider.java b/streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserDataProvider.java index 2b4c25f..b624989 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserDataProvider.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/main/java/org/apache/streams/gplus/provider/GPlusUserDataProvider.java @@ -47,22 +47,22 @@ import java.util.concurrent.TimeUnit; /** * Retrieve current profile status for a list of accounts. * - * <p/> + * <p></p> * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * gplus.oauth.pathToP12KeyFile * gplus.oauth.serviceAccountEmailAddress * gplus.apiKey * gplus.googlePlusUsers * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.gplus.provider.GPlusUserDataProvider -Dexec.args="application.conf profiles.json" */ public class GPlusUserDataProvider extends AbstractGPlusProvider { diff --git a/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/providers/TestGPlusUserActivityCollector.java b/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/providers/TestGPlusUserActivityCollector.java index 47ac3f6..84d3d52 100644 --- a/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/providers/TestGPlusUserActivityCollector.java +++ b/streams-contrib/streams-provider-google/google-gplus/src/test/java/org/apache/streams/gplus/providers/TestGPlusUserActivityCollector.java @@ -122,13 +122,13 @@ public class TestGPlusUserActivityCollector extends RandomizedTest { /** * Creates a randomized activity and randomized date range. - * <p/> + * <p></p> * The activity feed is separated into three chunks, * |. . . data too recent to be in date range . . .||. . . data in date range. . .||. . . data too old to be in date range| * [index 0, ............................................................................................., index length-1] - * <p/> + * <p></p> * Inside of those chunks data has no order, but the list is ordered by those three chunks. - * <p/> + * <p></p> * The test will check to see if the num of data in the date range make onto the output queue. */ @Test diff --git a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramCommentsProvider.java b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramCommentsProvider.java index 587b4a7..319a409 100644 --- a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramCommentsProvider.java +++ b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramCommentsProvider.java @@ -65,18 +65,18 @@ public class InstagramCommentsProvider extends InstagramAbstractProvider { /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * instagram.clientKey * instagram.usersInfo.authorizedTokens * instagram.usersInfo.users * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java \ * -Dexec.mainClass=org.apache.streams.instagram.provider.recentmedia.InstagramCommentsProvider \ * -Dexec.args="application.conf comments.json.txt" diff --git a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java index 491c4f3..f20c949 100644 --- a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java +++ b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java @@ -37,7 +37,7 @@ import java.util.concurrent.atomic.AtomicBoolean; /** * Executes on all of the Instagram requests to collect the Instagram data. - * <p/> + * <p></p> * If errors/exceptions occur when trying to gather data for a particular user, that user is skipped and the collector * move on to the next user. If a rate limit exception occurs it employs an exponential back off strategy. */ diff --git a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/recentmedia/InstagramRecentMediaCollector.java b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/recentmedia/InstagramRecentMediaCollector.java index e708ad9..92c4102 100644 --- a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/recentmedia/InstagramRecentMediaCollector.java +++ b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/recentmedia/InstagramRecentMediaCollector.java @@ -33,7 +33,7 @@ import java.util.Queue; /** * Executes on all of the Instagram requests to collect the media feed data. - * <p/> + * <p></p> * If errors/exceptions occur when trying to gather data for a particular user, that user is skipped and the collector * move on to the next user. If a rate limit exception occurs it employs an exponential back off strategy. */ diff --git a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/recentmedia/InstagramRecentMediaProvider.java b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/recentmedia/InstagramRecentMediaProvider.java index 5026f34..f458967 100644 --- a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/recentmedia/InstagramRecentMediaProvider.java +++ b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/recentmedia/InstagramRecentMediaProvider.java @@ -45,7 +45,7 @@ import java.util.concurrent.TimeUnit; /** * Instagram {@link org.apache.streams.core.StreamsProvider} that provides the recent media data for a group of users. * - * <p/> + * <p></p> * Retrieve recent posts from a list of user ids or names. * */ @@ -72,18 +72,18 @@ public class InstagramRecentMediaProvider extends InstagramAbstractProvider { /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * instagram.clientKey * instagram.usersInfo.authorizedTokens * instagram.usersInfo.users * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java \ * -Dexec.mainClass=org.apache.streams.instagram.provider.recentmedia.InstagramRecentMediaProvider \ * -Dexec.args="application.conf media.json.txt" diff --git a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/userinfo/InstagramUserInfoProvider.java b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/userinfo/InstagramUserInfoProvider.java index 433fbcf..78c2085 100644 --- a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/userinfo/InstagramUserInfoProvider.java +++ b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/userinfo/InstagramUserInfoProvider.java @@ -45,7 +45,7 @@ import java.util.concurrent.TimeUnit; /** * Instagram provider that pulls UserInfoData from Instagram. * - * <p/> + * <p></p> * Retrieve latest user details from a list of user ids or names. */ public class InstagramUserInfoProvider extends InstagramAbstractProvider { @@ -71,18 +71,18 @@ public class InstagramUserInfoProvider extends InstagramAbstractProvider { /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * instagram.clientKey * instagram.usersInfo.authorizedTokens * instagram.usersInfo.users * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java \ * -Dexec.mainClass=org.apache.streams.instagram.provider.userinfo.InstagramUserInfoProvider \ * -Dexec.args="application.conf userinfo.json" diff --git a/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/moreover/MoreoverProvider.java b/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/moreover/MoreoverProvider.java index a295898..a03143a 100644 --- a/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/moreover/MoreoverProvider.java +++ b/streams-contrib/streams-provider-moreover/src/main/java/org/apache/streams/moreover/MoreoverProvider.java @@ -141,13 +141,13 @@ public class MoreoverProvider implements StreamsProvider { /** * To use from command line: * - * <p/> + * <p></p> * Supply configuration similar to src/test/resources/rss.conf * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.moreover.MoreoverProvider -Dexec.args="rss.conf articles.json" * * @param args args diff --git a/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProvider.java b/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProvider.java index 5e9e7f9..af8278d 100644 --- a/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProvider.java +++ b/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProvider.java @@ -162,13 +162,13 @@ public class RssStreamProvider implements StreamsProvider { /** * To use from command line: * - * <p/> + * <p></p> * Supply configuration similar to src/test/resources/rss.conf * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.rss.provider.RssStreamProvider -Dexec.args="rss.conf articles.json" * @param args args * @throws Exception Exception diff --git a/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProviderTask.java b/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProviderTask.java index 8437ee0..1e82032 100644 --- a/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProviderTask.java +++ b/streams-contrib/streams-provider-rss/src/main/java/org/apache/streams/rss/provider/RssStreamProviderTask.java @@ -47,19 +47,19 @@ import java.util.concurrent.ConcurrentHashMap; /** * A {@link java.lang.Runnable} task that queues rss feed data. * - * <p/> + * <p></p> * <code>RssStreamProviderTask</code> reads the content of an rss feed and queues the articles from * the feed inform of a {@link com.fasterxml.jackson.databind.node.ObjectNode} wrapped in a {@link org.apache.streams.core.StreamsDatum}. * The task can filter articles by a published date. If the task cannot parse the date of the article or the article does not contain a * published date, by default the task will attempt to queue article. * - * <p/> + * <p></p> * A task can be run in perpetual mode which will store the article urls in a static variable. The next time a * <code>RssStreamProviderTask</code> is run, it will not queue data that was seen the previous time the rss feed was read. * This is an attempt to reduce multiple copies of an article from being output by a * {@link org.apache.streams.rss.provider.RssStreamProvider}. * - * <p/> + * <p></p> * ** Warning! ** * It still is possible to output multiples of the same article. If multiple tasks executions for the same rss feed overlap * in execution time, it possible that the previously seen articles static variable will not have been updated in time. diff --git a/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/RequestBuilder.java b/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/RequestBuilder.java index 53887af..f0fd36e 100644 --- a/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/RequestBuilder.java +++ b/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/RequestBuilder.java @@ -80,7 +80,7 @@ public interface RequestBuilder { /** * Returns the full url need to execute a request. * - * <p/> + * <p></p> * Example: * http://api.sysomos.com/dev/v1/heartbeat/content?apiKey=YOUR * -APIKEY&hid=YOUR-HEARTBEAT-ID&offset=0&size=10& diff --git a/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java b/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java index a77a129..df30164 100644 --- a/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java +++ b/streams-contrib/streams-provider-sysomos/src/main/java/org/apache/streams/sysomos/provider/SysomosProvider.java @@ -61,7 +61,7 @@ import java.util.concurrent.locks.ReentrantReadWriteLock; /** * Streams Provider for the Sysomos Heartbeat API - * <p/> + * <p></p> * Configuration: * The provider takes either a Map[String,Object] containing the mode (backfill and terminate OR continuous) and a * Map[String,String] of heartbeat IDs to document target ids or a string of the format @@ -113,11 +113,11 @@ public class SysomosProvider implements StreamsProvider { /** * To use from command line: - * <p/> + * <p></p> * Supply configuration similar to src/test/resources/rss.conf - * <p/> + * <p></p> * Launch using: - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.rss.provider.RssStreamProvider -Dexec.args="rss.conf articles.json" * @param args args * @throws Exception Exception diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/StreamsTwitterMapper.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/StreamsTwitterMapper.java index 166f5d7..989c103 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/StreamsTwitterMapper.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/converter/StreamsTwitterMapper.java @@ -39,7 +39,7 @@ import java.io.IOException; /** * This class assist with handling twitter's date-time format during conversion * - * <p/> + * <p></p> * Deprecated: use StreamsJacksonMapper.getInstance() with TwitterDateTimeFormat on the classpath instead */ @Deprecated diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java index d51e4e7..09c0390 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/TwitterTypeConverter.java @@ -23,7 +23,7 @@ import org.apache.streams.converter.ActivityConverterProcessor; /** * This class performs conversion of a twitter event to a specified outClass. * - * <p/> + * <p></p> * Deprecated: use TypeConverterProcessor and ActivityConverterProcessor instead */ @Deprecated diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/SevenDaySearchProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/SevenDaySearchProvider.java index f4a5f1c..2a59cba 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/SevenDaySearchProvider.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/SevenDaySearchProvider.java @@ -105,20 +105,20 @@ public class SevenDaySearchProvider implements Callable<Iterator<Tweet>>, Stream /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * twitter.oauth.consumerKey * twitter.oauth.consumerSecret * twitter.oauth.accessToken * twitter.oauth.accessTokenSecret * twitter.info * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterTimelineProvider -Dexec.args="application.conf tweets.json" * * @param args args diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/ThirtyDaySearchProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/ThirtyDaySearchProvider.java index b32ebc4..5e0a8ec 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/ThirtyDaySearchProvider.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/ThirtyDaySearchProvider.java @@ -105,20 +105,20 @@ public class ThirtyDaySearchProvider implements Callable<Iterator<Tweet>>, Strea /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * twitter.oauth.consumerKey * twitter.oauth.consumerSecret * twitter.oauth.accessToken * twitter.oauth.accessTokenSecret * twitter.info * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterTimelineProvider -Dexec.args="application.conf tweets.json" * * @param args args diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEngagersProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEngagersProvider.java index 6d1befe..c46ab72 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEngagersProvider.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterEngagersProvider.java @@ -110,20 +110,20 @@ public class TwitterEngagersProvider implements Callable<Iterator<User>>, Stream /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * twitter.oauth.consumerKey * twitter.oauth.consumerSecret * twitter.oauth.accessToken * twitter.oauth.accessTokenSecret * twitter.info * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterEngagersProvider -Dexec.args="application.conf retweeters.json.txt" * * @param args args diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterFollowingProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterFollowingProvider.java index a02e778..4603803 100644 --- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterFollowingProvider.java +++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterFollowingProvider.java @@ -102,20 +102,20 @@ public class TwitterFollowingProvider implements Callable<Iterator<Follow>>, Str /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * twitter.oauth.consumerKey * twitter.oauth.consumerSecret * twitter.oauth.accessToken * twitter.oauth.accessTokenSecret * twitter.info * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterFollowingProvider -Dexec.args="application.conf tweets.json" * * @param args args 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 108c2d7..432af96 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 @@ -90,19 +90,19 @@ public class TwitterStreamProvider implements StreamsProvider, Serializable, Dat /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * twitter.oauth.consumerKey * twitter.oauth.consumerSecret * twitter.oauth.accessToken * twitter.oauth.accessTokenSecret * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterStreamProvider -Dexec.args="application.conf tweets.json" * * @param args 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 a8b11aa..eee81c4 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 @@ -110,20 +110,20 @@ public class TwitterTimelineProvider implements Callable<Iterator<Tweet>>, Strea /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * twitter.oauth.consumerKey * twitter.oauth.consumerSecret * twitter.oauth.accessToken * twitter.oauth.accessTokenSecret * twitter.info * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterTimelineProvider -Dexec.args="application.conf tweets.json" * * @param args args 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 62c6805..6ceeb88 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 @@ -115,20 +115,20 @@ public class TwitterUserInformationProvider implements Callable<Iterator<User>>, /** * To use from command line: * - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * - * <p/> + * <p></p> * twitter.oauth.consumerKey * twitter.oauth.consumerSecret * twitter.oauth.accessToken * twitter.oauth.accessTokenSecret * twitter.info * - * <p/> + * <p></p> * Launch using: * - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterUserInformationProvider -Dexec.args="application.conf tweets.json" * * @param args args diff --git a/streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeChannelProvider.java b/streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeChannelProvider.java index 5be3f9f..d2a41b2 100644 --- a/streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeChannelProvider.java +++ b/streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeChannelProvider.java @@ -60,16 +60,16 @@ public class YoutubeChannelProvider extends YoutubeProvider { /** * To use from command line: - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: - * <p/> + * <p></p> * youtube.oauth.pathToP12KeyFile * youtube.oauth.serviceAccountEmailAddress * youtube.apiKey * youtube.youtubeUsers - * <p/> + * <p></p> * Launch using: - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.youtube.provider.YoutubeUserActivityProvider -Dexec.args="application.conf tweets.json" * @param args args * @throws Exception Exception diff --git a/streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeUserActivityProvider.java b/streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeUserActivityProvider.java index 63386b5..e349e75 100644 --- a/streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeUserActivityProvider.java +++ b/streams-contrib/streams-provider-youtube/src/main/java/org/apache/streams/youtube/provider/YoutubeUserActivityProvider.java @@ -62,19 +62,19 @@ public class YoutubeUserActivityProvider extends YoutubeProvider { /** * To use from command line: * <p> - * <p/> + * <p></p> * Supply (at least) the following required configuration in application.conf: * <p> - * <p/> + * <p></p> * youtube.oauth.pathToP12KeyFile * youtube.oauth.serviceAccountEmailAddress * youtube.apiKey * youtube.youtubeUsers * <p> - * <p/> + * <p></p> * Launch using: * <p> - * <p/> + * <p></p> * mvn exec:java -Dexec.mainClass=org.apache.streams.youtube.provider.YoutubeUserActivityProvider -Dexec.args="application.conf tweets.json" * * @param args args diff --git a/streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGenerator.java b/streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGenerator.java index 7c0df9d..9e34d01 100644 --- a/streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGenerator.java +++ b/streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGenerator.java @@ -66,7 +66,7 @@ public class StreamsCassandraResourceGenerator implements Runnable { /** * Run from CLI without Maven * - * <p/> + * <p></p> * java -jar streams-plugin-cassandra-jar-with-dependencies.jar StreamsCassandraResourceGenerator src/main/jsonschema target/generated-resources * * @param args [sourceDirectory, targetDirectory] diff --git a/streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGeneratorMojo.java b/streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGeneratorMojo.java index c75d3e3..589690d 100644 --- a/streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGeneratorMojo.java +++ b/streams-plugins/streams-plugin-cassandra/src/main/java/org/apache/streams/plugins/cassandra/StreamsCassandraResourceGeneratorMojo.java @@ -45,7 +45,7 @@ import java.util.List; /** * Run within a module containing a src/main/jsonschema directory. * - * <p/> + * <p></p> * mvn org.apache.streams.plugins:streams-plugin-cassandra:0.5.1:generate-resources * */ diff --git a/streams-plugins/streams-plugin-elasticsearch/src/main/java/org/apache/streams/plugins/elasticsearch/StreamsElasticsearchResourceGenerator.java b/streams-plugins/streams-plugin-elasticsearch/src/main/java/org/apache/streams/plugins/elasticsearch/StreamsElasticsearchResourceGenerator.java index 9ce459e..6bcd730 100644 --- a/streams-plugins/streams-plugin-elasticsearch/src/main/java/org/apache/streams/plugins/elasticsearch/StreamsElasticsearchResourceGenerator.java +++ b/streams-plugins/streams-plugin-elasticsearch/src/main/java/org/apache/streams/plugins/elasticsearch/StreamsElasticsearchResourceGenerator.java @@ -68,7 +68,7 @@ public class StreamsElasticsearchResourceGenerator implements Runnable { /** * Run from CLI without Maven * - * <p/> + * <p></p> * java -jar streams-plugin-elasticsearch-jar-with-dependencies.jar StreamsElasticsearchResourceGenerator src/main/jsonschema target/generated-resources * * @param args [sourceDirectory, targetDirectory] diff --git a/streams-plugins/streams-plugin-hbase/src/main/java/org/apache/streams/plugins/hbase/StreamsHbaseResourceGenerator.java b/streams-plugins/streams-plugin-hbase/src/main/java/org/apache/streams/plugins/hbase/StreamsHbaseResourceGenerator.java index 0701a6f..1f9b3db 100644 --- a/streams-plugins/streams-plugin-hbase/src/main/java/org/apache/streams/plugins/hbase/StreamsHbaseResourceGenerator.java +++ b/streams-plugins/streams-plugin-hbase/src/main/java/org/apache/streams/plugins/hbase/StreamsHbaseResourceGenerator.java @@ -61,7 +61,7 @@ public class StreamsHbaseResourceGenerator implements Runnable { /** * Run from CLI without Maven * - * <p/> + * <p></p> * java -jar streams-plugin-hbase-jar-with-dependencies.jar StreamsHbaseResourceGenerator src/main/jsonschema target/generated-resources * * @param args [sourceDirectory, targetDirectory] diff --git a/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/hive/StreamsHiveResourceGenerator.java b/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/hive/StreamsHiveResourceGenerator.java index a719e33..1773fb3 100644 --- a/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/hive/StreamsHiveResourceGenerator.java +++ b/streams-plugins/streams-plugin-hive/src/main/java/org/apache/streams/plugins/hive/StreamsHiveResourceGenerator.java @@ -67,7 +67,7 @@ public class StreamsHiveResourceGenerator implements Runnable { /** * Run from CLI without Maven * - * <p/> + * <p></p> * java -jar streams-plugin-hive-jar-with-dependencies.jar StreamsHiveResourceGenerator src/main/jsonschema target/generated-resources * * @param args [sourceDirectory, targetDirectory] diff --git a/streams-plugins/streams-plugin-pig/src/main/java/org/apache/streams/plugins/pig/StreamsPigResourceGenerator.java b/streams-plugins/streams-plugin-pig/src/main/java/org/apache/streams/plugins/pig/StreamsPigResourceGenerator.java index 2783f38..b118ddb 100644 --- a/streams-plugins/streams-plugin-pig/src/main/java/org/apache/streams/plugins/pig/StreamsPigResourceGenerator.java +++ b/streams-plugins/streams-plugin-pig/src/main/java/org/apache/streams/plugins/pig/StreamsPigResourceGenerator.java @@ -50,7 +50,7 @@ import static org.apache.streams.util.schema.FileUtil.writeFile; /** * Embed within your own java code * - * <p/> + * <p></p> * StreamsPigGenerationConfig config = new StreamsPigGenerationConfig(); * config.setSourceDirectory("src/main/jsonschema"); * config.setTargetDirectory("target/generated-resources"); @@ -73,7 +73,7 @@ public class StreamsPigResourceGenerator implements Runnable { /** * Run from CLI without Maven * - * <p/> + * <p></p> * java -jar streams-plugin-pig-jar-with-dependencies.jar StreamsPigResourceGenerator src/main/jsonschema target/generated-resources * * @param args [sourceDirectory, targetDirectory] diff --git a/streams-plugins/streams-plugin-pojo/src/main/java/org/apache/streams/plugins/StreamsPojoSourceGenerator.java b/streams-plugins/streams-plugin-pojo/src/main/java/org/apache/streams/plugins/StreamsPojoSourceGenerator.java index 0d31f10..a8048fa 100644 --- a/streams-plugins/streams-plugin-pojo/src/main/java/org/apache/streams/plugins/StreamsPojoSourceGenerator.java +++ b/streams-plugins/streams-plugin-pojo/src/main/java/org/apache/streams/plugins/StreamsPojoSourceGenerator.java @@ -32,7 +32,7 @@ import java.util.Objects; /** * Embed within your own java code * - * <p/> + * <p></p> * StreamsPojoGenerationConfig config = new StreamsPojoGenerationConfig(); * config.setSourceDirectory("src/main/jsonschema"); * config.setTargetDirectory("target/generated-sources/pojo"); @@ -51,7 +51,7 @@ public class StreamsPojoSourceGenerator implements Runnable { /** * Run from CLI without Maven * - * <p/> + * <p></p> * java -jar streams-plugin-pojo-jar-with-dependencies.jar StreamsPojoSourceGenerator src/main/jsonschema target/generated-sources * * @param args [sourceDirectory, targetDirectory, targetPackage] diff --git a/streams-plugins/streams-plugin-scala/src/main/java/org/apache/streams/plugins/StreamsScalaSourceGenerator.java b/streams-plugins/streams-plugin-scala/src/main/java/org/apache/streams/plugins/StreamsScalaSourceGenerator.java index b820125..2b93d32 100644 --- a/streams-plugins/streams-plugin-scala/src/main/java/org/apache/streams/plugins/StreamsScalaSourceGenerator.java +++ b/streams-plugins/streams-plugin-scala/src/main/java/org/apache/streams/plugins/StreamsScalaSourceGenerator.java @@ -45,7 +45,7 @@ import java.util.stream.Stream; /** * Embed within your own java code * - * <p/> + * <p></p> * StreamsScalaGenerationConfig config = new StreamsScalaGenerationConfig(); * config.setTargetDirectory("target/generated-sources/scala"); * config.setTargetPackage("com.example"); @@ -68,7 +68,7 @@ public class StreamsScalaSourceGenerator implements Runnable { /** * Run from CLI without Maven * - * <p/> + * <p></p> * java -jar streams-plugin-scala-jar-with-dependencies.jar StreamsScalaSourceGenerator target/generated-sources * * @param args [targetDirectory, targetPackage] diff --git a/streams-pojo/src/main/java/org/apache/streams/data/ActivityConverter.java b/streams-pojo/src/main/java/org/apache/streams/data/ActivityConverter.java index 70f2135..895d0de 100644 --- a/streams-pojo/src/main/java/org/apache/streams/data/ActivityConverter.java +++ b/streams-pojo/src/main/java/org/apache/streams/data/ActivityConverter.java @@ -27,22 +27,22 @@ import java.util.List; /** * Converts non-Activity documents to Activities and back. * - * <p/> + * <p></p> * Each converter may one, several, or zero activities. * - * <p/> + * <p></p> * The recommended approach for deriving multiple activities from a source document is: * - * <p/> + * <p></p> * 1) Return one activity for each occurance of a verb, from the same ActivityConverter, if the activities are of like type. * - * <p/> + * <p></p> * For example, BlogShareConverter would convert a blog containing two shares into two Activities with verb: share * - * <p/> + * <p></p> * 2) Create multiple ActivityConverters, if the activities are not of like type. * - * <p/> + * <p></p> * For example, a blog post that is both a post and a share should be transformed by two seperate Converters, individually * or simultaneously applied. */ diff --git a/streams-pojo/src/main/java/org/apache/streams/data/ActivityObjectConverter.java b/streams-pojo/src/main/java/org/apache/streams/data/ActivityObjectConverter.java index 7e80327..3b48104 100644 --- a/streams-pojo/src/main/java/org/apache/streams/data/ActivityObjectConverter.java +++ b/streams-pojo/src/main/java/org/apache/streams/data/ActivityObjectConverter.java @@ -26,7 +26,7 @@ import java.io.Serializable; /** * Converts non-ActivityObject documents to ActivityObjects and back. * - * <p/> + * <p></p> * Each converter may return zero or one alternative representations. */ public interface ActivityObjectConverter<T> extends Serializable { diff --git a/streams-pojo/src/main/java/org/apache/streams/data/ActivitySerializer.java b/streams-pojo/src/main/java/org/apache/streams/data/ActivitySerializer.java index 3a4282c..ab371b0 100644 --- a/streams-pojo/src/main/java/org/apache/streams/data/ActivitySerializer.java +++ b/streams-pojo/src/main/java/org/apache/streams/data/ActivitySerializer.java @@ -26,7 +26,7 @@ import java.util.List; /** * Serializes and deserializes Activities * - * <p/> + * <p></p> * Deprecated: Switch all modules to use {@link org.apache.streams.data.ActivityConverter} */ @Deprecated diff --git a/streams-pojo/src/main/java/org/apache/streams/data/util/ActivityUtil.java b/streams-pojo/src/main/java/org/apache/streams/data/util/ActivityUtil.java index c7e8337..fe0e2b8 100644 --- a/streams-pojo/src/main/java/org/apache/streams/data/util/ActivityUtil.java +++ b/streams-pojo/src/main/java/org/apache/streams/data/util/ActivityUtil.java @@ -30,7 +30,7 @@ import java.util.Map; /** * Utility class for managing activities * - * <p/> + * <p></p> * Deprecated: Use {@link org.apache.streams.pojo.extensions.ExtensionUtil} */ @Deprecated diff --git a/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsDateTimeDeserializer.java b/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsDateTimeDeserializer.java index 50ffb5d..1c1da99 100644 --- a/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsDateTimeDeserializer.java +++ b/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsDateTimeDeserializer.java @@ -39,7 +39,7 @@ import java.util.List; * StreamsDateTimeDeserializer is a supporting class for * @see {@link org.apache.streams.jackson.StreamsJacksonMapper} * - * <p/> + * <p></p> * Converting date-time strings other than RFC3339 to joda DateTime objects requires * additional formats to be provided when instantiating StreamsJacksonMapper. */ diff --git a/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsDateTimeFormat.java b/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsDateTimeFormat.java index 55b198d..a12ea42 100644 --- a/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsDateTimeFormat.java +++ b/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsDateTimeFormat.java @@ -21,7 +21,7 @@ package org.apache.streams.jackson; /** * Supplies a custom date-time format to StreamsJacksonModule. * - * <p/> + * <p></p> * Implementations must have a no-argument constructor */ public interface StreamsDateTimeFormat { diff --git a/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsJacksonMapper.java b/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsJacksonMapper.java index f31efc4..db0962d 100644 --- a/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsJacksonMapper.java +++ b/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsJacksonMapper.java @@ -37,10 +37,10 @@ import java.util.concurrent.ConcurrentHashMap; /** * StreamsJacksonMapper is the recommended interface to jackson for any streams component. * - * <p/> + * <p></p> * Date-time formats that must be supported can be specified with constructor arguments. * - * <p/> + * <p></p> * If no Date-time formats are specified, streams will use reflection to find formats. */ public class StreamsJacksonMapper extends ObjectMapper { diff --git a/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsJacksonModule.java b/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsJacksonModule.java index 6445881..9cd1c9c 100644 --- a/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsJacksonModule.java +++ b/streams-pojo/src/main/java/org/apache/streams/jackson/StreamsJacksonModule.java @@ -36,7 +36,7 @@ import java.util.Set; * StreamsJacksonModule is a supporting class for * @link org.apache.streams.jackson.StreamsJacksonMapper * - * <p/> + * <p></p> * RFC3339 dates are supported by default. */ public class StreamsJacksonModule extends SimpleModule { diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/queues/ThroughputQueue.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/queues/ThroughputQueue.java index aae12a0..10ee286 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/queues/ThroughputQueue.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/queues/ThroughputQueue.java @@ -43,7 +43,7 @@ import javax.management.ObjectName; * A {@link java.util.concurrent.BlockingQueue} implementation that allows the measure measurement of how * data flows through the queue. Is also a {@code MBean} so the flow statistics can be viewed through * JMX. Registration of the bean happens whenever a constructor receives a non-null id. - * <p/> + * <p></p> * !!! Warning !!! * Only the necessary methods for the local streams runtime are implemented. All other methods throw a * {@link org.apache.commons.lang.NotImplementedException}. diff --git a/streams-util/src/main/java/org/apache/streams/util/SerializationUtil.java b/streams-util/src/main/java/org/apache/streams/util/SerializationUtil.java index 4a4d831..2f4d7cf 100644 --- a/streams-util/src/main/java/org/apache/streams/util/SerializationUtil.java +++ b/streams-util/src/main/java/org/apache/streams/util/SerializationUtil.java @@ -35,7 +35,7 @@ public class SerializationUtil { /** * serialize Object as byte array. * - * <p/> + * <p></p> * BORROwED FROM APACHE STORM PROJECT * * @param obj Object @@ -56,7 +56,7 @@ public class SerializationUtil { /** * deserialize byte array as Object. * - * <p/> + * <p></p> * BORROwED FROM APACHE STORM PROJECT * * @param serialized byte[] diff --git a/streams-util/src/main/java/org/apache/streams/util/api/requests/backoff/BackOffStrategy.java b/streams-util/src/main/java/org/apache/streams/util/api/requests/backoff/BackOffStrategy.java index 44497ab..781fbb3 100644 --- a/streams-util/src/main/java/org/apache/streams/util/api/requests/backoff/BackOffStrategy.java +++ b/streams-util/src/main/java/org/apache/streams/util/api/requests/backoff/BackOffStrategy.java @@ -19,7 +19,7 @@ package org.apache.streams.util.api.requests.backoff; * BackOffStrategy will cause the current thread to sleep for a specific amount of time. This is used to adhere to * api rate limits. * - * <p/> + * <p></p> * The example below illustrates using a BackOffStrategy to slow down requests when you hit a rate limit exception. * * <code> diff --git a/streams-util/src/main/java/org/apache/streams/util/oauth/tokens/tokenmanager/impl/BasicTokenManager.java b/streams-util/src/main/java/org/apache/streams/util/oauth/tokens/tokenmanager/impl/BasicTokenManager.java index d69c61f..042c0dd 100644 --- a/streams-util/src/main/java/org/apache/streams/util/oauth/tokens/tokenmanager/impl/BasicTokenManager.java +++ b/streams-util/src/main/java/org/apache/streams/util/oauth/tokens/tokenmanager/impl/BasicTokenManager.java @@ -29,7 +29,7 @@ import java.util.Collection; * </p> * When adding tokens to the pool of available tokens, the manager will not add tokens that are already in the pool. * - * <p/> + * <p></p> * The manager class is thread safe. */ public class BasicTokenManager<T> implements SimpleTokenManager<T> { diff --git a/streams-util/src/main/java/org/apache/streams/util/schema/SchemaStore.java b/streams-util/src/main/java/org/apache/streams/util/schema/SchemaStore.java index 5bdf8b0..0955cdf 100644 --- a/streams-util/src/main/java/org/apache/streams/util/schema/SchemaStore.java +++ b/streams-util/src/main/java/org/apache/streams/util/schema/SchemaStore.java @@ -28,7 +28,7 @@ import java.util.Optional; /** * A SchemaStore resolves and indexes json schemas and makes their properties available. * - * <p/> + * <p></p> * Implementations include * - SchemaStoreImpl */
