Repository: apex-malhar Updated Branches: refs/heads/master ece1f5be0 -> 8e926949e
Add @since tags and update change log for release 3.7.0 Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/8e926949 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/8e926949 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/8e926949 Branch: refs/heads/master Commit: 8e926949e07484c401cd2464edc6e4f26f9a75ce Parents: ece1f5b Author: Apex Dev <[email protected]> Authored: Mon Mar 27 22:38:22 2017 -0700 Committer: Thomas Weise <[email protected]> Committed: Fri Mar 31 22:59:16 2017 -0700 ---------------------------------------------------------------------- CHANGELOG.md | 84 ++++++++++++++++++++ .../benchmark/window/AbstractGenerator.java | 3 + .../AbstractWindowedOperatorBenchmarkApp.java | 3 + .../KeyedWindowedOperatorBenchmarkApp.java | 3 + .../window/WindowedOperatorBenchmarkApp.java | 3 + .../contrib/parser/DelimitedSchema.java | 2 + .../contrib/parser/FixedWidthParser.java | 2 + .../contrib/parser/FixedWidthSchema.java | 2 + .../com/datatorrent/contrib/parser/Schema.java | 2 + .../malhar/contrib/parser/CommonLogParser.java | 2 + .../apex/malhar/contrib/parser/LogParser.java | 2 + .../malhar/contrib/parser/LogSchemaDetails.java | 2 + .../malhar/contrib/parser/log/CommonLog.java | 2 + .../apex/examples/csvformatter/Application.java | 3 + .../csvformatter/HDFSOutputOperator.java | 2 + .../examples/csvformatter/JsonGenerator.java | 3 + .../apex/examples/csvformatter/PojoEvent.java | 3 + .../apache/apex/examples/dedup/Application.java | 3 + .../org/apache/apex/examples/dynamic/App.java | 3 + .../org/apache/apex/examples/dynamic/Gen.java | 2 + .../apex/examples/enricher/DataGenerator.java | 2 + .../enricher/EnricherAppWithJSONFile.java | 3 + .../examples/enricher/LineOutputOperator.java | 2 + .../org/apache/apex/examples/enricher/POJO.java | 3 + .../apex/examples/enricher/POJOEnriched.java | 3 + .../apex/examples/filter/Application.java | 2 + .../apex/examples/filter/TransactionPOJO.java | 3 + .../innerjoin/InnerJoinApplication.java | 3 + .../apex/examples/innerjoin/POJOGenerator.java | 2 + .../examples/parser/jsonparser/Application.java | 3 + .../examples/parser/jsonparser/Campaign.java | 3 + .../parser/jsonparser/JsonGenerator.java | 3 + .../apex/examples/partition/Application.java | 3 + .../apache/apex/examples/partition/Codec3.java | 3 + .../partition/RandomNumberGenerator.java | 2 + .../apex/examples/partition/TestPartition.java | 2 + .../apex/examples/recordReader/Application.java | 3 + .../recordReader/TransactionsSchema.java | 3 + .../apex/examples/throttle/Application.java | 3 + .../examples/throttle/PassThroughOperator.java | 2 + .../throttle/RandomNumberGenerator.java | 2 + .../examples/throttle/SlowDevNullOperator.java | 2 + .../throttle/ThrottlingStatsListener.java | 2 + .../apex/examples/transform/Application.java | 3 + .../apex/examples/transform/CustomerEvent.java | 3 + .../apex/examples/transform/CustomerInfo.java | 3 + .../transform/DynamicTransformApplication.java | 3 + .../apex/examples/transform/POJOGenerator.java | 2 + ...dshiftJdbcTransactionableOutputOperator.java | 2 + .../lib/db/redshift/RedshiftOutputModule.java | 2 + .../lib/fs/FSRecordCompactionOperator.java | 2 + .../malhar/lib/fs/s3/S3BlockUploadOperator.java | 2 + .../apex/malhar/lib/fs/s3/S3FileMerger.java | 2 + .../lib/fs/s3/S3InitiateFileUploadOperator.java | 2 + .../apex/malhar/lib/fs/s3/S3OutputModule.java | 2 + .../apex/malhar/lib/fs/s3/S3Reconciler.java | 2 + .../lib/fs/s3/S3ReconcilerQueuePartitioner.java | 2 + .../apex/malhar/lib/fs/s3/S3RecordReader.java | 2 + .../malhar/lib/fs/s3/S3RecordReaderModule.java | 2 + .../malhar/lib/fs/s3/S3TupleOutputModule.java | 2 + .../MovingBoundaryTimeBucketAssigner.java | 2 + .../lib/state/managed/TimeBucketAssigner.java | 2 + .../managed/UnboundedTimeBucketAssigner.java | 2 + .../lib/utils/serde/ImmutablePairSerde.java | 2 + .../malhar/lib/utils/serde/TimeWindowSerde.java | 3 + .../lib/window/ImplicitWatermarkGenerator.java | 2 + .../window/accumulation/AbstractPojoJoin.java | 2 + .../accumulation/CompositeAccumulation.java | 2 + .../window/accumulation/PojoFullOuterJoin.java | 2 + .../window/accumulation/PojoLeftOuterJoin.java | 2 + .../window/accumulation/PojoRightOuterJoin.java | 2 + .../impl/FixedDiffEventTimeWatermarkGen.java | 2 + .../FixedDiffProcessingTimeWatermarkGen.java | 2 + 73 files changed, 255 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/CHANGELOG.md ---------------------------------------------------------------------- diff --git a/CHANGELOG.md b/CHANGELOG.md index f9f5354..163c7ea 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,6 +1,90 @@ Apex Malhar Changelog ======================================================================================================================== +Version 3.7.0 - 2017-03-31 +------------------------------------------------------------------------------------------------------------------------ + +### Sub-task +* [APEXMALHAR-2001] - Fix all the checkstyle violations in kafka module +* [APEXMALHAR-2221] - Fix checkstyle violations in benchmark module +* [APEXMALHAR-2298] - Kafka ExactlyOnce (0.9) output operator fixes +* [APEXMALHAR-2301] - Implement another TimeBucketAssigner to work with any time +* [APEXMALHAR-2345] - Purge the time buckets from managed state for all time buckets that fall beyond the lateness horizon +* [APEXMALHAR-2389] - Add User Documentation for Calcite Integration +* [APEXMALHAR-2407] - Time buckets are not purging after expiry +* [APEXMALHAR-2408] - Issues in correctness of get() for key search in ManagedTimeStateImpl +* [APEXMALHAR-2409] - Improve PojoInnerJoin accumulation to emit a POJO instead of Map +* [APEXMALHAR-2414] - Improve performance of PojoInnerJoin accum by using PojoUtils +* [APEXMALHAR-2415] - Enable PojoInnerJoin accum to allow multiple keys for join purpose +* [APEXMALHAR-2439] - In apex-malhar, renaming "demos" to "examples" +* [APEXMALHAR-2440] - Identify and group examples based on type +* [APEXMALHAR-2441] - Move Non-Ingestion Examples from [datatorrent/examples] to [apex-malhar/examples] + +### Bug +* [APEXMALHAR-2303] - S3 Line By Line Module +* [APEXMALHAR-2306] - Tests should allow for additions to OperatorContext interface +* [APEXMALHAR-2316] - Cannot register tuple class in XmlParser Operator +* [APEXMALHAR-2330] - JdbcPOJOPollInputOperator fails with NullPointerException when PostgreSQL driver +* [APEXMALHAR-2343] - Count Accumulation should only increase one for each tuple +* [APEXMALHAR-2346] - DocumentBuilder.parse() should take InputSource as an argument instead of String +* [APEXMALHAR-2350] - The key and value stream should match with the bucket +* [APEXMALHAR-2357] - JdbcPojoOperatorApplicationTest failing intermittently +* [APEXMALHAR-2368] - JDBCPollInput operator reads extra records when 1.5M records are added to a blank input table +* [APEXMALHAR-2371] - Importing 'Apache Apex Malhar Iteration Demo' throws error for 'property' tag in properties.xml +* [APEXMALHAR-2379] - AbstractFileInputOperator bug fixes for regex, negative values +* [APEXMALHAR-2399] - In PojoInnerJoin accumulation default constructor is directly throwing an exception which messes up in default serialization. +* [APEXMALHAR-2400] - In PojoInnerJoin accumulation same field names are emitted as single field +* [APEXMALHAR-2406] - ManagedState incorrect results for get() +* [APEXMALHAR-2418] - Update the twitter library to 4.0.6 +* [APEXMALHAR-2419] - KafkaSinglePortExactlyOnceOutputOperator fails on recovery +* [APEXMALHAR-2422] - WindowDataManager not recovering as expected on HDFS +* [APEXMALHAR-2424] - NullPointerException in JDBCPojoPollInputOperator with additional columns +* [APEXMALHAR-2450] - UniqueCounter emits empty maps even when there is no input +* [APEXMALHAR-2454] - CsvParser documentation xml formatting and rendering issue. + +### Dependency upgrade +* [APEXMALHAR-2398] - commons-beanutils upgrade + +### Documentation +* [APEXMALHAR-2183] - Add user document for CsvFormatter operator +* [APEXMALHAR-2364] - Add user documentation for S3OutputModule +* [APEXMALHAR-2370] - Add user documenation for Xml Parser +* [APEXMALHAR-2390] - Operator list in doc is not sorted +* [APEXMALHAR-2391] - JDBC Poller Input Operator exist but not listed +* [APEXMALHAR-2432] - javadoc for cassandra operator is improperly formatted +* [APEXMALHAR-2433] - Add readme for Windowing Benchmark + +### Improvement +* [APEXMALHAR-2220] - Move the FunctionOperator to Malhar library +* [APEXMALHAR-2344] - Initialize the list of FieldInfo in JDBCPollInput operator from properties.xml +* [APEXMALHAR-2354] - Add support for heuristic watermarks in WindowedOperator +* [APEXMALHAR-2358] - Optimise GenericSerde to use specific serde to improve the performance +* [APEXMALHAR-2359] - Optimise fire trigger to avoid go through all data +* [APEXMALHAR-2365] - LogParser - Operator to parse byte array using log format and emit a POJO +* [APEXMALHAR-2372] - Change the order of checks of table name in populateColumnDataTypes +* [APEXMALHAR-2374] - Recursive support for AbstractFileInputOperator +* [APEXMALHAR-2376] - Add Common Log support in LogParser operator +* [APEXMALHAR-2377] - Move LogParser operator to org.apache.apex.malhar.contrib.parser +* [APEXMALHAR-2380] - Add MutablePair for Kinensis Operator for Recovery State +* [APEXMALHAR-2381] - Change FSWindowManager for performance issues in Kinesis Input Operator +* [APEXMALHAR-2394] - AbstractFileOutputOperator.rotate(...) does not check if file has already been rotated before computing next rotation +* [APEXMALHAR-2411] - Avoid isreplaystate variable, incorporate logic in activate() and replay() for Kinesis Input Operator +* [APEXMALHAR-2412] - Provide emitTuple overriding functionality for user in kinesis Input operator +* [APEXMALHAR-2413] - Improve PojoInnerJoin Accumulation +* [APEXMALHAR-2429] - Ambiguity in passing "key" parameter to Join accumulation +* [APEXMALHAR-2430] - Optimize Join accumulation by changing the data structure in accumulation method +* [APEXMALHAR-2445] - KafkaExactlyOnce should not write to WAL during recovery + +### New Feature +* [APEXMALHAR-2022] - S3 Output Module for file copy +* [APEXMALHAR-2130] - Scalable windowed storage +* [APEXMALHAR-2218] - RegexParser- Operator to parse byte stream using Regex pattern and emit a POJO +* [APEXMALHAR-2259] - Create Fixed Length Parser Operator +* [APEXMALHAR-2369] - S3 output module for tuple based output +* [APEXMALHAR-2416] - Development of Redshift Output Module +* [APEXMALHAR-2417] - Add PojoOuterJoin (left, right and full) accumulation +* [APEXMALHAR-2428] - CompositeAccumulation for windowed operator + Version 3.6.0 - 2016-11-30 ------------------------------------------------------------------------------------------------------------------------ http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractGenerator.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractGenerator.java b/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractGenerator.java index c5b1594..bfdc0ec 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractGenerator.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractGenerator.java @@ -25,6 +25,9 @@ import com.datatorrent.api.DefaultOutputPort; import com.datatorrent.api.InputOperator; import com.datatorrent.common.util.BaseOperator; +/** + * @since 3.7.0 + */ public abstract class AbstractGenerator<T> extends BaseOperator implements InputOperator { public final transient DefaultOutputPort<T> data = new DefaultOutputPort<T>(); http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractWindowedOperatorBenchmarkApp.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractWindowedOperatorBenchmarkApp.java b/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractWindowedOperatorBenchmarkApp.java index 4b9b423..7a345fe 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractWindowedOperatorBenchmarkApp.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/window/AbstractWindowedOperatorBenchmarkApp.java @@ -51,6 +51,9 @@ import com.datatorrent.benchmark.window.WindowedOperatorBenchmarkApp.WindowedGen import com.datatorrent.lib.fileaccess.TFileImpl; import com.datatorrent.lib.stream.DevNull; +/** + * @since 3.7.0 + */ public abstract class AbstractWindowedOperatorBenchmarkApp<G extends Operator, O extends AbstractWindowedOperator> implements StreamingApplication { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/benchmark/src/main/java/com/datatorrent/benchmark/window/KeyedWindowedOperatorBenchmarkApp.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/window/KeyedWindowedOperatorBenchmarkApp.java b/benchmark/src/main/java/com/datatorrent/benchmark/window/KeyedWindowedOperatorBenchmarkApp.java index 19df8fd..fccc67a 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/window/KeyedWindowedOperatorBenchmarkApp.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/window/KeyedWindowedOperatorBenchmarkApp.java @@ -41,6 +41,9 @@ import com.datatorrent.api.DAG.Locality; import com.datatorrent.lib.fileaccess.TFileImpl; import com.datatorrent.lib.util.KeyValPair; +/** + * @since 3.7.0 + */ public class KeyedWindowedOperatorBenchmarkApp extends AbstractWindowedOperatorBenchmarkApp< KeyedWindowedOperatorBenchmarkApp.KeyedWindowedGenerator, KeyedWindowedOperatorBenchmarkApp.MyKeyedWindowedOperator> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/benchmark/src/main/java/com/datatorrent/benchmark/window/WindowedOperatorBenchmarkApp.java ---------------------------------------------------------------------- diff --git a/benchmark/src/main/java/com/datatorrent/benchmark/window/WindowedOperatorBenchmarkApp.java b/benchmark/src/main/java/com/datatorrent/benchmark/window/WindowedOperatorBenchmarkApp.java index d96b453..7e402fc 100644 --- a/benchmark/src/main/java/com/datatorrent/benchmark/window/WindowedOperatorBenchmarkApp.java +++ b/benchmark/src/main/java/com/datatorrent/benchmark/window/WindowedOperatorBenchmarkApp.java @@ -35,6 +35,9 @@ import com.datatorrent.api.DAG.Locality; import com.datatorrent.api.annotation.ApplicationAnnotation; @ApplicationAnnotation(name = "WindowedOperatorBenchmark") +/** + * @since 3.7.0 + */ public class WindowedOperatorBenchmarkApp extends AbstractWindowedOperatorBenchmarkApp< WindowedOperatorBenchmarkApp.WindowedGenerator, WindowedOperatorBenchmarkApp.MyWindowedOperator> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/contrib/src/main/java/com/datatorrent/contrib/parser/DelimitedSchema.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/parser/DelimitedSchema.java b/contrib/src/main/java/com/datatorrent/contrib/parser/DelimitedSchema.java index a47e138..1285b33 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/parser/DelimitedSchema.java +++ b/contrib/src/main/java/com/datatorrent/contrib/parser/DelimitedSchema.java @@ -52,6 +52,8 @@ import org.slf4j.LoggerFactory; * "dd/MM/yyyy" } }, { "name": "securityCode", "type": "Long", "constraints": { * "minValue": "10", "maxValue": "30" } }, { "name": "active", "type": * "Boolean", "constraints": { "required": "true" } } ] }} + * + * @since 3.7.0 */ public class DelimitedSchema extends Schema { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthParser.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthParser.java b/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthParser.java index 9ee556e..716d3f6 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthParser.java +++ b/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthParser.java @@ -72,6 +72,8 @@ import com.datatorrent.lib.util.PojoUtils; * @displayName FixedWidthParser * @category Parsers * @tags fixedwidth pojo parser + * + * @since 3.7.0 */ public class FixedWidthParser extends Parser<byte[], KeyValPair<String, String>> implements Operator.ActivationListener<Context> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthSchema.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthSchema.java b/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthSchema.java index e64125b..bd26f06 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthSchema.java +++ b/contrib/src/main/java/com/datatorrent/contrib/parser/FixedWidthSchema.java @@ -47,6 +47,8 @@ import org.slf4j.LoggerFactory; * "Double", "length": 5}, { "name": "startDate", "type": "Date", "length": 10, * "format":"dd/MM/yyyy" }, { "name": "securityCode", "type": "Long","length": 10 }, * { "name": "active", "type":"Boolean","length": 2} ] }} + * + * @since 3.7.0 */ public class FixedWidthSchema extends Schema { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/contrib/src/main/java/com/datatorrent/contrib/parser/Schema.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/com/datatorrent/contrib/parser/Schema.java b/contrib/src/main/java/com/datatorrent/contrib/parser/Schema.java index c09ff92..727db7f 100644 --- a/contrib/src/main/java/com/datatorrent/contrib/parser/Schema.java +++ b/contrib/src/main/java/com/datatorrent/contrib/parser/Schema.java @@ -29,6 +29,8 @@ import java.util.List; * The operators use this information to validate the incoming tuples. * Information from JSON schema is saved in this object and is used by the * operators + * + * @since 3.7.0 */ public class Schema { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/CommonLogParser.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/CommonLogParser.java b/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/CommonLogParser.java index ec20810..7490166 100644 --- a/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/CommonLogParser.java +++ b/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/CommonLogParser.java @@ -40,6 +40,8 @@ import com.datatorrent.api.Context; * <b>err</b>:tuples that do not confine to log format are emitted on this port as * KeyValPair<String,String><br> * Key being the tuple and Val being the reason. + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class CommonLogParser extends LogParser http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogParser.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogParser.java b/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogParser.java index 7a4e906..c9e06ba 100644 --- a/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogParser.java +++ b/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogParser.java @@ -47,6 +47,8 @@ import com.datatorrent.lib.util.KeyValPair; * <b>err</b>:tuples that do not confine to log format are emitted on this port as * KeyValPair<String,String><br> * Key being the tuple and Val being the reason. + * + * @since 3.7.0 */ @InterfaceStability.Unstable public class LogParser extends Parser<byte[], KeyValPair<String, String>> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogSchemaDetails.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogSchemaDetails.java b/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogSchemaDetails.java index 8120e00..1bf2ec4 100644 --- a/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogSchemaDetails.java +++ b/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/LogSchemaDetails.java @@ -45,6 +45,8 @@ import java.util.regex.Pattern; * {"field": "request","regex": "\"((?:[^\"]|\")+)\""}, * {"field": "statusCode","regex": "(\\d{3})"}, * {"field": "bytes","regex": "(\\d+|-)"}]} + * + * @since 3.7.0 */ public class LogSchemaDetails { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/log/CommonLog.java ---------------------------------------------------------------------- diff --git a/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/log/CommonLog.java b/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/log/CommonLog.java index aa44a76..e042781 100644 --- a/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/log/CommonLog.java +++ b/contrib/src/main/java/org/apache/apex/malhar/contrib/parser/log/CommonLog.java @@ -24,6 +24,8 @@ import org.apache.hadoop.classification.InterfaceStability; /** * This is default log format parser for <a href="https://en.wikipedia.org/wiki/Common_Log_Format";>Common log </a> * To use this format with {@link LogParser} operator just mention the property "logFileFormat" as "COMMON" + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class CommonLog http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/Application.java ---------------------------------------------------------------------- diff --git a/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/Application.java b/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/Application.java index 6dbb977..e57004a 100644 --- a/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/Application.java +++ b/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/Application.java @@ -30,6 +30,9 @@ import com.datatorrent.contrib.parser.JsonParser; import com.datatorrent.lib.appdata.schemas.SchemaUtils; @ApplicationAnnotation(name = "CustomOutputFormatter") +/** + * @since 3.7.0 + */ public class Application implements StreamingApplication { //Set the delimiters and schema structure for the custom output in schema.json http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/HDFSOutputOperator.java ---------------------------------------------------------------------- diff --git a/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/HDFSOutputOperator.java b/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/HDFSOutputOperator.java index 90fcc3d..c833e48 100644 --- a/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/HDFSOutputOperator.java +++ b/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/HDFSOutputOperator.java @@ -28,6 +28,8 @@ import com.datatorrent.lib.io.fs.AbstractFileOutputOperator; * HDFSoutput operator with implementation to write Objects to HDFS * * @param <T> + * + * @since 3.7.0 */ public class HDFSOutputOperator<T> extends AbstractFileOutputOperator<T> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/JsonGenerator.java ---------------------------------------------------------------------- diff --git a/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/JsonGenerator.java b/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/JsonGenerator.java index 628171b..77aae63 100644 --- a/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/JsonGenerator.java +++ b/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/JsonGenerator.java @@ -32,6 +32,9 @@ import com.datatorrent.api.DefaultOutputPort; import com.datatorrent.api.InputOperator; import com.datatorrent.common.util.BaseOperator; +/** + * @since 3.7.0 + */ public class JsonGenerator extends BaseOperator implements InputOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/PojoEvent.java ---------------------------------------------------------------------- diff --git a/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/PojoEvent.java b/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/PojoEvent.java index 8a71496..5b17373 100644 --- a/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/PojoEvent.java +++ b/examples/csvformatter/src/main/java/org/apache/apex/examples/csvformatter/PojoEvent.java @@ -21,6 +21,9 @@ package org.apache.apex.examples.csvformatter; import java.util.Date; +/** + * @since 3.7.0 + */ public class PojoEvent { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/dedup/src/main/java/org/apache/apex/examples/dedup/Application.java ---------------------------------------------------------------------- diff --git a/examples/dedup/src/main/java/org/apache/apex/examples/dedup/Application.java b/examples/dedup/src/main/java/org/apache/apex/examples/dedup/Application.java index 077e52c..d56b3ce 100644 --- a/examples/dedup/src/main/java/org/apache/apex/examples/dedup/Application.java +++ b/examples/dedup/src/main/java/org/apache/apex/examples/dedup/Application.java @@ -34,6 +34,9 @@ import com.datatorrent.common.util.BaseOperator; import com.datatorrent.lib.io.ConsoleOutputOperator; @ApplicationAnnotation(name = "DedupExample") +/** + * @since 3.7.0 + */ public class Application implements StreamingApplication { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/App.java ---------------------------------------------------------------------- diff --git a/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/App.java b/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/App.java index 60862ac..44c32a3 100644 --- a/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/App.java +++ b/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/App.java @@ -28,6 +28,9 @@ import com.datatorrent.api.annotation.ApplicationAnnotation; import com.datatorrent.lib.stream.DevNull; @ApplicationAnnotation(name = "Dyn") +/** + * @since 3.7.0 + */ public class App implements StreamingApplication { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/Gen.java ---------------------------------------------------------------------- diff --git a/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/Gen.java b/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/Gen.java index bb3f202..2827c96 100644 --- a/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/Gen.java +++ b/examples/dynamic-partition/src/main/java/org/apache/apex/examples/dynamic/Gen.java @@ -45,6 +45,8 @@ import com.datatorrent.common.util.BaseOperator; /** * Operator that dynamically partitions itself after 500 tuples have been emitted + * + * @since 3.7.0 */ public class Gen extends BaseOperator implements InputOperator, Partitioner<Gen>, StatsListener { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/enricher/src/main/java/org/apache/apex/examples/enricher/DataGenerator.java ---------------------------------------------------------------------- diff --git a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/DataGenerator.java b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/DataGenerator.java index 50f5c26..b10d12c 100644 --- a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/DataGenerator.java +++ b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/DataGenerator.java @@ -32,6 +32,8 @@ import com.datatorrent.common.util.BaseOperator; * A Party IMEI * A Party IMSI * Circle Id + * + * @since 3.7.0 */ public class DataGenerator extends BaseOperator implements InputOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/enricher/src/main/java/org/apache/apex/examples/enricher/EnricherAppWithJSONFile.java ---------------------------------------------------------------------- diff --git a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/EnricherAppWithJSONFile.java b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/EnricherAppWithJSONFile.java index 6894830..10024c8 100644 --- a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/EnricherAppWithJSONFile.java +++ b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/EnricherAppWithJSONFile.java @@ -32,6 +32,9 @@ import com.datatorrent.contrib.parser.JsonParser; import com.datatorrent.lib.io.ConsoleOutputOperator; @ApplicationAnnotation(name = "EnricherAppWithJSONFile") +/** + * @since 3.7.0 + */ public class EnricherAppWithJSONFile implements StreamingApplication { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/enricher/src/main/java/org/apache/apex/examples/enricher/LineOutputOperator.java ---------------------------------------------------------------------- diff --git a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/LineOutputOperator.java b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/LineOutputOperator.java index 6e0c742..d609202 100644 --- a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/LineOutputOperator.java +++ b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/LineOutputOperator.java @@ -28,6 +28,8 @@ import com.datatorrent.lib.io.fs.AbstractFileOutputOperator; /** * Converts each tuple to a string and writes it as a new line to the output file + * + * @since 3.7.0 */ public class LineOutputOperator extends AbstractFileOutputOperator<Object> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJO.java ---------------------------------------------------------------------- diff --git a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJO.java b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJO.java index 2a61c59..f6ef450 100644 --- a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJO.java +++ b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJO.java @@ -19,6 +19,9 @@ package org.apache.apex.examples.enricher; +/** + * @since 3.7.0 + */ public class POJO { private String phone; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJOEnriched.java ---------------------------------------------------------------------- diff --git a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJOEnriched.java b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJOEnriched.java index 55566c9..d89986a 100644 --- a/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJOEnriched.java +++ b/examples/enricher/src/main/java/org/apache/apex/examples/enricher/POJOEnriched.java @@ -19,6 +19,9 @@ package org.apache.apex.examples.enricher; +/** + * @since 3.7.0 + */ public class POJOEnriched { private String phone; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/filter/src/main/java/org/apache/apex/examples/filter/Application.java ---------------------------------------------------------------------- diff --git a/examples/filter/src/main/java/org/apache/apex/examples/filter/Application.java b/examples/filter/src/main/java/org/apache/apex/examples/filter/Application.java index ce832e6..65ec0c8 100644 --- a/examples/filter/src/main/java/org/apache/apex/examples/filter/Application.java +++ b/examples/filter/src/main/java/org/apache/apex/examples/filter/Application.java @@ -33,6 +33,8 @@ import com.datatorrent.lib.filter.FilterOperator; /** * Simple application illustrating filter operator + * + * @since 3.7.0 */ @ApplicationAnnotation(name = "FilterExample") public class Application implements StreamingApplication http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/filter/src/main/java/org/apache/apex/examples/filter/TransactionPOJO.java ---------------------------------------------------------------------- diff --git a/examples/filter/src/main/java/org/apache/apex/examples/filter/TransactionPOJO.java b/examples/filter/src/main/java/org/apache/apex/examples/filter/TransactionPOJO.java index 528d8b1..5a3cb0c 100644 --- a/examples/filter/src/main/java/org/apache/apex/examples/filter/TransactionPOJO.java +++ b/examples/filter/src/main/java/org/apache/apex/examples/filter/TransactionPOJO.java @@ -20,6 +20,9 @@ package org.apache.apex.examples.filter; +/** + * @since 3.7.0 + */ public class TransactionPOJO { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/InnerJoinApplication.java ---------------------------------------------------------------------- diff --git a/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/InnerJoinApplication.java b/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/InnerJoinApplication.java index ae62016..809e115 100644 --- a/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/InnerJoinApplication.java +++ b/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/InnerJoinApplication.java @@ -29,6 +29,9 @@ import com.datatorrent.api.annotation.ApplicationAnnotation; import com.datatorrent.lib.io.ConsoleOutputOperator; @ApplicationAnnotation(name = "InnerJoinExample") +/** + * @since 3.7.0 + */ public class InnerJoinApplication implements StreamingApplication { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/POJOGenerator.java ---------------------------------------------------------------------- diff --git a/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/POJOGenerator.java b/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/POJOGenerator.java index 0b57c07..7a4344b 100644 --- a/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/POJOGenerator.java +++ b/examples/innerjoin/src/main/java/org/apache/apex/examples/innerjoin/POJOGenerator.java @@ -29,6 +29,8 @@ import com.datatorrent.api.InputOperator; /** * Generates and emits the SalesEvent/ProductEvent based on isSalesEvent. + * + * @since 3.7.0 */ public class POJOGenerator implements InputOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Application.java ---------------------------------------------------------------------- diff --git a/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Application.java b/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Application.java index cacfadc..89853a3 100644 --- a/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Application.java +++ b/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Application.java @@ -30,6 +30,9 @@ import com.datatorrent.lib.formatter.JsonFormatter; import com.datatorrent.lib.io.ConsoleOutputOperator; @ApplicationAnnotation(name = "JsonProcessor") +/** + * @since 3.7.0 + */ public class Application implements StreamingApplication { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Campaign.java ---------------------------------------------------------------------- diff --git a/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Campaign.java b/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Campaign.java index f31e56d..0510630 100644 --- a/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Campaign.java +++ b/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/Campaign.java @@ -24,6 +24,9 @@ import java.util.Date; import com.fasterxml.jackson.annotation.JsonFormat; import com.fasterxml.jackson.annotation.JsonProperty; +/** + * @since 3.7.0 + */ public class Campaign { private int adId; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/JsonGenerator.java ---------------------------------------------------------------------- diff --git a/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/JsonGenerator.java b/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/JsonGenerator.java index 27416c3..8f4558e 100644 --- a/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/JsonGenerator.java +++ b/examples/parser/src/main/java/org/apache/apex/examples/parser/jsonparser/JsonGenerator.java @@ -34,6 +34,9 @@ import com.datatorrent.api.DefaultOutputPort; import com.datatorrent.api.InputOperator; import com.datatorrent.common.util.BaseOperator; +/** + * @since 3.7.0 + */ public class JsonGenerator extends BaseOperator implements InputOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/partition/src/main/java/org/apache/apex/examples/partition/Application.java ---------------------------------------------------------------------- diff --git a/examples/partition/src/main/java/org/apache/apex/examples/partition/Application.java b/examples/partition/src/main/java/org/apache/apex/examples/partition/Application.java index 8d1b3bf..59a480d 100644 --- a/examples/partition/src/main/java/org/apache/apex/examples/partition/Application.java +++ b/examples/partition/src/main/java/org/apache/apex/examples/partition/Application.java @@ -27,6 +27,9 @@ import com.datatorrent.api.StreamingApplication; import com.datatorrent.api.annotation.ApplicationAnnotation; @ApplicationAnnotation(name = "TestStuff") +/** + * @since 3.7.0 + */ public class Application implements StreamingApplication { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/partition/src/main/java/org/apache/apex/examples/partition/Codec3.java ---------------------------------------------------------------------- diff --git a/examples/partition/src/main/java/org/apache/apex/examples/partition/Codec3.java b/examples/partition/src/main/java/org/apache/apex/examples/partition/Codec3.java index b48cd83..6115747 100644 --- a/examples/partition/src/main/java/org/apache/apex/examples/partition/Codec3.java +++ b/examples/partition/src/main/java/org/apache/apex/examples/partition/Codec3.java @@ -21,6 +21,9 @@ package org.apache.apex.examples.partition; import com.datatorrent.lib.codec.KryoSerializableStreamCodec; +/** + * @since 3.7.0 + */ public class Codec3 extends KryoSerializableStreamCodec<Integer> { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/partition/src/main/java/org/apache/apex/examples/partition/RandomNumberGenerator.java ---------------------------------------------------------------------- diff --git a/examples/partition/src/main/java/org/apache/apex/examples/partition/RandomNumberGenerator.java b/examples/partition/src/main/java/org/apache/apex/examples/partition/RandomNumberGenerator.java index 40eb041..7fda0b9 100644 --- a/examples/partition/src/main/java/org/apache/apex/examples/partition/RandomNumberGenerator.java +++ b/examples/partition/src/main/java/org/apache/apex/examples/partition/RandomNumberGenerator.java @@ -33,6 +33,8 @@ import com.datatorrent.common.util.BaseOperator; /** * This is a simple operator that emits random integer. + * + * @since 3.7.0 */ public class RandomNumberGenerator extends BaseOperator implements InputOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/partition/src/main/java/org/apache/apex/examples/partition/TestPartition.java ---------------------------------------------------------------------- diff --git a/examples/partition/src/main/java/org/apache/apex/examples/partition/TestPartition.java b/examples/partition/src/main/java/org/apache/apex/examples/partition/TestPartition.java index 60eb69e..deb9ceb 100644 --- a/examples/partition/src/main/java/org/apache/apex/examples/partition/TestPartition.java +++ b/examples/partition/src/main/java/org/apache/apex/examples/partition/TestPartition.java @@ -40,6 +40,8 @@ import com.datatorrent.common.util.BaseOperator; /** * Simple operator to test partitioning + * + * @since 3.7.0 */ public class TestPartition extends BaseOperator implements Partitioner<TestPartition> { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/Application.java ---------------------------------------------------------------------- diff --git a/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/Application.java b/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/Application.java index ed78c17..f56217f 100644 --- a/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/Application.java +++ b/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/Application.java @@ -29,6 +29,9 @@ import com.datatorrent.contrib.formatter.CsvFormatter; import com.datatorrent.contrib.parser.CsvParser; @ApplicationAnnotation(name = "RecordReaderExample") +/** + * @since 3.7.0 + */ public class Application implements StreamingApplication { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/TransactionsSchema.java ---------------------------------------------------------------------- diff --git a/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/TransactionsSchema.java b/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/TransactionsSchema.java index 11437df..1c13d95 100644 --- a/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/TransactionsSchema.java +++ b/examples/recordReader/src/main/java/org/apache/apex/examples/recordReader/TransactionsSchema.java @@ -21,6 +21,9 @@ package org.apache.apex.examples.recordReader; import java.util.Date; +/** + * @since 3.7.0 + */ public class TransactionsSchema { private String customerName; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/throttle/src/main/java/org/apache/apex/examples/throttle/Application.java ---------------------------------------------------------------------- diff --git a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/Application.java b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/Application.java index 9571456..b35f2d1 100644 --- a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/Application.java +++ b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/Application.java @@ -32,6 +32,9 @@ import com.datatorrent.api.StreamingApplication; import com.datatorrent.api.annotation.ApplicationAnnotation; @ApplicationAnnotation(name = "ThrottleApplication") +/** + * @since 3.7.0 + */ public class Application implements StreamingApplication { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/throttle/src/main/java/org/apache/apex/examples/throttle/PassThroughOperator.java ---------------------------------------------------------------------- diff --git a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/PassThroughOperator.java b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/PassThroughOperator.java index 52d3b1b..8ff3925 100644 --- a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/PassThroughOperator.java +++ b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/PassThroughOperator.java @@ -25,6 +25,8 @@ import com.datatorrent.common.util.BaseOperator; /** * Created by pramod on 9/27/16. + * + * @since 3.7.0 */ public class PassThroughOperator<T> extends BaseOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/throttle/src/main/java/org/apache/apex/examples/throttle/RandomNumberGenerator.java ---------------------------------------------------------------------- diff --git a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/RandomNumberGenerator.java b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/RandomNumberGenerator.java index e24b63e..89e252b 100644 --- a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/RandomNumberGenerator.java +++ b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/RandomNumberGenerator.java @@ -28,6 +28,8 @@ import com.datatorrent.common.util.BaseOperator; /** * This is a simple operator that emits random number. + * + * @since 3.7.0 */ public class RandomNumberGenerator extends BaseOperator implements InputOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/throttle/src/main/java/org/apache/apex/examples/throttle/SlowDevNullOperator.java ---------------------------------------------------------------------- diff --git a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/SlowDevNullOperator.java b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/SlowDevNullOperator.java index e830013..572194b 100644 --- a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/SlowDevNullOperator.java +++ b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/SlowDevNullOperator.java @@ -26,6 +26,8 @@ import com.datatorrent.common.util.BaseOperator; /** * Created by pramod on 9/27/16. + * + * @since 3.7.0 */ public class SlowDevNullOperator<T> extends BaseOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/throttle/src/main/java/org/apache/apex/examples/throttle/ThrottlingStatsListener.java ---------------------------------------------------------------------- diff --git a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/ThrottlingStatsListener.java b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/ThrottlingStatsListener.java index 5504332..acb840a 100644 --- a/examples/throttle/src/main/java/org/apache/apex/examples/throttle/ThrottlingStatsListener.java +++ b/examples/throttle/src/main/java/org/apache/apex/examples/throttle/ThrottlingStatsListener.java @@ -35,6 +35,8 @@ import com.datatorrent.api.StatsListener; /** * Created by pramod on 9/27/16. + * + * @since 3.7.0 */ public class ThrottlingStatsListener implements StatsListener, Serializable { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/transform/src/main/java/org/apache/apex/examples/transform/Application.java ---------------------------------------------------------------------- diff --git a/examples/transform/src/main/java/org/apache/apex/examples/transform/Application.java b/examples/transform/src/main/java/org/apache/apex/examples/transform/Application.java index f35a591..0df31f4 100644 --- a/examples/transform/src/main/java/org/apache/apex/examples/transform/Application.java +++ b/examples/transform/src/main/java/org/apache/apex/examples/transform/Application.java @@ -33,6 +33,9 @@ import com.datatorrent.lib.io.ConsoleOutputOperator; import com.datatorrent.lib.transform.TransformOperator; @ApplicationAnnotation(name = "TransformExample") +/** + * @since 3.7.0 + */ public class Application implements StreamingApplication { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerEvent.java ---------------------------------------------------------------------- diff --git a/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerEvent.java b/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerEvent.java index bfc9660..9d23999 100644 --- a/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerEvent.java +++ b/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerEvent.java @@ -21,6 +21,9 @@ package org.apache.apex.examples.transform; import java.util.Date; +/** + * @since 3.7.0 + */ public class CustomerEvent { private int customerId; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerInfo.java ---------------------------------------------------------------------- diff --git a/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerInfo.java b/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerInfo.java index 1dc347b..add1c68 100644 --- a/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerInfo.java +++ b/examples/transform/src/main/java/org/apache/apex/examples/transform/CustomerInfo.java @@ -19,6 +19,9 @@ package org.apache.apex.examples.transform; +/** + * @since 3.7.0 + */ public class CustomerInfo { private int customerId; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/transform/src/main/java/org/apache/apex/examples/transform/DynamicTransformApplication.java ---------------------------------------------------------------------- diff --git a/examples/transform/src/main/java/org/apache/apex/examples/transform/DynamicTransformApplication.java b/examples/transform/src/main/java/org/apache/apex/examples/transform/DynamicTransformApplication.java index 4063cce..95fb6c8 100644 --- a/examples/transform/src/main/java/org/apache/apex/examples/transform/DynamicTransformApplication.java +++ b/examples/transform/src/main/java/org/apache/apex/examples/transform/DynamicTransformApplication.java @@ -35,6 +35,9 @@ import com.datatorrent.lib.partitioner.StatelessThroughputBasedPartitioner; import com.datatorrent.lib.transform.TransformOperator; @ApplicationAnnotation(name = "DynamicTransformApp") +/** + * @since 3.7.0 + */ public class DynamicTransformApplication implements StreamingApplication { private static String COOL_DOWN_MILLIS = "dt.cooldown"; http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/examples/transform/src/main/java/org/apache/apex/examples/transform/POJOGenerator.java ---------------------------------------------------------------------- diff --git a/examples/transform/src/main/java/org/apache/apex/examples/transform/POJOGenerator.java b/examples/transform/src/main/java/org/apache/apex/examples/transform/POJOGenerator.java index 1b4f3ef..251f8ee 100644 --- a/examples/transform/src/main/java/org/apache/apex/examples/transform/POJOGenerator.java +++ b/examples/transform/src/main/java/org/apache/apex/examples/transform/POJOGenerator.java @@ -32,6 +32,8 @@ import com.datatorrent.api.InputOperator; /** * Generates and emits the CustomerEvent + * + * @since 3.7.0 */ public class POJOGenerator implements InputOperator { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java index fa11fc7..1ab1893 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftJdbcTransactionableOutputOperator.java @@ -47,6 +47,8 @@ import com.datatorrent.lib.db.jdbc.AbstractJdbcTransactionableOutputOperator; * @displayName Redshift Output Operator * @category Output * @tags database, jdbc, redshift + * + * @since 3.7.0 */ @InterfaceStability.Evolving @OperatorAnnotation(partitionable = false) http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftOutputModule.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftOutputModule.java b/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftOutputModule.java index 7d24ef9..56b7f70 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftOutputModule.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/db/redshift/RedshiftOutputModule.java @@ -41,6 +41,8 @@ import static org.apache.apex.malhar.lib.db.redshift.RedshiftOutputModule.READER * rolling files will load into Redshift table using copy command. * By default, it load files from S3 into Redshfit table. If the file is located in EMR, then specify "readFromS3" parameter to false. * + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class RedshiftOutputModule implements Module http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordCompactionOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordCompactionOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordCompactionOperator.java index 1dd12c4..dc214d5 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordCompactionOperator.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordCompactionOperator.java @@ -41,6 +41,8 @@ import com.datatorrent.api.DefaultOutputPort; * Type for incoming tuples. Converter needs to be defined which * converts these tuples to byte[]. Default converters for String, * byte[] tuples are provided in S3TupleOutputModule. + * + * @since 3.7.0 */ @org.apache.hadoop.classification.InterfaceStability.Evolving public class FSRecordCompactionOperator<INPUT> extends GenericFileOutputOperator<INPUT> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3BlockUploadOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3BlockUploadOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3BlockUploadOperator.java index aafa3a7..950ec50 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3BlockUploadOperator.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3BlockUploadOperator.java @@ -59,6 +59,8 @@ import com.datatorrent.netlet.util.Slice; * This operator can be used to upload the block into S3 bucket using multi-part feature or putObject API. * Upload the block into S3 using multi-part feature only if the number of blocks of a file is > 1. * This operator is useful in context of S3 Output Module. + * + * @since 3.7.0 */ @InterfaceStability.Evolving http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3FileMerger.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3FileMerger.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3FileMerger.java index 96fbc29..9c4bc33 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3FileMerger.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3FileMerger.java @@ -50,6 +50,8 @@ import com.datatorrent.api.Operator; * This operator can be used to merge the S3 blocks into a file. This operator will request for * S3 CompleteMultipartUploadRequest once all the blocks are uploaded using multi-part feature. * This operator is useful in context of S3 Output Module. + * + * @since 3.7.0 */ @InterfaceStability.Evolving http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3InitiateFileUploadOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3InitiateFileUploadOperator.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3InitiateFileUploadOperator.java index 3a38265..fd70b11 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3InitiateFileUploadOperator.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3InitiateFileUploadOperator.java @@ -48,6 +48,8 @@ import com.datatorrent.lib.io.fs.AbstractFileSplitter; * This is an S3 Initiate file upload operator which can be used to initiate file upload and emits the upload id. * Initiate the given file for upload only if the file contains more than one block. * This operator is useful in context of S3 Output Module. + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class S3InitiateFileUploadOperator implements Operator, Operator.CheckpointNotificationListener http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3OutputModule.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3OutputModule.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3OutputModule.java index 6c3d8be..2141e69 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3OutputModule.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3OutputModule.java @@ -59,6 +59,8 @@ import static com.datatorrent.api.Context.OperatorContext.TIMEOUT_WINDOW_COUNT; * * @displayName S3 Output Module * @tags S3, Output + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class S3OutputModule implements Module http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3Reconciler.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3Reconciler.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3Reconciler.java index 0c47e26..1e7b68c 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3Reconciler.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3Reconciler.java @@ -55,6 +55,8 @@ import com.datatorrent.lib.io.fs.AbstractReconciler; * frozen by the committed callback. * * S3TupleOutputModule uses this operator in conjunction with S3CompactionOperator + * + * @since 3.7.0 */ @org.apache.hadoop.classification.InterfaceStability.Evolving public class S3Reconciler extends AbstractReconciler<FSRecordCompactionOperator.OutputMetaData, FSRecordCompactionOperator.OutputMetaData> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3ReconcilerQueuePartitioner.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3ReconcilerQueuePartitioner.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3ReconcilerQueuePartitioner.java index edd0054..7d3093e 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3ReconcilerQueuePartitioner.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3ReconcilerQueuePartitioner.java @@ -34,6 +34,8 @@ import com.datatorrent.lib.partitioner.StatsAwareStatelessPartitioner; * This partitioner looks at Reconciler queue size to decide no. of partitions. * This partitioner is used for S3Reconciler Operator. * @param <T> + * + * @since 3.7.0 */ @org.apache.hadoop.classification.InterfaceStability.Evolving public class S3ReconcilerQueuePartitioner<T extends Operator> extends StatsAwareStatelessPartitioner<T> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReader.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReader.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReader.java index 9de2896..71ca929 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReader.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReader.java @@ -46,6 +46,8 @@ import com.datatorrent.lib.io.block.ReaderContext; * * Typically, this operator will be connected to output of FileSplitterInput to * read records in parallel. + * + * @since 3.7.0 */ @Evolving public class S3RecordReader extends FSRecordReader http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReaderModule.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReaderModule.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReaderModule.java index 884073c..b40337e 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReaderModule.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3RecordReaderModule.java @@ -61,6 +61,8 @@ import com.datatorrent.lib.io.fs.S3BlockReader; * partitioning<br/> * different file. <br/> * 12. s3EndPoint: Optional parameter used to specify S3 endpoint to use + * + * @since 3.7.0 */ @org.apache.hadoop.classification.InterfaceStability.Evolving public class S3RecordReaderModule extends FSRecordReaderModule http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3TupleOutputModule.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3TupleOutputModule.java b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3TupleOutputModule.java index 7e907b1..4c93631 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3TupleOutputModule.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/fs/s3/S3TupleOutputModule.java @@ -47,6 +47,8 @@ import com.datatorrent.lib.partitioner.StatelessThroughputBasedPartitioner; * * @displayName S3 Tuple Output Module * @tags S3, Output + * + * @since 3.7.0 */ @org.apache.hadoop.classification.InterfaceStability.Evolving public abstract class S3TupleOutputModule<INPUT> implements Module http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/state/managed/MovingBoundaryTimeBucketAssigner.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/MovingBoundaryTimeBucketAssigner.java b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/MovingBoundaryTimeBucketAssigner.java index f3b40e1..cb1f8a2 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/MovingBoundaryTimeBucketAssigner.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/MovingBoundaryTimeBucketAssigner.java @@ -48,6 +48,8 @@ import com.esotericsoftware.kryo.serializers.JavaSerializer; * argument to this method can be ahead of <code>end</code>. This means that the corresponding event is a future event * (wrt TimeBucketAssigner) and cannot be ignored. Therefore it is accounted by sliding boundaries further. * + * + * @since 3.7.0 */ public class MovingBoundaryTimeBucketAssigner extends TimeBucketAssigner { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeBucketAssigner.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeBucketAssigner.java b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeBucketAssigner.java index 2cae914..8510452 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeBucketAssigner.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/TimeBucketAssigner.java @@ -32,6 +32,8 @@ import com.datatorrent.api.Context; /** * Abstract class to extract a bucket for a given time + * + * @since 3.7.0 */ public abstract class TimeBucketAssigner implements ManagedStateComponent, WindowListener { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/state/managed/UnboundedTimeBucketAssigner.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/UnboundedTimeBucketAssigner.java b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/UnboundedTimeBucketAssigner.java index 2027249..77f870c 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/state/managed/UnboundedTimeBucketAssigner.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/state/managed/UnboundedTimeBucketAssigner.java @@ -29,6 +29,8 @@ import com.google.common.base.Preconditions; * All times 1001, 1002 ... 1999 will be assigned to time bucket 1000 <br> * * + * + * @since 3.7.0 */ public class UnboundedTimeBucketAssigner extends TimeBucketAssigner { http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ImmutablePairSerde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ImmutablePairSerde.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ImmutablePairSerde.java index 98ced16..6bce6ca 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ImmutablePairSerde.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/ImmutablePairSerde.java @@ -27,6 +27,8 @@ import com.esotericsoftware.kryo.io.Output; /** * An implementation of {@link Serde} which serializes and deserializes {@link ImmtablePair}s. * + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class ImmutablePairSerde<L, R> implements Serde<ImmutablePair<L, R>> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/TimeWindowSerde.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/TimeWindowSerde.java b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/TimeWindowSerde.java index 268a7ce..5546342 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/TimeWindowSerde.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/utils/serde/TimeWindowSerde.java @@ -24,6 +24,9 @@ import org.apache.apex.malhar.lib.window.Window.TimeWindow; import com.esotericsoftware.kryo.io.Input; import com.esotericsoftware.kryo.io.Output; +/** + * @since 3.7.0 + */ public class TimeWindowSerde implements Serde<Window.TimeWindow> { @Override http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/window/ImplicitWatermarkGenerator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/ImplicitWatermarkGenerator.java b/library/src/main/java/org/apache/apex/malhar/lib/window/ImplicitWatermarkGenerator.java index c7e91a1..c154744 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/ImplicitWatermarkGenerator.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/ImplicitWatermarkGenerator.java @@ -26,6 +26,8 @@ import com.datatorrent.api.Component; * Interface for generators for implicit watermarks. * An operator which does not want to rely on explicit watermarks (generated from upstream), * can use implementations of this interface to get implicit watermarks. + * + * @since 3.7.0 */ @InterfaceStability.Evolving public interface ImplicitWatermarkGenerator extends Component http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/AbstractPojoJoin.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/AbstractPojoJoin.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/AbstractPojoJoin.java index 8fe7df3..fa63ffd 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/AbstractPojoJoin.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/AbstractPojoJoin.java @@ -41,6 +41,8 @@ import static org.apache.apex.malhar.lib.window.accumulation.AbstractPojoJoin.ST /** * Join Accumulation for Pojo Streams. * + * + * @since 3.7.0 */ @InterfaceStability.Evolving public abstract class AbstractPojoJoin<InputT1, InputT2> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CompositeAccumulation.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CompositeAccumulation.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CompositeAccumulation.java index 2184388..6928435 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CompositeAccumulation.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/CompositeAccumulation.java @@ -28,6 +28,8 @@ import com.google.common.collect.Lists; /** * The CompositeAccumulation is an Accumulation which delegate task to sub accumulations. * + * + * @since 3.7.0 */ @SuppressWarnings("rawtypes") @Evolving http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoFullOuterJoin.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoFullOuterJoin.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoFullOuterJoin.java index c74ded3..24b8731 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoFullOuterJoin.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoFullOuterJoin.java @@ -33,6 +33,8 @@ import com.datatorrent.lib.util.PojoUtils; /** * Full outer join Accumulation for Pojo Streams. * + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class PojoFullOuterJoin<InputT1, InputT2> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoLeftOuterJoin.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoLeftOuterJoin.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoLeftOuterJoin.java index 5405ca5..8d2f1f0 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoLeftOuterJoin.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoLeftOuterJoin.java @@ -33,6 +33,8 @@ import com.datatorrent.lib.util.PojoUtils; /** * Left Outer join Accumulation for Pojo Streams. * + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class PojoLeftOuterJoin<InputT1, InputT2> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoRightOuterJoin.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoRightOuterJoin.java b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoRightOuterJoin.java index 9d22229..3fdcd26 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoRightOuterJoin.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/accumulation/PojoRightOuterJoin.java @@ -33,6 +33,8 @@ import com.datatorrent.lib.util.PojoUtils; /** * Right outer join Accumulation for Pojo Streams. * + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class PojoRightOuterJoin<InputT1, InputT2> http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffEventTimeWatermarkGen.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffEventTimeWatermarkGen.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffEventTimeWatermarkGen.java index 1e61a29..a244cb4 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffEventTimeWatermarkGen.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffEventTimeWatermarkGen.java @@ -32,6 +32,8 @@ import com.datatorrent.api.Context; * based on event time. * * Generates a watermark tuple with a fixed difference from the latest event time. + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class FixedDiffEventTimeWatermarkGen implements ImplicitWatermarkGenerator http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/8e926949/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffProcessingTimeWatermarkGen.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffProcessingTimeWatermarkGen.java b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffProcessingTimeWatermarkGen.java index a4d9e1a..af7b6dd 100644 --- a/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffProcessingTimeWatermarkGen.java +++ b/library/src/main/java/org/apache/apex/malhar/lib/window/impl/FixedDiffProcessingTimeWatermarkGen.java @@ -30,6 +30,8 @@ import com.datatorrent.api.Context; * based on processing time. * * Generates a watermark tuple with a fixed difference from the current processing time. + * + * @since 3.7.0 */ @InterfaceStability.Evolving public class FixedDiffProcessingTimeWatermarkGen implements ImplicitWatermarkGenerator
