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 <[email protected]> Authored: Mon May 1 13:22:32 2017 +0530 Committer: Tushar R. Gosavi <[email protected]> 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 {
