apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vro...@apache.org
Subject [23/34] incubator-apex-core git commit: Automated license header format: mvn license:format -Dlicense.skip=false
Date Sat, 26 Sep 2015 04:11:41 GMT
Automated license header format:
mvn license:format -Dlicense.skip=false

Check:
mvn apache-rat:check


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

Branch: refs/heads/feature-module
Commit: 730e57f78d44874db7be7ecf89497cf0010e1c55
Parents: 6345be3
Author: MalharJenkins <jenkins@datatorrent.com>
Authored: Thu Sep 24 18:19:33 2015 -0700
Committer: MalharJenkins <jenkins@datatorrent.com>
Committed: Thu Sep 24 18:19:33 2015 -0700

----------------------------------------------------------------------
 apex-app-archetype/pom.xml                      | 20 +++++++++++++
 .../META-INF/maven/archetype-metadata.xml       | 20 +++++++++++++
 .../main/resources/META-INF/maven/archetype.xml | 20 +++++++++++++
 .../projects/basic/archetype.properties         | 19 ++++++++++++
 apex-conf-archetype/pom.xml                     | 20 +++++++++++++
 .../META-INF/maven/archetype-metadata.xml       | 20 +++++++++++++
 .../main/resources/META-INF/maven/archetype.xml | 20 +++++++++++++
 .../projects/basic/archetype.properties         | 19 ++++++++++++
 apex_checks.xml                                 | 20 +++++++++++++
 api/pom.xml                                     | 20 +++++++++++++
 .../java/com/datatorrent/api/Attribute.java     | 25 +++++++++-------
 .../java/com/datatorrent/api/AutoMetric.java    | 25 +++++++++-------
 .../java/com/datatorrent/api/Component.java     | 25 +++++++++-------
 .../main/java/com/datatorrent/api/Context.java  | 25 +++++++++-------
 api/src/main/java/com/datatorrent/api/DAG.java  | 25 +++++++++-------
 .../com/datatorrent/api/DefaultInputPort.java   | 25 +++++++++-------
 .../com/datatorrent/api/DefaultOutputPort.java  | 25 +++++++++-------
 .../com/datatorrent/api/DefaultPartition.java   | 25 +++++++++-------
 .../java/com/datatorrent/api/InputOperator.java | 25 +++++++++-------
 .../java/com/datatorrent/api/LocalMode.java     | 25 +++++++++-------
 .../main/java/com/datatorrent/api/Operator.java | 25 +++++++++-------
 .../java/com/datatorrent/api/Partitioner.java   | 25 +++++++++-------
 api/src/main/java/com/datatorrent/api/Sink.java | 25 +++++++++-------
 .../main/java/com/datatorrent/api/Stats.java    | 25 +++++++++-------
 .../java/com/datatorrent/api/StatsListener.java | 25 +++++++++-------
 .../java/com/datatorrent/api/StorageAgent.java  | 25 +++++++++-------
 .../java/com/datatorrent/api/StreamCodec.java   | 25 +++++++++-------
 .../datatorrent/api/StreamingApplication.java   | 25 +++++++++-------
 .../java/com/datatorrent/api/StringCodec.java   | 25 +++++++++-------
 .../api/annotation/ApplicationAnnotation.java   | 25 +++++++++-------
 .../annotation/InputPortFieldAnnotation.java    | 25 +++++++++-------
 .../com/datatorrent/api/annotation/Name.java    | 27 +++++++++--------
 .../api/annotation/OperatorAnnotation.java      | 25 +++++++++-------
 .../annotation/OutputPortFieldAnnotation.java   | 25 +++++++++-------
 .../datatorrent/api/annotation/RecordField.java | 25 +++++++++-------
 .../datatorrent/api/annotation/Stateless.java   | 25 +++++++++-------
 .../api/annotation/package-info.java            | 25 +++++++++-------
 .../java/com/datatorrent/api/package-info.java  | 25 +++++++++-------
 .../com/datatorrent/api/AttributeMapTest.java   | 25 +++++++++-------
 .../com/datatorrent/api/Object2StringTest.java  | 25 +++++++++-------
 api/src/test/resources/log4j.properties         | 19 ++++++++++++
 bufferserver/nbactions.xml                      | 20 +++++++++++++
 bufferserver/pom.xml                            | 20 +++++++++++++
 .../bufferserver/auth/AuthManager.java          | 25 +++++++++-------
 .../bufferserver/client/AuthClient.java         | 25 +++++++++-------
 .../bufferserver/client/Controller.java         | 25 +++++++++-------
 .../bufferserver/client/Publisher.java          | 25 +++++++++-------
 .../bufferserver/client/Subscriber.java         | 25 +++++++++-------
 .../bufferserver/internal/DataList.java         | 25 +++++++++-------
 .../bufferserver/internal/DataListener.java     | 25 +++++++++-------
 .../bufferserver/internal/FastDataList.java     | 25 +++++++++-------
 .../bufferserver/internal/LogicalNode.java      | 25 +++++++++-------
 .../bufferserver/internal/PhysicalNode.java     | 25 +++++++++-------
 .../bufferserver/internal/package-info.java     | 25 +++++++++-------
 .../bufferserver/packet/BeginWindowTuple.java   | 25 +++++++++-------
 .../bufferserver/packet/DataTuple.java          | 25 +++++++++-------
 .../bufferserver/packet/EmptyTuple.java         | 25 +++++++++-------
 .../bufferserver/packet/EndStreamTuple.java     | 25 +++++++++-------
 .../bufferserver/packet/EndWindowTuple.java     | 25 +++++++++-------
 .../packet/GenericRequestTuple.java             | 25 +++++++++-------
 .../bufferserver/packet/MessageType.java        | 25 +++++++++-------
 .../bufferserver/packet/NoMessageTuple.java     | 25 +++++++++-------
 .../bufferserver/packet/PayloadTuple.java       | 25 +++++++++-------
 .../packet/PublishRequestTuple.java             | 25 +++++++++-------
 .../bufferserver/packet/PurgeRequestTuple.java  | 25 +++++++++-------
 .../bufferserver/packet/RequestTuple.java       | 25 +++++++++-------
 .../bufferserver/packet/ResetRequestTuple.java  | 25 +++++++++-------
 .../bufferserver/packet/ResetWindowTuple.java   | 25 +++++++++-------
 .../packet/SubscribeRequestTuple.java           | 25 +++++++++-------
 .../datatorrent/bufferserver/packet/Tuple.java  | 25 +++++++++-------
 .../bufferserver/packet/WindowIdTuple.java      | 25 +++++++++-------
 .../bufferserver/policy/AbstractPolicy.java     | 25 +++++++++-------
 .../bufferserver/policy/GiveAll.java            | 25 +++++++++-------
 .../bufferserver/policy/LeastBusy.java          | 25 +++++++++-------
 .../datatorrent/bufferserver/policy/Policy.java | 25 +++++++++-------
 .../bufferserver/policy/RandomOne.java          | 25 +++++++++-------
 .../bufferserver/policy/RoundRobin.java         | 25 +++++++++-------
 .../bufferserver/policy/package-info.java       | 25 +++++++++-------
 .../datatorrent/bufferserver/server/Server.java | 25 +++++++++-------
 .../bufferserver/storage/DiskStorage.java       | 25 +++++++++-------
 .../bufferserver/storage/Storage.java           | 25 +++++++++-------
 .../bufferserver/util/BitVector.java            | 25 +++++++++-------
 .../datatorrent/bufferserver/util/Codec.java    | 25 +++++++++-------
 .../bufferserver/util/SerializedData.java       | 25 +++++++++-------
 .../datatorrent/bufferserver/util/System.java   | 25 +++++++++-------
 .../datatorrent/bufferserver/util/VarInt.java   | 27 +++++++++--------
 .../bufferserver/util/package-info.java         | 25 +++++++++-------
 .../bufferserver/client/SubscriberTest.java     | 25 +++++++++-------
 .../bufferserver/packet/NoMessageTupleTest.java | 25 +++++++++-------
 .../packet/PublishRequestTupleTest.java         | 25 +++++++++-------
 .../packet/ResetWindowTupleTest.java            | 25 +++++++++-------
 .../packet/SubscribeRequestTupleTest.java       | 25 +++++++++-------
 .../bufferserver/server/ServerTest.java         | 25 +++++++++-------
 .../bufferserver/storage/DiskStorageTest.java   | 25 +++++++++-------
 .../bufferserver/support/Controller.java        | 25 +++++++++-------
 .../bufferserver/support/Publisher.java         | 25 +++++++++-------
 .../bufferserver/support/Subscriber.java        | 25 +++++++++-------
 .../bufferserver/util/CodecTest.java            | 25 +++++++++-------
 .../src/test/resources/log4j.properties         | 19 ++++++++++++
 common/pom.xml                                  | 20 +++++++++++++
 .../common/codec/JsonStreamCodec.java           | 25 +++++++++-------
 .../common/experimental/AppData.java            | 25 +++++++++-------
 .../common/metric/MetricsAggregator.java        | 25 +++++++++-------
 .../common/metric/SingleMetricAggregator.java   | 27 +++++++++--------
 .../common/metric/sum/DoubleSumAggregator.java  | 27 +++++++++--------
 .../common/metric/sum/LongSumAggregator.java    | 27 +++++++++--------
 .../partitioner/StatelessPartitioner.java       | 25 +++++++++-------
 .../common/security/SecurityContext.java        | 25 +++++++++-------
 .../auth/callback/DefaultCallbackHandler.java   | 25 +++++++++-------
 .../common/util/AsyncFSStorageAgent.java        | 26 ++++++++--------
 .../datatorrent/common/util/BaseOperator.java   | 25 +++++++++-------
 .../util/BasicContainerOptConfigurator.java     | 25 +++++++++-------
 .../datatorrent/common/util/FSStorageAgent.java | 25 +++++++++-------
 .../util/JacksonObjectMapperProvider.java       | 25 +++++++++-------
 .../common/util/NameableThreadFactory.java      | 25 +++++++++-------
 .../common/util/NumberAggregate.java            | 25 +++++++++-------
 .../common/util/ObjectMapperString.java         | 25 +++++++++-------
 .../java/com/datatorrent/common/util/Pair.java  | 25 +++++++++-------
 .../datatorrent/common/util/PubSubMessage.java  | 25 +++++++++-------
 .../common/util/PubSubMessageCodec.java         | 25 +++++++++-------
 .../common/util/PubSubWebSocketClient.java      | 25 +++++++++-------
 .../common/util/ScheduledExecutorService.java   | 25 +++++++++-------
 .../util/ScheduledThreadPoolExecutor.java       | 25 +++++++++-------
 .../common/util/SerializableObject.java         | 25 +++++++++-------
 .../datatorrent/common/util/package-info.java   | 25 +++++++++-------
 .../common/codec/JsonStreamCodecTest.java       | 25 +++++++++-------
 .../partitioner/StatelessPartitionerTest.java   | 25 +++++++++-------
 .../common/util/AsyncFSStorageAgentTest.java    | 25 +++++++++-------
 .../common/util/FSStorageAgentTest.java         | 25 +++++++++-------
 .../common/util/SerializableObjectTest.java     | 25 +++++++++-------
 common/src/test/resources/log4j.properties      | 19 ++++++++++++
 engine/pom.xml                                  | 20 +++++++++++++
 .../stram/BufferServerController.java           | 25 +++++++++-------
 .../stram/ComponentConfigurationPair.java       | 25 +++++++++-------
 .../datatorrent/stram/ComponentContextPair.java | 25 +++++++++-------
 .../com/datatorrent/stram/EventRecorder.java    | 25 +++++++++-------
 .../com/datatorrent/stram/FSEventRecorder.java  | 25 +++++++++-------
 .../datatorrent/stram/FSRecoveryHandler.java    | 25 +++++++++-------
 .../com/datatorrent/stram/FSStatsRecorder.java  | 25 +++++++++-------
 .../java/com/datatorrent/stram/Journal.java     | 25 +++++++++-------
 .../stram/LaunchContainerRunnable.java          | 25 +++++++++-------
 .../datatorrent/stram/LicensingProtocol.java    | 25 +++++++++-------
 .../com/datatorrent/stram/LocalModeImpl.java    | 25 +++++++++-------
 .../stram/PhysicalMetricsContextImpl.java       | 25 +++++++++-------
 .../datatorrent/stram/RecoverableRpcProxy.java  | 25 +++++++++-------
 .../stram/ResourceRequestHandler.java           | 25 +++++++++-------
 .../com/datatorrent/stram/StatsRecorder.java    | 25 +++++++++-------
 .../com/datatorrent/stram/StramAppContext.java  | 25 +++++++++-------
 .../java/com/datatorrent/stram/StramClient.java | 25 +++++++++-------
 .../datatorrent/stram/StramLocalCluster.java    | 25 +++++++++-------
 .../java/com/datatorrent/stram/StramUtils.java  | 25 +++++++++-------
 .../datatorrent/stram/StreamingAppMaster.java   | 25 +++++++++-------
 .../stram/StreamingAppMasterService.java        | 25 +++++++++-------
 .../stram/StreamingContainerAgent.java          | 25 +++++++++-------
 .../stram/StreamingContainerManager.java        | 25 +++++++++-------
 .../stram/StreamingContainerParent.java         | 25 +++++++++-------
 .../stram/StreamingContainerSecurityInfo.java   | 25 +++++++++-------
 .../com/datatorrent/stram/StringCodecs.java     | 25 +++++++++-------
 .../stram/WebsocketAppDataPusher.java           | 25 +++++++++-------
 .../datatorrent/stram/api/AppDataPusher.java    | 25 +++++++++-------
 .../datatorrent/stram/api/AppDataSource.java    | 27 +++++++++--------
 .../com/datatorrent/stram/api/BaseContext.java  | 25 +++++++++-------
 .../com/datatorrent/stram/api/Checkpoint.java   | 25 +++++++++-------
 .../datatorrent/stram/api/ContainerContext.java | 25 +++++++++-------
 .../datatorrent/stram/api/ContainerEvent.java   | 25 +++++++++-------
 .../stram/api/NodeActivationListener.java       | 25 +++++++++-------
 .../stram/api/OperatorDeployInfo.java           | 25 +++++++++-------
 .../datatorrent/stram/api/RequestFactory.java   | 25 +++++++++-------
 .../com/datatorrent/stram/api/StramEvent.java   | 25 +++++++++-------
 .../api/StramToNodeChangeLoggersRequest.java    | 25 +++++++++-------
 .../api/StramToNodeGetPropertyRequest.java      | 25 +++++++++-------
 .../api/StramToNodeSetPropertyRequest.java      | 25 +++++++++-------
 .../api/StramToNodeStartRecordingRequest.java   | 25 +++++++++-------
 .../StreamingContainerUmbilicalProtocol.java    | 25 +++++++++-------
 .../stram/appdata/AppDataPushAgent.java         | 25 +++++++++-------
 .../java/com/datatorrent/stram/cli/DTCli.java   | 25 +++++++++-------
 .../com/datatorrent/stram/cli/package-info.java | 25 +++++++++-------
 .../datatorrent/stram/client/AppPackage.java    | 25 +++++++++-------
 .../stram/client/ClassPathResolvers.java        | 25 +++++++++-------
 .../datatorrent/stram/client/ConfigPackage.java | 25 +++++++++-------
 .../stram/client/DTConfiguration.java           | 25 +++++++++-------
 .../datatorrent/stram/client/EventsAgent.java   | 25 +++++++++-------
 .../com/datatorrent/stram/client/FSAgent.java   | 25 +++++++++-------
 .../stram/client/FSPartFileAgent.java           | 25 +++++++++-------
 .../stram/client/PermissionsInfo.java           | 25 +++++++++-------
 .../stram/client/RecordingsAgent.java           | 25 +++++++++-------
 .../datatorrent/stram/client/StatsAgent.java    | 25 +++++++++-------
 .../datatorrent/stram/client/StramAgent.java    | 25 +++++++++-------
 .../stram/client/StramAppLauncher.java          | 25 +++++++++-------
 .../stram/client/StramClientUtils.java          | 25 +++++++++-------
 .../client/WebServicesVersionConversion.java    | 25 +++++++++-------
 .../stram/codec/DefaultStatefulStreamCodec.java | 25 +++++++++-------
 .../stram/codec/LogicalPlanSerializer.java      | 25 +++++++++-------
 .../stram/codec/StatefulStreamCodec.java        | 25 +++++++++-------
 .../com/datatorrent/stram/debug/MuxSink.java    | 25 +++++++++-------
 .../stram/debug/OperatorIdPortNamePair.java     | 25 +++++++++-------
 .../datatorrent/stram/debug/StdOutErrLog.java   | 25 +++++++++-------
 .../stram/debug/TappedReservoir.java            | 25 +++++++++-------
 .../datatorrent/stram/debug/TupleRecorder.java  | 25 +++++++++-------
 .../stram/debug/TupleRecorderCollection.java    | 25 +++++++++-------
 .../engine/BufferServerStatsSubscriber.java     | 25 +++++++++-------
 .../stram/engine/ByteCounterStream.java         | 25 +++++++++-------
 .../stram/engine/DefaultReservoir.java          | 25 +++++++++-------
 .../stram/engine/DefaultUnifier.java            | 25 +++++++++-------
 .../datatorrent/stram/engine/GenericNode.java   | 25 +++++++++-------
 .../com/datatorrent/stram/engine/InputNode.java | 25 +++++++++-------
 .../datatorrent/stram/engine/MuxReservoir.java  | 25 +++++++++-------
 .../java/com/datatorrent/stram/engine/Node.java | 25 +++++++++-------
 .../com/datatorrent/stram/engine/OiONode.java   | 25 +++++++++-------
 .../stram/engine/OperatorContext.java           | 25 +++++++++-------
 .../stram/engine/OperatorResponse.java          | 25 +++++++++-------
 .../datatorrent/stram/engine/PortContext.java   | 25 +++++++++-------
 .../com/datatorrent/stram/engine/Reservoir.java | 25 +++++++++-------
 .../com/datatorrent/stram/engine/Slider.java    | 27 +++++++++--------
 .../com/datatorrent/stram/engine/Stream.java    | 25 +++++++++-------
 .../datatorrent/stram/engine/StreamContext.java | 25 +++++++++-------
 .../stram/engine/StreamingContainer.java        | 25 +++++++++-------
 .../stram/engine/SweepableReservoir.java        | 25 +++++++++-------
 .../datatorrent/stram/engine/UnifierNode.java   | 25 +++++++++-------
 .../stram/engine/WindowGenerator.java           | 25 +++++++++-------
 .../engine/WindowIdActivatedReservoir.java      | 25 +++++++++-------
 .../datatorrent/stram/engine/package-info.java  | 25 +++++++++-------
 .../com/datatorrent/stram/package-info.java     | 25 +++++++++-------
 .../plan/logical/DefaultKryoStreamCodec.java    | 25 +++++++++-------
 .../plan/logical/LogicalOperatorStatus.java     | 25 +++++++++-------
 .../stram/plan/logical/LogicalPlan.java         | 25 +++++++++-------
 .../plan/logical/LogicalPlanConfiguration.java  | 25 +++++++++-------
 .../stram/plan/logical/Operators.java           | 25 +++++++++-------
 .../StreamCodecWrapperForPersistance.java       | 18 ++++++++++++
 .../logical/requests/AddStreamSinkRequest.java  | 25 +++++++++-------
 .../logical/requests/CreateOperatorRequest.java | 25 +++++++++-------
 .../logical/requests/CreateStreamRequest.java   | 25 +++++++++-------
 .../logical/requests/LogicalPlanRequest.java    | 25 +++++++++-------
 .../logical/requests/RemoveOperatorRequest.java | 25 +++++++++-------
 .../logical/requests/RemoveStreamRequest.java   | 25 +++++++++-------
 .../requests/SetOperatorAttributeRequest.java   | 25 +++++++++-------
 .../requests/SetOperatorPropertyRequest.java    | 25 +++++++++-------
 .../requests/SetPortAttributeRequest.java       | 25 +++++++++-------
 .../requests/SetStreamAttributeRequest.java     | 25 +++++++++-------
 .../stram/plan/physical/OperatorStatus.java     | 25 +++++++++-------
 .../stram/plan/physical/PTContainer.java        | 25 +++++++++-------
 .../stram/plan/physical/PTOperator.java         | 25 +++++++++-------
 .../stram/plan/physical/PhysicalPlan.java       | 25 +++++++++-------
 .../stram/plan/physical/PlanModifier.java       | 25 +++++++++-------
 .../stram/plan/physical/StatsRevisions.java     | 25 +++++++++-------
 .../stram/plan/physical/StreamMapping.java      | 25 +++++++++-------
 .../stram/security/KerberosAuth.java            | 25 +++++++++-------
 .../StramDelegationTokenIdentifier.java         | 25 +++++++++-------
 .../security/StramDelegationTokenManager.java   | 25 +++++++++-------
 .../security/StramDelegationTokenSelector.java  | 25 +++++++++-------
 .../stram/security/StramUserLogin.java          | 25 +++++++++-------
 .../stram/security/StramWSFilter.java           | 25 +++++++++-------
 .../security/StramWSFilterInitializer.java      | 25 +++++++++-------
 .../stram/security/StramWSPrincipal.java        | 25 +++++++++-------
 .../security/StramWSServletRequestWrapper.java  | 25 +++++++++-------
 .../stram/stream/BufferServerPublisher.java     | 25 +++++++++-------
 .../stram/stream/BufferServerSubscriber.java    | 25 +++++++++-------
 .../datatorrent/stram/stream/FastPublisher.java | 25 +++++++++-------
 .../stram/stream/FastSubscriber.java            | 25 +++++++++-------
 .../datatorrent/stram/stream/InlineStream.java  | 25 +++++++++-------
 .../com/datatorrent/stram/stream/MuxStream.java | 25 +++++++++-------
 .../com/datatorrent/stram/stream/OiOStream.java | 25 +++++++++-------
 .../stram/stream/PartitionAwareSink.java        | 25 +++++++++-------
 .../PartitionAwareSinkForPersistence.java       | 18 ++++++++++++
 .../datatorrent/stram/stream/package-info.java  | 25 +++++++++-------
 .../stram/tuple/CheckpointTuple.java            | 25 +++++++++-------
 .../stram/tuple/CodecStateTuple.java            | 25 +++++++++-------
 .../datatorrent/stram/tuple/EndStreamTuple.java | 25 +++++++++-------
 .../datatorrent/stram/tuple/EndWindowTuple.java | 25 +++++++++-------
 .../stram/tuple/ResetWindowTuple.java           | 25 +++++++++-------
 .../java/com/datatorrent/stram/tuple/Tuple.java | 25 +++++++++-------
 .../stram/util/AbstractWritableAdapter.java     | 25 +++++++++-------
 .../com/datatorrent/stram/util/ConfigUtils.java | 25 +++++++++-------
 .../datatorrent/stram/util/ConfigValidator.java | 25 +++++++++-------
 .../stram/util/ExternalizableConf.java          | 25 +++++++++-------
 .../datatorrent/stram/util/FSJsonLineFile.java  | 25 +++++++++-------
 .../stram/util/FSPartFileCollection.java        | 25 +++++++++-------
 .../java/com/datatorrent/stram/util/FSUtil.java | 25 +++++++++-------
 .../stram/util/HeaderClientFilter.java          | 25 +++++++++-------
 .../stram/util/JSONSerializationProvider.java   | 25 +++++++++-------
 .../com/datatorrent/stram/util/LRUCache.java    | 25 +++++++++-------
 .../datatorrent/stram/util/MovingAverage.java   | 25 +++++++++-------
 .../stram/util/ObjectMapperFactory.java         | 25 +++++++++-------
 .../stram/util/PubSubWebSocketServlet.java      | 20 +++++++++++--
 .../datatorrent/stram/util/SecureExecutor.java  | 25 +++++++++-------
 .../stram/util/SharedPubSubWebSocketClient.java | 25 +++++++++-------
 .../stram/util/StablePriorityQueue.java         | 25 +++++++++-------
 .../datatorrent/stram/util/StableWrapper.java   | 25 +++++++++-------
 .../datatorrent/stram/util/StreamGobbler.java   | 25 +++++++++-------
 .../com/datatorrent/stram/util/VersionInfo.java | 25 +++++++++-------
 .../stram/util/WebServicesClient.java           | 25 +++++++++-------
 .../datatorrent/stram/util/package-info.java    | 25 +++++++++-------
 .../com/datatorrent/stram/webapp/AppInfo.java   | 25 +++++++++-------
 .../datatorrent/stram/webapp/ContainerInfo.java | 31 +++++++++-----------
 .../stram/webapp/ContainersInfo.java            | 25 +++++++++-------
 .../stram/webapp/LogicalOperatorInfo.java       | 25 +++++++++-------
 .../stram/webapp/LogicalOperatorsInfo.java      | 25 +++++++++-------
 .../stram/webapp/OperatorAggregationInfo.java   | 25 +++++++++-------
 .../stram/webapp/OperatorDiscoverer.java        | 25 +++++++++-------
 .../datatorrent/stram/webapp/OperatorInfo.java  | 25 +++++++++-------
 .../datatorrent/stram/webapp/OperatorsInfo.java | 25 +++++++++-------
 .../com/datatorrent/stram/webapp/PortInfo.java  | 25 +++++++++-------
 .../datatorrent/stram/webapp/StramWebApp.java   | 25 +++++++++-------
 .../stram/webapp/StramWebServices.java          | 25 +++++++++-------
 .../datatorrent/stram/webapp/StreamInfo.java    | 25 +++++++++-------
 .../datatorrent/stram/webapp/StreamsInfo.java   | 25 +++++++++-------
 .../stram/webapp/TypeDiscoverer.java            | 25 +++++++++-------
 .../com/datatorrent/stram/webapp/TypeGraph.java | 25 +++++++++-------
 .../stram/webapp/TypeGraphFactory.java          | 25 +++++++++-------
 .../datatorrent/stram/webapp/WebServices.java   | 25 +++++++++-------
 .../datatorrent/stram/webapp/asm/ASMUtil.java   | 25 +++++++++-------
 .../stram/webapp/asm/BaseSignatureVisitor.java  | 25 +++++++++-------
 .../stram/webapp/asm/ClassNodeType.java         | 25 +++++++++-------
 .../stram/webapp/asm/ClassSignatureVisitor.java | 25 +++++++++-------
 .../stram/webapp/asm/CompactAnnotationNode.java | 27 +++++++++--------
 .../stram/webapp/asm/CompactClassNode.java      | 25 +++++++++-------
 .../stram/webapp/asm/CompactFieldNode.java      | 27 +++++++++--------
 .../stram/webapp/asm/CompactMethodNode.java     | 25 +++++++++-------
 .../stram/webapp/asm/CompactUtil.java           | 25 +++++++++-------
 .../datatorrent/stram/webapp/asm/FieldNode.java | 25 +++++++++-------
 .../stram/webapp/asm/FieldSignatureVisitor.java | 27 +++++++++--------
 .../stram/webapp/asm/MethodNode.java            | 25 +++++++++-------
 .../webapp/asm/MethodSignatureVisitor.java      | 25 +++++++++-------
 .../com/datatorrent/stram/webapp/asm/Type.java  | 25 +++++++++-------
 .../datatorrent/stram/webapp/package-info.java  | 25 +++++++++-------
 .../java/org/apache/log4j/DTLoggerFactory.java  | 25 +++++++++-------
 engine/src/main/scripts/dtcli                   | 21 ++++++++++---
 .../com/datatorrent/stram/CheckpointTest.java   | 25 +++++++++-------
 .../stram/GenericOperatorPropertyCodecTest.java | 25 +++++++++-------
 .../com/datatorrent/stram/HostLocalTest.java    | 25 +++++++++-------
 .../java/com/datatorrent/stram/InlineAM.java    | 25 +++++++++-------
 .../com/datatorrent/stram/LocalityTest.java     | 25 +++++++++-------
 .../stram/LogicalPlanModificationTest.java      | 25 +++++++++-------
 .../com/datatorrent/stram/MockContainer.java    | 25 +++++++++-------
 .../datatorrent/stram/OutputUnifiedTest.java    | 25 +++++++++-------
 .../com/datatorrent/stram/PartitioningTest.java | 25 +++++++++-------
 .../stram/StramLocalClusterTest.java            | 25 +++++++++-------
 .../datatorrent/stram/StramMiniClusterTest.java | 25 +++++++++-------
 .../datatorrent/stram/StramRecoveryTest.java    | 25 +++++++++-------
 .../com/datatorrent/stram/StreamCodecTest.java  | 25 +++++++++-------
 .../stram/StreamingContainerManagerTest.java    | 25 +++++++++-------
 .../com/datatorrent/stram/cli/DTCliTest.java    | 25 +++++++++-------
 .../stram/client/AppPackageTest.java            | 25 +++++++++-------
 .../stram/client/ClassPathResolverTest.java     | 25 +++++++++-------
 .../stram/client/ConfigPackageTest.java         | 25 +++++++++-------
 .../stram/client/EvalPropertiesTest.java        | 25 +++++++++-------
 .../WebServicesVersionConversionTest.java       | 25 +++++++++-------
 .../codec/DefaultStatefulStreamCodecTest.java   | 25 +++++++++-------
 .../datatorrent/stram/debug/MuxSinkTest.java    | 25 +++++++++-------
 .../stram/debug/TupleRecorderTest.java          | 25 +++++++++-------
 .../stram/engine/AtLeastOnceTest.java           | 25 +++++++++-------
 .../stram/engine/AtMostOnceTest.java            | 25 +++++++++-------
 .../stram/engine/AutoMetricTest.java            | 25 +++++++++-------
 .../stram/engine/ExactlyOnceTest.java           | 25 +++++++++-------
 .../stram/engine/GenericNodeTest.java           | 25 +++++++++-------
 .../stram/engine/GenericOperatorProperty.java   | 25 +++++++++-------
 .../stram/engine/GenericTestOperator.java       | 25 +++++++++-------
 .../stram/engine/InputOperatorTest.java         | 25 +++++++++-------
 .../com/datatorrent/stram/engine/NodeTest.java  | 25 +++++++++-------
 .../stram/engine/ProcessingModeTests.java       | 25 +++++++++-------
 .../stram/engine/RecoverableInputOperator.java  | 25 +++++++++-------
 .../datatorrent/stram/engine/SliderTest.java    | 25 +++++++++-------
 .../com/datatorrent/stram/engine/StatsTest.java | 25 +++++++++-------
 .../stram/engine/StreamingContainerTest.java    | 25 +++++++++-------
 .../stram/engine/TestAppDataQueryOperator.java  | 25 +++++++++-------
 .../stram/engine/TestAppDataResultOperator.java | 25 +++++++++-------
 .../stram/engine/TestAppDataSourceOperator.java | 25 +++++++++-------
 .../engine/TestGeneratorInputOperator.java      | 25 +++++++++-------
 .../TestNonOptionalOutportInputOperator.java    | 25 +++++++++-------
 .../stram/engine/TestOutputOperator.java        | 25 +++++++++-------
 .../com/datatorrent/stram/engine/TestSink.java  | 25 +++++++++-------
 .../stram/engine/WindowGeneratorTest.java       | 25 +++++++++-------
 .../stram/moduleexperiment/InjectConfig.java    | 25 +++++++++-------
 .../moduleexperiment/InjectConfigTest.java      | 25 +++++++++-------
 .../stram/plan/SchemaTestOperator.java          | 25 +++++++++-------
 .../stram/plan/StreamPersistanceTests.java      | 18 ++++++++++++
 .../datatorrent/stram/plan/TestPlanContext.java | 25 +++++++++-------
 .../logical/LogicalPlanConfigurationTest.java   | 25 +++++++++-------
 .../stram/plan/logical/LogicalPlanTest.java     | 25 +++++++++-------
 .../stram/plan/logical/MockStorageAgent.java    | 26 ++++++++--------
 .../stram/plan/physical/PhysicalPlanTest.java   | 25 +++++++++-------
 .../stram/plan/physical/StatsRevisionsTest.java | 25 +++++++++-------
 .../stream/BufferServerSubscriberTest.java      | 25 +++++++++-------
 .../stram/stream/FastPublisherTest.java         | 25 +++++++++-------
 .../stram/stream/FastStreamTest.java            | 25 +++++++++-------
 .../stram/stream/InlineStreamTest.java          | 25 +++++++++-------
 .../stram/stream/OiOEndWindowTest.java          | 25 +++++++++-------
 .../datatorrent/stram/stream/OiOStreamTest.java | 25 +++++++++-------
 .../stram/stream/SocketStreamTest.java          | 25 +++++++++-------
 .../support/ManualScheduledExecutorService.java | 25 +++++++++-------
 .../stram/support/StramTestSupport.java         | 25 +++++++++-------
 .../stram/util/StablePriorityQueueTest.java     | 25 +++++++++-------
 .../datatorrent/stram/util/VersionInfoTest.java | 25 +++++++++-------
 .../stram/webapp/OperatorDiscoveryTest.java     | 25 +++++++++-------
 .../stram/webapp/StramWebServicesTest.java      | 25 +++++++++-------
 .../stram/webapp/TypeDiscoveryTest.java         | 25 +++++++++-------
 .../org/apache/log4j/DTLoggerFactoryTest.java   | 25 +++++++++-------
 .../test/resources/clusterTest.app.properties   | 19 ++++++++++++
 engine/src/test/resources/dt-site.xml           | 20 +++++++++++++
 engine/src/test/resources/log4j.properties      | 19 ++++++++++++
 .../resources/testAppPackage/.dt/dt-site.xml    | 20 +++++++++++++
 .../resources/testAppPackage/local-conf.xml     | 20 +++++++++++++
 .../resources/testAppPackage/mydtapp/pom.xml    | 20 +++++++++++++
 .../mydtapp/src/assemble/appPackage.xml         | 20 +++++++++++++
 .../java/com/example/mydtapp/Application.java   | 17 ++++++++++-
 .../example/mydtapp/RandomNumberGenerator.java  | 18 ++++++++++++
 .../com/example/mydtapp/StdoutOperator.java     | 18 ++++++++++++
 .../META-INF/properties-MyFirstApplication.xml  | 20 +++++++++++++
 .../src/main/resources/META-INF/properties.xml  | 20 +++++++++++++
 .../example/mydtapp/StdoutOperator/ExtRes.html  | 20 +++++++++++++
 .../mydtapp/src/site/conf/my-app-conf1.xml      | 20 +++++++++++++
 .../com/example/mydtapp/ApplicationTest.java    | 17 ++++++++++-
 .../mydtapp/src/test/resources/log4j.properties | 19 ++++++++++++
 .../META-INF/properties-MyFirstApplication.xml  | 20 +++++++++++++
 .../META-INF/properties-app1.xml                | 20 +++++++++++++
 .../META-INF/properties.xml                     | 20 +++++++++++++
 .../classpath/xyz.properties                    | 19 ++++++++++++
 .../src/test/resources/testTopology.properties  | 19 ++++++++++++
 engine/src/test/resources/yarn-site.xml         | 20 +++++++++++++
 pom.xml                                         | 20 +++++++++++++
 420 files changed, 6116 insertions(+), 4162 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex-app-archetype/pom.xml
----------------------------------------------------------------------
diff --git a/apex-app-archetype/pom.xml b/apex-app-archetype/pom.xml
index b0a7a15..7c9f332 100644
--- a/apex-app-archetype/pom.xml
+++ b/apex-app-archetype/pom.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex-app-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml
----------------------------------------------------------------------
diff --git a/apex-app-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml b/apex-app-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml
index d60b35b..c93a8d9 100644
--- a/apex-app-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml
+++ b/apex-app-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <archetype-descriptor xsi:schemaLocation="http://maven.apache.org/plugins/maven-archetype-plugin/archetype-descriptor/1.0.0 http://maven.apache.org/xsd/archetype-descriptor-1.0.0.xsd" name="apex-app-archetype"
     xmlns="http://maven.apache.org/plugins/maven-archetype-plugin/archetype-descriptor/1.0.0"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex-app-archetype/src/main/resources/META-INF/maven/archetype.xml
----------------------------------------------------------------------
diff --git a/apex-app-archetype/src/main/resources/META-INF/maven/archetype.xml b/apex-app-archetype/src/main/resources/META-INF/maven/archetype.xml
index 18a0ad8..757b6c1 100644
--- a/apex-app-archetype/src/main/resources/META-INF/maven/archetype.xml
+++ b/apex-app-archetype/src/main/resources/META-INF/maven/archetype.xml
@@ -1,3 +1,23 @@
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 #set( $symbol_pound = '#' )
 #set( $symbol_dollar = '$' )
 #set( $symbol_escape = '\' )

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex-app-archetype/src/test/resources/projects/basic/archetype.properties
----------------------------------------------------------------------
diff --git a/apex-app-archetype/src/test/resources/projects/basic/archetype.properties b/apex-app-archetype/src/test/resources/projects/basic/archetype.properties
index a5faf73..7b03fd1 100644
--- a/apex-app-archetype/src/test/resources/projects/basic/archetype.properties
+++ b/apex-app-archetype/src/test/resources/projects/basic/archetype.properties
@@ -1,3 +1,22 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
 #Wed Jul 02 18:52:59 PDT 2014
 package=it.pkg
 version=0.1-SNAPSHOT

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex-conf-archetype/pom.xml
----------------------------------------------------------------------
diff --git a/apex-conf-archetype/pom.xml b/apex-conf-archetype/pom.xml
index 1bebb43..e5b4d3e 100644
--- a/apex-conf-archetype/pom.xml
+++ b/apex-conf-archetype/pom.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex-conf-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml
----------------------------------------------------------------------
diff --git a/apex-conf-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml b/apex-conf-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml
index b367bd6..d739c53 100644
--- a/apex-conf-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml
+++ b/apex-conf-archetype/src/main/resources/META-INF/maven/archetype-metadata.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <archetype-descriptor xsi:schemaLocation="http://maven.apache.org/plugins/maven-archetype-plugin/archetype-descriptor/1.0.0 http://maven.apache.org/xsd/archetype-descriptor-1.0.0.xsd" name="apex-app-archetype"
     xmlns="http://maven.apache.org/plugins/maven-archetype-plugin/archetype-descriptor/1.0.0"
     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex-conf-archetype/src/main/resources/META-INF/maven/archetype.xml
----------------------------------------------------------------------
diff --git a/apex-conf-archetype/src/main/resources/META-INF/maven/archetype.xml b/apex-conf-archetype/src/main/resources/META-INF/maven/archetype.xml
index 208bc6f..728c76e 100644
--- a/apex-conf-archetype/src/main/resources/META-INF/maven/archetype.xml
+++ b/apex-conf-archetype/src/main/resources/META-INF/maven/archetype.xml
@@ -1,3 +1,23 @@
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 #set( $symbol_pound = '#' )
 #set( $symbol_dollar = '$' )
 #set( $symbol_escape = '\' )

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex-conf-archetype/src/test/resources/projects/basic/archetype.properties
----------------------------------------------------------------------
diff --git a/apex-conf-archetype/src/test/resources/projects/basic/archetype.properties b/apex-conf-archetype/src/test/resources/projects/basic/archetype.properties
index a5faf73..7b03fd1 100644
--- a/apex-conf-archetype/src/test/resources/projects/basic/archetype.properties
+++ b/apex-conf-archetype/src/test/resources/projects/basic/archetype.properties
@@ -1,3 +1,22 @@
+#
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#   http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+#
+
 #Wed Jul 02 18:52:59 PDT 2014
 package=it.pkg
 version=0.1-SNAPSHOT

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/apex_checks.xml
----------------------------------------------------------------------
diff --git a/apex_checks.xml b/apex_checks.xml
index f7967e6..b4b3277 100644
--- a/apex_checks.xml
+++ b/apex_checks.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <!DOCTYPE module PUBLIC
   "-//Puppy Crawl//DTD Check Configuration 1.3//EN"
   "http://www.puppycrawl.com/dtds/configuration_1_3.dtd">

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/pom.xml
----------------------------------------------------------------------
diff --git a/api/pom.xml b/api/pom.xml
index 70b3c65..52fc5a7 100644
--- a/api/pom.xml
+++ b/api/pom.xml
@@ -1,4 +1,24 @@
 <?xml version="1.0"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
 <project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0"
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
   <modelVersion>4.0.0</modelVersion>

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/Attribute.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/Attribute.java b/api/src/main/java/com/datatorrent/api/Attribute.java
index a7492b5..459d719 100644
--- a/api/src/main/java/com/datatorrent/api/Attribute.java
+++ b/api/src/main/java/com/datatorrent/api/Attribute.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/AutoMetric.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/AutoMetric.java b/api/src/main/java/com/datatorrent/api/AutoMetric.java
index 61e8dd0..ddf99c6 100644
--- a/api/src/main/java/com/datatorrent/api/AutoMetric.java
+++ b/api/src/main/java/com/datatorrent/api/AutoMetric.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/Component.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/Component.java b/api/src/main/java/com/datatorrent/api/Component.java
index 137b737..f15d6de 100644
--- a/api/src/main/java/com/datatorrent/api/Component.java
+++ b/api/src/main/java/com/datatorrent/api/Component.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/Context.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/Context.java b/api/src/main/java/com/datatorrent/api/Context.java
index cd10398..2054920 100644
--- a/api/src/main/java/com/datatorrent/api/Context.java
+++ b/api/src/main/java/com/datatorrent/api/Context.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/DAG.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/DAG.java b/api/src/main/java/com/datatorrent/api/DAG.java
index 9c6c492..6b1d1b2 100644
--- a/api/src/main/java/com/datatorrent/api/DAG.java
+++ b/api/src/main/java/com/datatorrent/api/DAG.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/DefaultInputPort.java b/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
index 25fe596..e3998f0 100644
--- a/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
+++ b/api/src/main/java/com/datatorrent/api/DefaultInputPort.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/DefaultOutputPort.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/DefaultOutputPort.java b/api/src/main/java/com/datatorrent/api/DefaultOutputPort.java
index b5eebd1..d145657 100644
--- a/api/src/main/java/com/datatorrent/api/DefaultOutputPort.java
+++ b/api/src/main/java/com/datatorrent/api/DefaultOutputPort.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/DefaultPartition.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/DefaultPartition.java b/api/src/main/java/com/datatorrent/api/DefaultPartition.java
index d149d85..222f44e 100644
--- a/api/src/main/java/com/datatorrent/api/DefaultPartition.java
+++ b/api/src/main/java/com/datatorrent/api/DefaultPartition.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/InputOperator.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/InputOperator.java b/api/src/main/java/com/datatorrent/api/InputOperator.java
index 43f48dc..e6a0a65 100644
--- a/api/src/main/java/com/datatorrent/api/InputOperator.java
+++ b/api/src/main/java/com/datatorrent/api/InputOperator.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/LocalMode.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/LocalMode.java b/api/src/main/java/com/datatorrent/api/LocalMode.java
index 06f1277..0115f2a 100644
--- a/api/src/main/java/com/datatorrent/api/LocalMode.java
+++ b/api/src/main/java/com/datatorrent/api/LocalMode.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/Operator.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/Operator.java b/api/src/main/java/com/datatorrent/api/Operator.java
index e26b37a..c362159 100644
--- a/api/src/main/java/com/datatorrent/api/Operator.java
+++ b/api/src/main/java/com/datatorrent/api/Operator.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/Partitioner.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/Partitioner.java b/api/src/main/java/com/datatorrent/api/Partitioner.java
index 08fb0fd..1627c51 100644
--- a/api/src/main/java/com/datatorrent/api/Partitioner.java
+++ b/api/src/main/java/com/datatorrent/api/Partitioner.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/Sink.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/Sink.java b/api/src/main/java/com/datatorrent/api/Sink.java
index 73ec666..1e7b1b3 100644
--- a/api/src/main/java/com/datatorrent/api/Sink.java
+++ b/api/src/main/java/com/datatorrent/api/Sink.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/Stats.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/Stats.java b/api/src/main/java/com/datatorrent/api/Stats.java
index 1e7f3c1..3ba1402 100644
--- a/api/src/main/java/com/datatorrent/api/Stats.java
+++ b/api/src/main/java/com/datatorrent/api/Stats.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/StatsListener.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/StatsListener.java b/api/src/main/java/com/datatorrent/api/StatsListener.java
index 1bc65a1..38b93cd 100644
--- a/api/src/main/java/com/datatorrent/api/StatsListener.java
+++ b/api/src/main/java/com/datatorrent/api/StatsListener.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/StorageAgent.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/StorageAgent.java b/api/src/main/java/com/datatorrent/api/StorageAgent.java
index 10b8888..e155ed3 100644
--- a/api/src/main/java/com/datatorrent/api/StorageAgent.java
+++ b/api/src/main/java/com/datatorrent/api/StorageAgent.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/StreamCodec.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/StreamCodec.java b/api/src/main/java/com/datatorrent/api/StreamCodec.java
index d85ec9f..a097dc9 100644
--- a/api/src/main/java/com/datatorrent/api/StreamCodec.java
+++ b/api/src/main/java/com/datatorrent/api/StreamCodec.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/StreamingApplication.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/StreamingApplication.java b/api/src/main/java/com/datatorrent/api/StreamingApplication.java
index 6aa9a84..f4ecd4a 100644
--- a/api/src/main/java/com/datatorrent/api/StreamingApplication.java
+++ b/api/src/main/java/com/datatorrent/api/StreamingApplication.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/StringCodec.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/StringCodec.java b/api/src/main/java/com/datatorrent/api/StringCodec.java
index 22e0a3e..b19d15e 100644
--- a/api/src/main/java/com/datatorrent/api/StringCodec.java
+++ b/api/src/main/java/com/datatorrent/api/StringCodec.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/annotation/ApplicationAnnotation.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/annotation/ApplicationAnnotation.java b/api/src/main/java/com/datatorrent/api/annotation/ApplicationAnnotation.java
index 7d9e3fe..b568ade 100644
--- a/api/src/main/java/com/datatorrent/api/annotation/ApplicationAnnotation.java
+++ b/api/src/main/java/com/datatorrent/api/annotation/ApplicationAnnotation.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api.annotation;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/annotation/InputPortFieldAnnotation.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/annotation/InputPortFieldAnnotation.java b/api/src/main/java/com/datatorrent/api/annotation/InputPortFieldAnnotation.java
index 2734bf6..c247c82 100644
--- a/api/src/main/java/com/datatorrent/api/annotation/InputPortFieldAnnotation.java
+++ b/api/src/main/java/com/datatorrent/api/annotation/InputPortFieldAnnotation.java
@@ -1,17 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api.annotation;
 

http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/730e57f7/api/src/main/java/com/datatorrent/api/annotation/Name.java
----------------------------------------------------------------------
diff --git a/api/src/main/java/com/datatorrent/api/annotation/Name.java b/api/src/main/java/com/datatorrent/api/annotation/Name.java
index 2ad7683..a93f59c 100644
--- a/api/src/main/java/com/datatorrent/api/annotation/Name.java
+++ b/api/src/main/java/com/datatorrent/api/annotation/Name.java
@@ -1,19 +1,20 @@
 /**
- * Copyright (C) 2015 DataTorrent, Inc.
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
  *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
+ *   http://www.apache.org/licenses/LICENSE-2.0
  *
- *         http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- *
- * @since 3.0.0
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
  */
 package com.datatorrent.api.annotation;
 



Mime
View raw message