apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tus...@apache.org
Subject [1/2] apex-core git commit: Add @since tags and update change log for release 3.6.0
Date Fri, 05 May 2017 07:12:35 GMT
Repository: apex-core
Updated Branches:
  refs/heads/release-3.6 ce0a13581 -> f78d5bd5c


Add @since tags and update change log for release 3.6.0


Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/856833c1
Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/856833c1
Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/856833c1

Branch: refs/heads/release-3.6
Commit: 856833c1720d56dbb5732f35e96878bef0c33ce1
Parents: ce0a135
Author: Apex Dev <dev@apex.apache.org>
Authored: Mon May 1 13:22:32 2017 +0530
Committer: Tushar R. Gosavi <tushar@apache.org>
Committed: Mon May 1 13:22:32 2017 +0530

----------------------------------------------------------------------
 CHANGELOG.md                                    | 88 ++++++++++++++++++++
 .../api/ControlTupleEnabledSink.java            |  2 +
 .../apex/api/ControlAwareDefaultInputPort.java  |  2 +
 .../apex/api/ControlAwareDefaultOutputPort.java |  2 +
 .../apache/apex/api/operator/ControlTuple.java  |  2 +
 .../apache/apex/api/plugin/DAGSetupEvent.java   |  3 +
 .../apache/apex/api/plugin/DAGSetupPlugin.java  |  2 +
 .../java/org/apache/apex/api/plugin/Event.java  |  2 +
 .../java/org/apache/apex/api/plugin/Plugin.java |  2 +
 .../bufferserver/packet/CustomControlTuple.java |  2 +
 .../apex/common/util/AsyncStorageAgent.java     |  2 +
 .../org/apache/apex/common/util/JarHelper.java  |  3 +
 .../plan/logical/DAGSetupPluginManager.java     |  3 +
 .../stram/tuple/CustomControlTuple.java         |  2 +
 .../engine/api/plugin/DAGExecutionEvent.java    |  3 +
 .../engine/api/plugin/DAGExecutionPlugin.java   |  2 +
 .../apex/engine/api/plugin/PluginLocator.java   |  2 +
 .../plugin/AbstractApexPluginDispatcher.java    |  2 +
 .../AbstractDAGExecutionPluginContext.java      |  3 +
 .../engine/plugin/ApexPluginDispatcher.java     |  3 +
 .../plugin/DefaultApexPluginDispatcher.java     |  2 +
 .../engine/plugin/NoOpApexPluginDispatcher.java |  3 +
 .../plugin/loaders/ChainedPluginLocator.java    |  3 +
 .../loaders/PropertyBasedPluginLocator.java     |  3 +
 .../ServiceLoaderBasedPluginLocator.java        |  3 +
 .../plugin/loaders/StaticPluginLocator.java     |  3 +
 .../apex/engine/util/CascadeStorageAgent.java   |  2 +
 .../org/apache/apex/log/LogFileInformation.java |  3 +
 28 files changed, 154 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 59e7257..ac521af 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,6 +1,94 @@
 Apex Changelog
 ========================================================================================================================
 
+Version 3.6.0 - 2017-05-04
+------------------------------------------------------------------------------------------------------------------------
+
+### Bug
+* [APEXCORE-471] - Requests for container allocation are not resubmitted
+* [APEXCORE-504] - Possible race condition in StreamingContainerAgent.getStreamCodec()
+* [APEXCORE-558] - Do not use yellow color to display command strings in help output
+* [APEXCORE-583] - Buffer Server LogicalNode should not be reused by Subscribers
+* [APEXCORE-585] - Latency should be calculated only after the first window has been complete
+* [APEXCORE-590] - Failed to restart application on MapR
+* [APEXCORE-591] - SubscribeRequestTuple has wrong buffer size when mask is zero
+* [APEXCORE-593] - apex cli get-app-package-info could not retrieve properties defined in
properties.xml
+* [APEXCORE-595] - Master incorrectly updates committedWindowId when all partitions are terminated.
+* [APEXCORE-596] - Committed method on operators not called when stream locality is THREAD_LOCAL
+* [APEXCORE-597] - BufferServer needs to shutdown all created execution services
+* [APEXCORE-598] - Embedded mode execution does not use APPLICATION_PATH for checkpointing
+* [APEXCORE-608] - Streaming Containers use stale RPC proxy after connection is closed
+* [APEXCORE-610] - Avoid multiple getBytes() calls in Tuple.writeString
+* [APEXCORE-616] - Application fails to start Kerberised cluster
+* [APEXCORE-617] - InputNodeTest intermittently fails with ConcurrentModificationException
+* [APEXCORE-624] - Shutdown does not work because of incorrect logic in the AppMaster
+* [APEXCORE-627] - Unit test AtMostOnceTest intermittently fails
+* [APEXCORE-634] - Unifier attributes are not set for modules in DAG
+* [APEXCORE-636] - Ability to refresh tokens using user's own kerberos credentials in a
managed environment
+* [APEXCORE-641] - Subscribers/DataListeners may not be scheduled to execute even when they
have data to process
+* [APEXCORE-644] - get-app-package-operators with parent option does not work
+* [APEXCORE-645] - StramLocalCluster does not wait for master thread termination
+* [APEXCORE-648] - Unnecessary byte array copy in DefaultStatefulStreamCodec.toDataStatePair()
+* [APEXCORE-654] - Recovery window is not updated when Delay Operator is used along with
Partitioned Operators
+* [APEXCORE-663] - Application restart not working.
+* [APEXCORE-671] - DTConfiguration utility class ValueEntry access level was changed
+* [APEXCORE-678] - Shutdown of application should start from input nodes
+* [APEXCORE-686] - AppPackage fails when .apa contains zero length stored entry
+* [APEXCORE-690] - Embedded app launcher does not apply HEARTBEAT_MONITORING setting
+* [APEXCORE-703] - Window processing timeout for finished/undeployed container
+* [APEXCORE-709] - Refactor changes done through APEXCORE-575
+
+### Dependency upgrade
+* [APEXCORE-656] - Upgrade org.apache.httpcomponents.httpclient to  4.3.6 version
+
+### Documentation
+* [APEXCORE-687] - Update docs, change supported Hadoop version to 2.6
+* [APEXCORE-692] - Apex Dev Setup doc should reference download page
+
+### Improvement
+* [APEXCORE-294] - Graceful application shutdown
+* [APEXCORE-426] - Support work preserving AM recovery
+* [APEXCORE-456] - Explicitly limit Server.Subscriber to one way communication
+* [APEXCORE-511] - DAG.addOperator, addStream and addModule should check for null and empty
names
+* [APEXCORE-522] - Promote singleton usage pattern for String2String, Long2String and other
StringCodecs
+* [APEXCORE-570] - Prevent upstream operators from getting too far ahead when downstream
operators are slow
+* [APEXCORE-572] - Remove dependency on hadoop-common test.jar
+* [APEXCORE-575] - Improve application relaunch time.
+* [APEXCORE-592] - Returning description field in defaultProperties during apex cli call
get-app-package-info
+* [APEXCORE-605] - Suppress bootstrap compiler warning
+* [APEXCORE-611] - Stram Event Log Levels
+* [APEXCORE-655] - Support RELEASE as archetype version when creating a project
+* [APEXCORE-676] - Show description for DefaultProperties only when user requests it
+* [APEXCORE-677] - Avoid starting StramLocalCluster in StreamingContainerManagerTest.testAppDataSources
+* [APEXCORE-683] - Apex client should support application packages on HDFS
+* [APEXCORE-715] - Remove unnecessary @Evolving annotation in engine
+
+### New Feature
+* [APEXCORE-563] - Have a pointer to log file name and offset in container/operator failure
events
+* [APEXCORE-579] - Custom control tuple support
+* [APEXCORE-594] - Plugin support in Apex
+
+### Task
+* [APEXCORE-480] - Change the container log name from dt.log to apex.log
+* [APEXCORE-658] - Replace dt. prefix with apex. for configuration keys
+* [APEXCORE-662] - Raise StramEvent for heartbeat miss
+* [APEXCORE-691] - Use type inference for generic instance creation
+* [APEXCORE-695] - Remove unnecessary interface modifiers
+* [APEXCORE-701] - Upgrade Malhar version in archetype to 3.7.0
+
+### Sub-task
+* [APEXCORE-577] - Plugin support to inspect DAG before launch.
+* [APEXCORE-580] - Interface for processing and emitting control tuples
+* [APEXCORE-581] - Delivery of Custom Control Tuples
+* [APEXCORE-604] - Extend DAG API to allow accessing DAG objects.
+* [APEXCORE-649] - Infrastructure for user define stram event listeners.
+* [APEXCORE-660] - Documentation for Control tuple support changes
+* [APEXCORE-674] - Change access specifier of DTConfiguration.ValueEntry to private
+* [APEXCORE-680] - Review container heartbeat timeout log level messages
+* [APEXCORE-700] - Make the plugin registration interface uniform
+* [APEXCORE-702] - Mark ApexPlugin as Evolving
+
+
 Version 3.5.0 - 2016-12-09
 ------------------------------------------------------------------------------------------------------------------------
 

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java b/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java
index 40b7436..bf642ad 100644
--- a/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java
+++ b/api/src/main/java/com/datatorrent/api/ControlTupleEnabledSink.java
@@ -23,6 +23,8 @@ import org.apache.hadoop.classification.InterfaceStability;
 
 /**
  * A {@link Sink} which supports adding control tuples
+ *
+ * @since 3.6.0
  */
 @InterfaceStability.Evolving
 public interface ControlTupleEnabledSink<T> extends Sink<T>

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java b/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java
index 07e8343..f17d540 100644
--- a/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java
+++ b/api/src/main/java/org/apache/apex/api/ControlAwareDefaultInputPort.java
@@ -27,6 +27,8 @@ import com.datatorrent.api.DefaultInputPort;
 /**
  * Default abstract implementation for an input port which is capable of processing
  * @{@link UserDefinedControlTuple}
+ *
+ * @since 3.6.0
  */
 @InterfaceStability.Evolving
 public abstract class ControlAwareDefaultInputPort<T> extends DefaultInputPort<T>
implements ControlTupleEnabledSink<T>

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java b/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java
index 77addf9..9400bbd 100644
--- a/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java
+++ b/api/src/main/java/org/apache/apex/api/ControlAwareDefaultOutputPort.java
@@ -28,6 +28,8 @@ import com.datatorrent.api.Sink;
 /**
  * Default implementation for an output port which can emit a @{@link ControlTuple}.
  * The {@link #emitControl(ControlTuple)} method can be used to emit control tuples onto
this output port
+ *
+ * @since 3.6.0
  */
 @InterfaceStability.Evolving
 public class ControlAwareDefaultOutputPort<T> extends DefaultOutputPort<T>

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java b/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java
index a1aa6f9..1dc9ae2 100644
--- a/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java
+++ b/api/src/main/java/org/apache/apex/api/operator/ControlTuple.java
@@ -22,6 +22,8 @@ import org.apache.hadoop.classification.InterfaceStability;
 
 /**
  * Any user generated control tuple must implement {@link ControlTuple} interface
+ *
+ * @since 3.6.0
  */
 @InterfaceStability.Evolving
 public interface ControlTuple

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java b/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java
index 95d17e2..85182de 100644
--- a/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java
+++ b/api/src/main/java/org/apache/apex/api/plugin/DAGSetupEvent.java
@@ -24,6 +24,9 @@ import org.apache.hadoop.conf.Configuration;
 import com.datatorrent.api.DAG;
 
 @Evolving
+/**
+ * @since 3.6.0
+ */
 public class DAGSetupEvent extends Event.BaseEvent<DAGSetupEvent.Type>
 {
   @Evolving

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java b/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java
index 31ea1f3..c2b77a0 100644
--- a/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java
+++ b/api/src/main/java/org/apache/apex/api/plugin/DAGSetupPlugin.java
@@ -35,6 +35,8 @@ import com.datatorrent.api.DAG;
  *   <li>Before dag is validated</li>
  *   <li>After dag is validated</li>
  * </ul>
+ *
+ * @since 3.6.0
  */
 @Evolving
 public interface DAGSetupPlugin<T extends DAGSetupPlugin.Context> extends Plugin<T>

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/plugin/Event.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/plugin/Event.java b/api/src/main/java/org/apache/apex/api/plugin/Event.java
index 9b95187..edca156 100644
--- a/api/src/main/java/org/apache/apex/api/plugin/Event.java
+++ b/api/src/main/java/org/apache/apex/api/plugin/Event.java
@@ -27,6 +27,8 @@ import org.apache.hadoop.classification.InterfaceStability.Evolving;
  * Plugins express interest in receiving events by registering handlers for the event type
and their handlers receive
  * the events.
  * @param <T> event type
+ *
+ * @since 3.6.0
  */
 @Evolving
 public interface Event<T extends Type>

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/api/src/main/java/org/apache/apex/api/plugin/Plugin.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/org/apache/apex/api/plugin/Plugin.java b/api/src/main/java/org/apache/apex/api/plugin/Plugin.java
index e0a3872..dc21395 100644
--- a/api/src/main/java/org/apache/apex/api/plugin/Plugin.java
+++ b/api/src/main/java/org/apache/apex/api/plugin/Plugin.java
@@ -30,6 +30,8 @@ import com.datatorrent.api.Context;
  * initialization method. They should also cleanup any additional resources created during
shutdown such as helper
  * threads and open files in the {@link Component#teardown()} method.
  * @param <T> plugin context type
+ *
+ * @since 3.6.0
  */
 @Evolving
 public interface Plugin<T extends Plugin.PluginContext> extends Component<T>

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
----------------------------------------------------------------------
diff --git a/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
b/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
index 3aca31d..19a6a41 100644
--- a/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
+++ b/bufferserver/src/main/java/com/datatorrent/bufferserver/packet/CustomControlTuple.java
@@ -20,6 +20,8 @@ package com.datatorrent.bufferserver.packet;
 
 /**
  * Custom Control Tuple class
+ *
+ * @since 3.6.0
  */
 public class CustomControlTuple extends DataTuple
 {

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java b/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java
index f797b92..2fb399d 100644
--- a/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java
+++ b/common/src/main/java/org/apache/apex/common/util/AsyncStorageAgent.java
@@ -29,6 +29,8 @@ import com.datatorrent.api.StorageAgent;
  * An AsyncStorageAgent enables quick checkpoints by taking local snapshot of an operator
  * and unblocking the operator to process more data, while storage engine is pushing local
snapshot to
  * the distributed or globally accessible location for recovery.
+ *
+ * @since 3.6.0
  */
 @InterfaceStability.Evolving
 public interface AsyncStorageAgent extends StorageAgent

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/common/src/main/java/org/apache/apex/common/util/JarHelper.java
----------------------------------------------------------------------
diff --git a/common/src/main/java/org/apache/apex/common/util/JarHelper.java b/common/src/main/java/org/apache/apex/common/util/JarHelper.java
index 91ba117..d40cec8 100644
--- a/common/src/main/java/org/apache/apex/common/util/JarHelper.java
+++ b/common/src/main/java/org/apache/apex/common/util/JarHelper.java
@@ -46,6 +46,9 @@ import org.apache.hadoop.classification.InterfaceStability;
 
 @InterfaceAudience.Public
 @InterfaceStability.Evolving
+/**
+ * @since 3.6.0
+ */
 public class JarHelper
 {
   private static final Logger logger = LoggerFactory.getLogger(JarHelper.class);

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
b/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
index 370aaaa..03958f4 100644
--- a/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
+++ b/engine/src/main/java/com/datatorrent/stram/plan/logical/DAGSetupPluginManager.java
@@ -38,6 +38,9 @@ import com.datatorrent.api.DAG;
 
 import static org.slf4j.LoggerFactory.getLogger;
 
+/**
+ * @since 3.6.0
+ */
 public class DAGSetupPluginManager
 {
   private static final Logger LOG = getLogger(DAGSetupPluginManager.class);

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java b/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java
index 810fa57..ad549c5 100644
--- a/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java
+++ b/engine/src/main/java/com/datatorrent/stram/tuple/CustomControlTuple.java
@@ -28,6 +28,8 @@ import com.datatorrent.bufferserver.packet.MessageType;
 /**
  * An implementation for @{@link Tuple} which can be generated by the user
  * Acts as the wrapper for the user payload
+ *
+ * @since 3.6.0
  */
 public class CustomControlTuple extends Tuple
 {

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
index dfffbca..3a9a016 100644
--- a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
+++ b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionEvent.java
@@ -27,6 +27,9 @@ import static org.apache.apex.engine.api.plugin.DAGExecutionEvent.Type.COMMIT_EV
 import static org.apache.apex.engine.api.plugin.DAGExecutionEvent.Type.HEARTBEAT_EVENT;
 import static org.apache.apex.engine.api.plugin.DAGExecutionEvent.Type.STRAM_EVENT;
 
+/**
+ * @since 3.6.0
+ */
 public class DAGExecutionEvent extends Event.BaseEvent<DAGExecutionEvent.Type>
 {
   public enum Type implements Event.Type

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
index 7cfb1fa..200948d 100644
--- a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
+++ b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java
@@ -43,6 +43,8 @@ import com.datatorrent.stram.webapp.LogicalOperatorInfo;
  *   <li>{@see Context.COMMIT_EVENT} When committedWindowId changes in the platform
an event will be delivered to the plugin</li>
  * </ul>
  *
+ *
+ * @since 3.6.0
  */
 public interface DAGExecutionPlugin<T extends DAGExecutionPlugin.Context> extends Plugin<T>
 {

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java b/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java
index cd9a208..ec1c92d 100644
--- a/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java
@@ -25,6 +25,8 @@ import org.apache.hadoop.conf.Configuration;
 /**
  * Interface to discover plugins during Apex Master initialization. This should return collection
of
  * objects implementing an interface of type T.
+ *
+ * @since 3.6.0
  */
 public interface PluginLocator<T>
 {

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
b/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
index 74ee0c8..5e468f5 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/AbstractApexPluginDispatcher.java
@@ -53,6 +53,8 @@ import com.datatorrent.stram.webapp.AppInfo;
 /**
  * A default implementation for ApexPluginDispatcher. It handles common tasks, such as handler
  * registrations. Actual dispatching is left for classes extending from it.
+ *
+ * @since 3.6.0
  */
 public abstract class AbstractApexPluginDispatcher extends AbstractService implements ApexPluginDispatcher
 {

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
b/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
index 21f29f8..e839ffc 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/AbstractDAGExecutionPluginContext.java
@@ -38,6 +38,9 @@ import com.datatorrent.stram.util.VersionInfo;
 import com.datatorrent.stram.webapp.AppInfo;
 import com.datatorrent.stram.webapp.LogicalOperatorInfo;
 
+/**
+ * @since 3.6.0
+ */
 public abstract class AbstractDAGExecutionPluginContext<E extends DAGExecutionEvent>
implements DAGExecutionPlugin.Context<E>
 {
   private final StreamingContainerManager dnmgr;

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
b/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
index 9ef2a5d..663c23a 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/ApexPluginDispatcher.java
@@ -23,6 +23,9 @@ import org.apache.hadoop.service.Service;
 
 import com.datatorrent.api.DAG;
 
+/**
+ * @since 3.6.0
+ */
 public interface ApexPluginDispatcher extends Service
 {
 

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
b/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
index 1252061..b7bbc48 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/DefaultApexPluginDispatcher.java
@@ -43,6 +43,8 @@ import com.datatorrent.stram.webapp.AppInfo;
  * Handle dispatching of events from Stram to Plugins. This implementation creates an executor
  * service to process the event asynchronously. A separate task {@link DefaultApexPluginDispatcher.ProcessEventTask}
  * is created to process an event and then submitted to the executor for execution.
+ *
+ * @since 3.6.0
  */
 public class DefaultApexPluginDispatcher extends AbstractApexPluginDispatcher
 {

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
b/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
index a629a3f..f2be11a 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/NoOpApexPluginDispatcher.java
@@ -21,6 +21,9 @@ package org.apache.apex.engine.plugin;
 import org.apache.apex.api.plugin.Event;
 import org.apache.hadoop.service.AbstractService;
 
+/**
+ * @since 3.6.0
+ */
 public class NoOpApexPluginDispatcher extends AbstractService implements ApexPluginDispatcher
 {
   public NoOpApexPluginDispatcher()

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
index df3b50a..362928d 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ChainedPluginLocator.java
@@ -28,6 +28,9 @@ import org.slf4j.LoggerFactory;
 import org.apache.apex.engine.api.plugin.PluginLocator;
 import org.apache.hadoop.conf.Configuration;
 
+/**
+ * @since 3.6.0
+ */
 public class ChainedPluginLocator<T> implements PluginLocator<T>
 {
   private static final Logger LOG = LoggerFactory.getLogger(ChainedPluginLocator.class);

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
index b131109..d701199 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/PropertyBasedPluginLocator.java
@@ -30,6 +30,9 @@ import org.apache.hadoop.conf.Configuration;
 
 import com.datatorrent.stram.StramUtils;
 
+/**
+ * @since 3.6.0
+ */
 public class PropertyBasedPluginLocator<T> implements PluginLocator<T>
 {
   private static final Logger LOG = LoggerFactory.getLogger(PropertyBasedPluginLocator.class);

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
index be7dfc4..33eba65 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/ServiceLoaderBasedPluginLocator.java
@@ -26,6 +26,9 @@ import java.util.ServiceLoader;
 import org.apache.apex.engine.api.plugin.PluginLocator;
 import org.apache.hadoop.conf.Configuration;
 
+/**
+ * @since 3.6.0
+ */
 public class ServiceLoaderBasedPluginLocator<T> implements PluginLocator<T>
 {
   private final Class<T> klass;

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
index 4767196..2da1665 100644
--- a/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
+++ b/engine/src/main/java/org/apache/apex/engine/plugin/loaders/StaticPluginLocator.java
@@ -27,6 +27,9 @@ import org.slf4j.LoggerFactory;
 import org.apache.apex.engine.api.plugin.PluginLocator;
 import org.apache.hadoop.conf.Configuration;
 
+/**
+ * @since 3.6.0
+ */
 public class StaticPluginLocator<T> implements PluginLocator<T>
 {
   private static final Logger LOG = LoggerFactory.getLogger(StaticPluginLocator.class);

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java b/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java
index bc3df77..918483f 100644
--- a/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java
+++ b/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java
@@ -40,6 +40,8 @@ import com.datatorrent.api.StorageAgent;
  * large impacting application restart time. This storage-agent is used during application
  * restart to avoiding copying checkpoints from old application directory to improve application
  * restart time.
+ *
+ * @since 3.6.0
  */
 public class CascadeStorageAgent implements StorageAgent, AsyncStorageAgent, Serializable
 {

http://git-wip-us.apache.org/repos/asf/apex-core/blob/856833c1/engine/src/main/java/org/apache/apex/log/LogFileInformation.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/org/apache/apex/log/LogFileInformation.java b/engine/src/main/java/org/apache/apex/log/LogFileInformation.java
index 841d847..e4b195c 100644
--- a/engine/src/main/java/org/apache/apex/log/LogFileInformation.java
+++ b/engine/src/main/java/org/apache/apex/log/LogFileInformation.java
@@ -20,6 +20,9 @@ package org.apache.apex.log;
 
 import com.datatorrent.stram.util.AbstractWritableAdapter;
 
+/**
+ * @since 3.6.0
+ */
 public class LogFileInformation extends AbstractWritableAdapter
 {
 


Mime
View raw message