You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2017/03/28 06:24:13 UTC
[1/2] apex-malhar git commit: Add @since tags and update change log
for release 3.7.0
Repository: apex-malhar
Updated Branches:
refs/heads/release-3.7 [created] 207b373f2
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/98f4f03c
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/98f4f03c
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/98f4f03c
Branch: refs/heads/release-3.7
Commit: 98f4f03c1b94935d9f6631fe9305a9dc5268720b
Parents: b8a83a4
Author: Apex Dev <de...@apex.apache.org>
Authored: Mon Mar 27 22:38:22 2017 -0700
Committer: Thomas Weise <th...@apache.org>
Committed: Mon Mar 27 22:38:22 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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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/98f4f03c/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
[2/2] apex-malhar git commit: Preparing to release 3.7.0-RC1
Posted by th...@apache.org.
Preparing to release 3.7.0-RC1
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/207b373f
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/207b373f
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/207b373f
Branch: refs/heads/release-3.7
Commit: 207b373f2f828636a03294bb388a279d03c5593b
Parents: 98f4f03
Author: Apex Dev <de...@apex.apache.org>
Authored: Mon Mar 27 22:39:51 2017 -0700
Committer: Thomas Weise <th...@apache.org>
Committed: Mon Mar 27 22:39:51 2017 -0700
----------------------------------------------------------------------
apps/filecopy/pom.xml | 4 ++--
apps/logstream/pom.xml | 2 +-
apps/pom.xml | 2 +-
benchmark/pom.xml | 2 +-
contrib/pom.xml | 2 +-
examples/csvformatter/pom.xml | 2 +-
examples/dedup/pom.xml | 2 +-
examples/distributedistinct/pom.xml | 2 +-
examples/dynamic-partition/pom.xml | 2 +-
examples/echoserver/pom.xml | 2 +-
examples/enricher/pom.xml | 2 +-
examples/filter/pom.xml | 2 +-
examples/frauddetect/pom.xml | 2 +-
examples/highlevelapi/pom.xml | 2 +-
examples/innerjoin/pom.xml | 2 +-
examples/iteration/pom.xml | 2 +-
examples/machinedata/pom.xml | 2 +-
examples/mobile/pom.xml | 2 +-
examples/mrmonitor/pom.xml | 2 +-
examples/mroperator/pom.xml | 2 +-
examples/parser/pom.xml | 2 +-
examples/partition/pom.xml | 2 +-
examples/pi/pom.xml | 2 +-
examples/pom.xml | 2 +-
examples/r/pom.xml | 2 +-
examples/recordReader/pom.xml | 2 +-
examples/sql/pom.xml | 2 +-
examples/throttle/pom.xml | 2 +-
examples/transform/pom.xml | 2 +-
examples/twitter/pom.xml | 2 +-
examples/uniquecount/pom.xml | 2 +-
examples/wordcount/pom.xml | 2 +-
examples/yahoofinance/pom.xml | 2 +-
hive/pom.xml | 2 +-
kafka/pom.xml | 2 +-
library/pom.xml | 2 +-
pom.xml | 2 +-
samples/pom.xml | 2 +-
sql/pom.xml | 2 +-
stream/pom.xml | 2 +-
40 files changed, 41 insertions(+), 41 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/apps/filecopy/pom.xml
----------------------------------------------------------------------
diff --git a/apps/filecopy/pom.xml b/apps/filecopy/pom.xml
index da50520..6fc21cc 100644
--- a/apps/filecopy/pom.xml
+++ b/apps/filecopy/pom.xml
@@ -24,7 +24,7 @@
<parent>
<artifactId>malhar-apps</artifactId>
<groupId>org.apache.apex</groupId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>filecopy</artifactId>
@@ -79,7 +79,7 @@
<dependency>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-library</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
<exclusions>
<exclusion>
<groupId>*</groupId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/apps/logstream/pom.xml
----------------------------------------------------------------------
diff --git a/apps/logstream/pom.xml b/apps/logstream/pom.xml
index 58fe356..c2aa9a6 100644
--- a/apps/logstream/pom.xml
+++ b/apps/logstream/pom.xml
@@ -24,7 +24,7 @@
<parent>
<artifactId>malhar-apps</artifactId>
<groupId>org.apache.apex</groupId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<groupId>org.apache.apex</groupId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/apps/pom.xml
----------------------------------------------------------------------
diff --git a/apps/pom.xml b/apps/pom.xml
index ae8477a..4fc5259 100644
--- a/apps/pom.xml
+++ b/apps/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-apps</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/benchmark/pom.xml
----------------------------------------------------------------------
diff --git a/benchmark/pom.xml b/benchmark/pom.xml
index 4bbd5ac..6c8f127 100644
--- a/benchmark/pom.xml
+++ b/benchmark/pom.xml
@@ -24,7 +24,7 @@
<parent>
<artifactId>malhar</artifactId>
<groupId>org.apache.apex</groupId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<groupId>org.apache.apex</groupId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/contrib/pom.xml
----------------------------------------------------------------------
diff --git a/contrib/pom.xml b/contrib/pom.xml
index 4636ca3..50e14da 100755
--- a/contrib/pom.xml
+++ b/contrib/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-contrib</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/csvformatter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/csvformatter/pom.xml b/examples/csvformatter/pom.xml
index 7df58e4..e480600 100644
--- a/examples/csvformatter/pom.xml
+++ b/examples/csvformatter/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-csvformatter</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/dedup/pom.xml
----------------------------------------------------------------------
diff --git a/examples/dedup/pom.xml b/examples/dedup/pom.xml
index acba0f6..b457420 100644
--- a/examples/dedup/pom.xml
+++ b/examples/dedup/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-dedup</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/distributedistinct/pom.xml
----------------------------------------------------------------------
diff --git a/examples/distributedistinct/pom.xml b/examples/distributedistinct/pom.xml
index 510ea68..352498d 100644
--- a/examples/distributedistinct/pom.xml
+++ b/examples/distributedistinct/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/dynamic-partition/pom.xml
----------------------------------------------------------------------
diff --git a/examples/dynamic-partition/pom.xml b/examples/dynamic-partition/pom.xml
index b12c09f..51dc5a7 100644
--- a/examples/dynamic-partition/pom.xml
+++ b/examples/dynamic-partition/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-dynamic-partition</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/echoserver/pom.xml
----------------------------------------------------------------------
diff --git a/examples/echoserver/pom.xml b/examples/echoserver/pom.xml
index ae8a4be..6782953 100644
--- a/examples/echoserver/pom.xml
+++ b/examples/echoserver/pom.xml
@@ -24,7 +24,7 @@
<parent>
<artifactId>malhar-examples</artifactId>
<groupId>org.apache.apex</groupId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<groupId>org.apache.apex</groupId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/enricher/pom.xml
----------------------------------------------------------------------
diff --git a/examples/enricher/pom.xml b/examples/enricher/pom.xml
index 170efa6..c69736f 100644
--- a/examples/enricher/pom.xml
+++ b/examples/enricher/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-enricher</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/filter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/filter/pom.xml b/examples/filter/pom.xml
index 265ddd5..db8a356 100644
--- a/examples/filter/pom.xml
+++ b/examples/filter/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-filter</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/frauddetect/pom.xml
----------------------------------------------------------------------
diff --git a/examples/frauddetect/pom.xml b/examples/frauddetect/pom.xml
index 36d4153..d2de215 100644
--- a/examples/frauddetect/pom.xml
+++ b/examples/frauddetect/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/highlevelapi/pom.xml
----------------------------------------------------------------------
diff --git a/examples/highlevelapi/pom.xml b/examples/highlevelapi/pom.xml
index da843b7..63305e5 100644
--- a/examples/highlevelapi/pom.xml
+++ b/examples/highlevelapi/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<build>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/innerjoin/pom.xml
----------------------------------------------------------------------
diff --git a/examples/innerjoin/pom.xml b/examples/innerjoin/pom.xml
index ef2a12c..6932978 100644
--- a/examples/innerjoin/pom.xml
+++ b/examples/innerjoin/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-innerjoin</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/iteration/pom.xml
----------------------------------------------------------------------
diff --git a/examples/iteration/pom.xml b/examples/iteration/pom.xml
index 471b173..9a7bd89 100644
--- a/examples/iteration/pom.xml
+++ b/examples/iteration/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
</project>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/machinedata/pom.xml
----------------------------------------------------------------------
diff --git a/examples/machinedata/pom.xml b/examples/machinedata/pom.xml
index cf17d9b..a008041 100644
--- a/examples/machinedata/pom.xml
+++ b/examples/machinedata/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<dependencies>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/mobile/pom.xml
----------------------------------------------------------------------
diff --git a/examples/mobile/pom.xml b/examples/mobile/pom.xml
index cb40887..05281dd 100644
--- a/examples/mobile/pom.xml
+++ b/examples/mobile/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/mrmonitor/pom.xml
----------------------------------------------------------------------
diff --git a/examples/mrmonitor/pom.xml b/examples/mrmonitor/pom.xml
index 527565b..657b505 100644
--- a/examples/mrmonitor/pom.xml
+++ b/examples/mrmonitor/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/mroperator/pom.xml
----------------------------------------------------------------------
diff --git a/examples/mroperator/pom.xml b/examples/mroperator/pom.xml
index c9a7b65..2108775 100644
--- a/examples/mroperator/pom.xml
+++ b/examples/mroperator/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/parser/pom.xml
----------------------------------------------------------------------
diff --git a/examples/parser/pom.xml b/examples/parser/pom.xml
index b90b06e..89217c4 100644
--- a/examples/parser/pom.xml
+++ b/examples/parser/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-parser</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/partition/pom.xml
----------------------------------------------------------------------
diff --git a/examples/partition/pom.xml b/examples/partition/pom.xml
index 55af32f..0df9f64 100644
--- a/examples/partition/pom.xml
+++ b/examples/partition/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-partition</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/pi/pom.xml
----------------------------------------------------------------------
diff --git a/examples/pi/pom.xml b/examples/pi/pom.xml
index 6c4935f..7faaafe 100644
--- a/examples/pi/pom.xml
+++ b/examples/pi/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<dependencies>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/pom.xml
----------------------------------------------------------------------
diff --git a/examples/pom.xml b/examples/pom.xml
index be0f0d3..fd9b48f 100644
--- a/examples/pom.xml
+++ b/examples/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/r/pom.xml
----------------------------------------------------------------------
diff --git a/examples/r/pom.xml b/examples/r/pom.xml
index 46b7d47..1703c71 100644
--- a/examples/r/pom.xml
+++ b/examples/r/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/recordReader/pom.xml
----------------------------------------------------------------------
diff --git a/examples/recordReader/pom.xml b/examples/recordReader/pom.xml
index e264f51..005c9bd 100644
--- a/examples/recordReader/pom.xml
+++ b/examples/recordReader/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-recordReader</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/sql/pom.xml
----------------------------------------------------------------------
diff --git a/examples/sql/pom.xml b/examples/sql/pom.xml
index 7eb0f4d..45a778b 100644
--- a/examples/sql/pom.xml
+++ b/examples/sql/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<build>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/throttle/pom.xml
----------------------------------------------------------------------
diff --git a/examples/throttle/pom.xml b/examples/throttle/pom.xml
index df0a8fd..d9da700 100644
--- a/examples/throttle/pom.xml
+++ b/examples/throttle/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-throttle</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/transform/pom.xml
----------------------------------------------------------------------
diff --git a/examples/transform/pom.xml b/examples/transform/pom.xml
index b2354f9..e410bc9 100644
--- a/examples/transform/pom.xml
+++ b/examples/transform/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-examples-transform</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/twitter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/twitter/pom.xml b/examples/twitter/pom.xml
index 76924c9..4014452 100644
--- a/examples/twitter/pom.xml
+++ b/examples/twitter/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/uniquecount/pom.xml
----------------------------------------------------------------------
diff --git a/examples/uniquecount/pom.xml b/examples/uniquecount/pom.xml
index 37e4bb1..42d025d 100644
--- a/examples/uniquecount/pom.xml
+++ b/examples/uniquecount/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/wordcount/pom.xml
----------------------------------------------------------------------
diff --git a/examples/wordcount/pom.xml b/examples/wordcount/pom.xml
index 9106c7c..a1f2f26 100644
--- a/examples/wordcount/pom.xml
+++ b/examples/wordcount/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/examples/yahoofinance/pom.xml
----------------------------------------------------------------------
diff --git a/examples/yahoofinance/pom.xml b/examples/yahoofinance/pom.xml
index c607198..3ae38df 100644
--- a/examples/yahoofinance/pom.xml
+++ b/examples/yahoofinance/pom.xml
@@ -31,7 +31,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar-examples</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<properties>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/hive/pom.xml
----------------------------------------------------------------------
diff --git a/hive/pom.xml b/hive/pom.xml
index 56d1084..803949b 100755
--- a/hive/pom.xml
+++ b/hive/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-hive</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/kafka/pom.xml
----------------------------------------------------------------------
diff --git a/kafka/pom.xml b/kafka/pom.xml
index 654c62c..a0fb915 100755
--- a/kafka/pom.xml
+++ b/kafka/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-kafka</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/library/pom.xml
----------------------------------------------------------------------
diff --git a/library/pom.xml b/library/pom.xml
index a8b3b9b..393f849 100644
--- a/library/pom.xml
+++ b/library/pom.xml
@@ -26,7 +26,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-library</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 9660982..a320a27 100644
--- a/pom.xml
+++ b/pom.xml
@@ -30,7 +30,7 @@
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
<packaging>pom</packaging>
<name>Apache Apex Malhar</name>
<url>http://apex.apache.org</url>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/samples/pom.xml
----------------------------------------------------------------------
diff --git a/samples/pom.xml b/samples/pom.xml
index e1488d5..ba6f569 100644
--- a/samples/pom.xml
+++ b/samples/pom.xml
@@ -26,7 +26,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-samples</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/sql/pom.xml
----------------------------------------------------------------------
diff --git a/sql/pom.xml b/sql/pom.xml
index 4d5b1d0..00d3c3a 100644
--- a/sql/pom.xml
+++ b/sql/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-sql</artifactId>
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/207b373f/stream/pom.xml
----------------------------------------------------------------------
diff --git a/stream/pom.xml b/stream/pom.xml
index 8e7b98a..da85686 100755
--- a/stream/pom.xml
+++ b/stream/pom.xml
@@ -25,7 +25,7 @@
<parent>
<groupId>org.apache.apex</groupId>
<artifactId>malhar</artifactId>
- <version>3.7.0-SNAPSHOT</version>
+ <version>3.7.0</version>
</parent>
<artifactId>malhar-stream</artifactId>