apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [1/2] incubator-apex-malhar git commit: Add @since tags and update change log for release 3.2.0
Date Fri, 06 Nov 2015 08:05:08 GMT
Repository: incubator-apex-malhar
Updated Branches:
  refs/heads/release-3.2 29de8905a -> 862e157e5


Add @since tags and update change log for release 3.2.0


Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/a2e3a730
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/a2e3a730
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/a2e3a730

Branch: refs/heads/release-3.2
Commit: a2e3a7309474e047411de75baed2c03c17ec114d
Parents: 29de890
Author: Thomas Weise <thomas@datatorrent.com>
Authored: Thu Nov 5 23:43:09 2015 -0800
Committer: Thomas Weise <thomas@datatorrent.com>
Committed: Thu Nov 5 23:43:09 2015 -0800

----------------------------------------------------------------------
 CHANGELOG.md                                    | 49 ++++++++++++++++++++
 .../contrib/converter/Converter.java            |  1 +
 .../contrib/schema/formatter/CsvFormatter.java  |  1 +
 .../contrib/schema/formatter/Formatter.java     |  1 +
 .../contrib/schema/formatter/JsonFormatter.java |  1 +
 .../contrib/schema/formatter/XmlFormatter.java  |  1 +
 .../contrib/schema/parser/CsvParser.java        |  1 +
 .../contrib/schema/parser/JsonParser.java       |  1 +
 .../contrib/schema/parser/Parser.java           |  1 +
 .../contrib/schema/parser/XmlParser.java        |  1 +
 .../datatorrent/demos/pi/NamedValueList.java    |  1 +
 .../demos/wordcount/FileWordCount.java          |  2 +
 .../lib/appdata/query/WindowBoundedService.java |  2 +
 .../lib/appdata/schemas/CustomTimeBucket.java   |  2 +
 .../lib/io/fs/AbstractFileSplitter.java         |  2 +
 .../datatorrent/lib/io/fs/FileSplitterBase.java |  2 +
 16 files changed, 69 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
new file mode 100644
index 0000000..3bf8a6b
--- /dev/null
+++ b/CHANGELOG.md
@@ -0,0 +1,49 @@
+Apex Malhar Changelog
+========================================================================================================================
+
+
+Version 3.2.0-incubating - 2015-11-08
+------------------------------------------------------------------------------------------------------------------------
+
+### Sub-task
+* [MLHR-1870] - JsonParser unit test failing
+* [MLHR-1872] - Add license headers in unit tests of parsers and formatters
+* [MLHR-1886] - Optimize recovery of files which are not corrupted
+* [MLHR-1889] - AbstractFileOutputOperator should have rename method to do rename operation
+
+### Bug
+* [MLHR-1799] - Cassandra Pojo input operator is broken
+* [MLHR-1820] - Fix NPE in SnapshotServer
+* [MLHR-1823] - AbstractFileOutputOperator not finalizing the file after the recovery
+* [MLHR-1825] - AbstractFileOutputOperator throwing FileNotFoundException during the recovery
+* [MLHR-1830] - Fix Backword Compatibility Errors
+* [MLHR-1835] - WebSocketInputOperator Creates More And More Zombie Threads As It Runs
+* [MLHR-1837] - AbstractFileOutputOperator writing to same temp file after the recovery
+* [MLHR-1839] - Configure All The Twitter Demos To Use Embeddable Query
+* [MLHR-1841] - AbstractFileOutputOperator rotation interval not working when there is no
processing
+* [MLHR-1852] - File Splitter Test Failing On My Machine
+* [MLHR-1856] - Make Custom Time Buckets Sortable
+* [MLHR-1860] - Check for null fileName in new wordcount app in wrong place
+* [MLHR-1864] - Some Times Expired Queries Are processed
+* [MLHR-1866] - Travis-ci build integration
+* [MLHR-1876] - WindowBoundedService Can Block The Shutdown Of A Container
+* [MLHR-1880] - Incorrect documentation for maxLength property on AbstractFileOutputOperator
+* [MLHR-1885] - Adding getter methods to the variables of KafkaMessage
+
+### Task
+* [MLHR-1857] - Apache license headers and related files
+* [MLHR-1869] - Update Maven coordinates for ASF release
+* [MLHR-1871] - Expand checks in CI build
+* [MLHR-1891] - Skip install/deploy of source archives
+
+### Improvement
+* [MLHR-1803] - Add Embeddable Query To AppDataSnapshotServer
+* [MLHR-1804] - Enable FileSplitter to be used as a non-input operator
+* [MLHR-1805] - Ability to supply additional file meta information in FileSplitter
+* [MLHR-1806] - Ability to supply additional block meta information in FileSplitter
+* [MLHR-1824] - Convert Pi Demo to support Query Operator
+* [MLHR-1836] - Integrate schema with Jdbc POJO operators
+* [MLHR-1862] - Clean up code for Machine Data Demo
+* [MLHR-1863] - Make Custom Time Bucket Comparable
+* [MLHR-1868] - Improve GPOUtils hashcode function
+

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/converter/Converter.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/converter/Converter.java b/contrib/src/main/java/com/datatorrent/contrib/converter/Converter.java
index ebf2925..601268d 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/converter/Converter.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/converter/Converter.java
@@ -27,6 +27,7 @@ import org.apache.hadoop.classification.InterfaceStability;
  * 
  * @param <INPUT>
  * @param <OUTPUT>
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public interface Converter<INPUT, OUTPUT>

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/CsvFormatter.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/CsvFormatter.java
b/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/CsvFormatter.java
index 924acc6..490c4f2 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/CsvFormatter.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/CsvFormatter.java
@@ -53,6 +53,7 @@ import com.datatorrent.netlet.util.DTThrowable;
  * @displayName CsvFormatter
  * @category Formatter
  * @tags pojo csv formatter
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public class CsvFormatter extends Formatter<String>

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/Formatter.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/Formatter.java
b/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/Formatter.java
index 19a78e0..77fa630 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/Formatter.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/Formatter.java
@@ -44,6 +44,7 @@ import com.datatorrent.contrib.converter.Converter;
  * @displayName Parser
  * @tags parser converter
  * @param <INPUT>
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public abstract class Formatter<OUTPUT> extends BaseOperator implements Converter<Object,
OUTPUT>,

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/JsonFormatter.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/JsonFormatter.java
b/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/JsonFormatter.java
index 344ac60..5f7bce6 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/JsonFormatter.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/JsonFormatter.java
@@ -42,6 +42,7 @@ import com.datatorrent.netlet.util.DTThrowable;
  * @displayName JsonFormatter
  * @category Formatter
  * @tags pojo json formatter
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public class JsonFormatter extends Formatter<String>

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/XmlFormatter.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/XmlFormatter.java
b/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/XmlFormatter.java
index b387031..40fef69 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/XmlFormatter.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/schema/formatter/XmlFormatter.java
@@ -38,6 +38,7 @@ import com.thoughtworks.xstream.io.xml.XppDriver;
  * @displayName XmlParser
  * @category Formatter
  * @tags xml pojo formatter
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public class XmlFormatter extends Formatter<String>

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/schema/parser/CsvParser.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/schema/parser/CsvParser.java b/contrib/src/main/java/com/datatorrent/contrib/schema/parser/CsvParser.java
index 4fd39fb..991f6eb 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/schema/parser/CsvParser.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/schema/parser/CsvParser.java
@@ -59,6 +59,7 @@ import com.datatorrent.netlet.util.DTThrowable;
  * @displayName CsvParser
  * @category Parsers
  * @tags csv pojo parser
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public class CsvParser extends Parser<String>

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/schema/parser/JsonParser.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/schema/parser/JsonParser.java b/contrib/src/main/java/com/datatorrent/contrib/schema/parser/JsonParser.java
index d01e436..513be15 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/schema/parser/JsonParser.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/schema/parser/JsonParser.java
@@ -42,6 +42,7 @@ import com.datatorrent.netlet.util.DTThrowable;
  * @displayName JsonParser
  * @category Parsers
  * @tags json pojo parser
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public class JsonParser extends Parser<String>

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/schema/parser/Parser.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/schema/parser/Parser.java b/contrib/src/main/java/com/datatorrent/contrib/schema/parser/Parser.java
index e5ff7f5..3c1df8f 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/schema/parser/Parser.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/schema/parser/Parser.java
@@ -44,6 +44,7 @@ import com.datatorrent.contrib.converter.Converter;
  * @displayName Parser
  * @tags parser converter
  * @param <INPUT>
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public abstract class Parser<INPUT> extends BaseOperator implements Converter<INPUT,
Object>,

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/contrib/src/main/java/com/datatorrent/contrib/schema/parser/XmlParser.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/schema/parser/XmlParser.java b/contrib/src/main/java/com/datatorrent/contrib/schema/parser/XmlParser.java
index 4931497..9e1c8be 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/schema/parser/XmlParser.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/schema/parser/XmlParser.java
@@ -41,6 +41,7 @@ import com.datatorrent.api.Context;
  * @displayName XmlParser
  * @category Parsers
  * @tags xml pojo parser
+ * @since 3.2.0
  */
 @InterfaceStability.Evolving
 public class XmlParser extends Parser<String>

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/demos/pi/src/main/java/com/datatorrent/demos/pi/NamedValueList.java
----------------------------------------------------------------------
diff --git a/demos/pi/src/main/java/com/datatorrent/demos/pi/NamedValueList.java b/demos/pi/src/main/java/com/datatorrent/demos/pi/NamedValueList.java
index f884994..ce5ef9d 100644
--- a/demos/pi/src/main/java/com/datatorrent/demos/pi/NamedValueList.java
+++ b/demos/pi/src/main/java/com/datatorrent/demos/pi/NamedValueList.java
@@ -37,6 +37,7 @@ import com.datatorrent.api.Context.OperatorContext;
  * <p>
  * @displayNamed Value
  * @tags count
+ * @since 3.2.0
  */
 public class NamedValueList<T> extends BaseOperator
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/demos/wordcount/src/main/java/com/datatorrent/demos/wordcount/FileWordCount.java
----------------------------------------------------------------------
diff --git a/demos/wordcount/src/main/java/com/datatorrent/demos/wordcount/FileWordCount.java
b/demos/wordcount/src/main/java/com/datatorrent/demos/wordcount/FileWordCount.java
index 51539dc..ee9439e 100644
--- a/demos/wordcount/src/main/java/com/datatorrent/demos/wordcount/FileWordCount.java
+++ b/demos/wordcount/src/main/java/com/datatorrent/demos/wordcount/FileWordCount.java
@@ -54,6 +54,8 @@ import com.datatorrent.common.util.BaseOperator;
  * to a different snapshot server.
  *
  * Since the EOF is received by a single operator, this operator cannot be partitionable
+ *
+ * @since 3.2.0
  */
 public class FileWordCount extends BaseOperator
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/library/src/main/java/com/datatorrent/lib/appdata/query/WindowBoundedService.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/query/WindowBoundedService.java
b/library/src/main/java/com/datatorrent/lib/appdata/query/WindowBoundedService.java
index 4f653a3..ea9d54b 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/query/WindowBoundedService.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/query/WindowBoundedService.java
@@ -43,6 +43,8 @@ import com.datatorrent.netlet.util.DTThrowable;
  * <br/><br/>
  * <b>Note:</b> This service cannot be used in operators which allow checkpointing
within an
  * application window.
+ *
+ * @since 3.2.0
  */
 public class WindowBoundedService implements Component<OperatorContext>
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/library/src/main/java/com/datatorrent/lib/appdata/schemas/CustomTimeBucket.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/appdata/schemas/CustomTimeBucket.java
b/library/src/main/java/com/datatorrent/lib/appdata/schemas/CustomTimeBucket.java
index f50bb4b..3075da5 100644
--- a/library/src/main/java/com/datatorrent/lib/appdata/schemas/CustomTimeBucket.java
+++ b/library/src/main/java/com/datatorrent/lib/appdata/schemas/CustomTimeBucket.java
@@ -28,6 +28,8 @@ import com.google.common.base.Preconditions;
 
 /**
  * This represents a {@link TimeBucket} which can be a multiple of a time unit.
+ *
+ * @since 3.2.0
  */
 public class CustomTimeBucket implements Serializable, Comparable<CustomTimeBucket>
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java
index e7551a5..6ef9684 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java
@@ -41,6 +41,8 @@ import com.datatorrent.lib.io.block.BlockMetadata;
 
 /**
  * An abstract File Splitter.
+ *
+ * @since 3.2.0
  */
 public abstract class AbstractFileSplitter extends BaseOperator
 {

http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a2e3a730/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java
----------------------------------------------------------------------
diff --git a/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java b/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java
index ebf3739..17a3bb6 100644
--- a/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java
+++ b/library/src/main/java/com/datatorrent/lib/io/fs/FileSplitterBase.java
@@ -36,6 +36,8 @@ import com.datatorrent.api.Operator;
 
 /**
  * A file splitter that receives its input from an upstream operator.
+ *
+ * @since 3.2.0
  */
 public class FileSplitterBase extends AbstractFileSplitter implements Operator.IdleTimeHandler
 {


Mime
View raw message