You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@heron.apache.org by ka...@apache.org on 2018/05/03 06:01:52 UTC
[incubator-heron] branch karthik/scribe updated (2c69caa -> abcd160)
This is an automated email from the ASF dual-hosted git repository.
karthikz pushed a change to branch karthik/scribe
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git.
from 2c69caa remove scribe dependency in tests
add 9d621b2 Update NOTICE file (#2878)
add 9957ef3 Update license text in cpp files (#2882)
add 0138b8d Update license text in java files (#2881)
add 1e7e35a Update license text in H files (#2885)
new abcd160 Merge branch 'master' into karthik/scribe
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
NOTICE | 8 +-
.../apache/heron/examples/eco/EvenAndOddBolt.java | 32 +++--
.../org/apache/heron/examples/eco/LogInfoBolt.java | 32 +++--
.../apache/heron/examples/eco/RandomString.java | 32 +++--
.../heron/examples/eco/StatefulConsumerBolt.java | 32 +++--
.../heron/examples/eco/StatefulNumberSpout.java | 32 +++--
.../heron/examples/eco/StatefulRandomIntSpout.java | 32 +++--
.../heron/examples/eco/StatefulWindowSumBolt.java | 32 +++--
.../heron/examples/eco/TestFibonacciSpout.java | 32 +++--
.../heron/examples/eco/TestIBasicPrintBolt.java | 32 +++--
.../apache/heron/examples/eco/TestNameCounter.java | 32 +++--
.../apache/heron/examples/eco/TestNameSpout.java | 32 +++--
.../apache/heron/examples/eco/TestPrintBolt.java | 32 +++--
.../heron/examples/eco/TestPropertyHolder.java | 32 +++--
.../org/apache/heron/examples/eco/TestUnits.java | 32 +++--
.../apache/heron/examples/eco/TestWindowBolt.java | 32 +++--
.../org/apache/heron/examples/eco/WordSpout.java | 32 +++--
.../apache/heron/examples/eco/EvenAndOddBolt.java | 32 +++--
.../org/apache/heron/examples/eco/LogInfoBolt.java | 32 +++--
.../heron/examples/eco/TestFibonacciSpout.java | 32 +++--
.../heron/examples/eco/TestIBasicPrintBolt.java | 32 +++--
.../apache/heron/examples/eco/TestNameCounter.java | 32 +++--
.../apache/heron/examples/eco/TestNameSpout.java | 32 +++--
.../apache/heron/examples/eco/TestPrintBolt.java | 32 +++--
.../heron/examples/eco/TestPropertyHolder.java | 32 +++--
.../org/apache/heron/examples/eco/TestUnits.java | 32 +++--
.../apache/heron/examples/eco/TestWindowBolt.java | 32 +++--
eco/src/java/org/apache/heron/eco/Eco.java | 32 +++--
.../org/apache/heron/eco/builder/BoltBuilder.java | 32 +++--
.../apache/heron/eco/builder/BuilderUtility.java | 32 +++--
.../apache/heron/eco/builder/ComponentBuilder.java | 32 +++--
.../apache/heron/eco/builder/ConfigBuilder.java | 32 +++--
.../apache/heron/eco/builder/ObjectBuilder.java | 32 +++--
.../apache/heron/eco/builder/heron/EcoBuilder.java | 32 +++--
.../heron/eco/builder/heron/SpoutBuilder.java | 32 +++--
.../heron/eco/builder/heron/StreamBuilder.java | 32 +++--
.../apache/heron/eco/builder/storm/EcoBuilder.java | 32 +++--
.../heron/eco/builder/storm/SpoutBuilder.java | 32 +++--
.../heron/eco/builder/storm/StreamBuilder.java | 32 +++--
.../heron/eco/definition/BeanDefinition.java | 32 +++--
.../heron/eco/definition/BeanListReference.java | 32 +++--
.../apache/heron/eco/definition/BeanReference.java | 32 +++--
.../heron/eco/definition/BoltDefinition.java | 32 +++--
.../heron/eco/definition/ComponentStream.java | 32 +++--
.../definition/ConfigurationMethodDefinition.java | 32 +++--
.../heron/eco/definition/EcoExecutionContext.java | 32 +++--
.../eco/definition/EcoTopologyDefinition.java | 32 +++--
.../heron/eco/definition/GroupingDefinition.java | 32 +++--
.../heron/eco/definition/ObjectDefinition.java | 32 +++--
.../heron/eco/definition/PropertyDefinition.java | 32 +++--
.../heron/eco/definition/SpoutDefinition.java | 32 +++--
.../heron/eco/definition/StreamDefinition.java | 32 +++--
.../org/apache/heron/eco/parser/EcoParser.java | 32 +++--
.../org/apache/heron/eco/submit/EcoSubmitter.java | 32 +++--
eco/tests/java/org/apache/heron/eco/EcoTest.java | 32 +++--
.../apache/heron/eco/builder/BoltBuilderTest.java | 32 +++--
.../heron/eco/builder/BuilderUtilityTest.java | 32 +++--
.../heron/eco/builder/ComponentBuilderTest.java | 32 +++--
.../heron/eco/builder/ConfigBuilderTest.java | 32 +++--
.../heron/eco/builder/ObjectBuilderTest.java | 32 +++--
.../eco/builder/heron/HeronEcoBuilderTest.java | 32 +++--
.../eco/builder/heron/HeronSpoutBuilderTest.java | 32 +++--
.../eco/builder/heron/HeronStreamBuilderTest.java | 32 +++--
.../eco/builder/storm/StormEcoBuilderTest.java | 32 +++--
.../eco/builder/storm/StormSpoutBuilderTest.java | 32 +++--
.../eco/builder/storm/StormStreamBuilderTest.java | 32 +++--
.../org/apache/heron/eco/parser/EcoParserTest.java | 139 +++------------------
.../apache/heron/eco/submit/EcoSubmitterTest.java | 32 +++--
examples/src/cpp/ackfail/ackfail-topology.cpp | 25 ++--
.../src/cpp/exclamation/exclamation-topology.cpp | 25 ++--
examples/src/cpp/spouts/test-word-spout.h | 25 ++--
.../apache/heron/examples/api/AckingTopology.java | 32 +++--
.../examples/api/ComponentJVMOptionsTopology.java | 32 +++--
.../heron/examples/api/CustomGroupingTopology.java | 32 +++--
.../heron/examples/api/ExampleResources.java | 32 +++--
.../heron/examples/api/ExclamationTopology.java | 32 +++--
.../api/MultiSpoutExclamationTopology.java | 32 +++--
.../examples/api/MultiStageAckingTopology.java | 32 +++--
.../examples/api/SentenceWordCountTopology.java | 32 +++--
.../heron/examples/api/SlidingWindowTopology.java | 32 +++--
.../api/StatefulSlidingWindowTopology.java | 32 +++--
.../examples/api/StatefulWordCountTopology.java | 32 +++--
.../heron/examples/api/TaskHookTopology.java | 32 +++--
.../examples/api/WindowedWordCountTopology.java | 32 +++--
.../heron/examples/api/WordCountTopology.java | 32 +++--
.../heron/examples/api/bolt/PrinterBolt.java | 32 +++--
.../examples/api/bolt/SlidingWindowSumBolt.java | 32 +++--
.../examples/api/spout/RandomIntegerSpout.java | 32 +++--
.../heron/examples/api/spout/TestWordSpout.java | 32 +++--
.../examples/streamlet/FilesystemSinkTopology.java | 32 +++--
.../streamlet/FormattedOutputTopology.java | 32 +++--
.../streamlet/ImpressionsAndClicksTopology.java | 32 +++--
.../streamlet/IntegerProcessingTopology.java | 32 +++--
.../examples/streamlet/RepartitionTopology.java | 32 +++--
.../streamlet/SimplePulsarSourceTopology.java | 32 +++--
.../examples/streamlet/SmartWatchTopology.java | 32 +++--
.../examples/streamlet/StreamletCloneTopology.java | 32 +++--
.../examples/streamlet/TransformsTopology.java | 32 +++--
.../streamlet/WindowedWordCountTopology.java | 32 +++--
.../examples/streamlet/WireRequestsTopology.java | 32 +++--
.../examples/streamlet/utils/StreamletUtils.java | 32 +++--
heron/api/src/cpp/bolt/base-basic-bolt.h | 25 ++--
heron/api/src/cpp/bolt/base-rich-bolt.h | 25 ++--
heron/api/src/cpp/bolt/basic-bolt-collector.h | 25 ++--
heron/api/src/cpp/bolt/ibasic-bolt.h | 25 ++--
heron/api/src/cpp/bolt/ibolt-output-collector.h | 25 ++--
heron/api/src/cpp/bolt/ibolt.h | 25 ++--
heron/api/src/cpp/bolt/irich-bolt.h | 25 ++--
heron/api/src/cpp/config/config.cpp | 25 ++--
heron/api/src/cpp/config/config.h | 25 ++--
.../src/cpp/exceptions/already-alive-exception.h | 25 ++--
.../cpp/exceptions/invalid-topology-exception.h | 25 ++--
.../src/cpp/exceptions/serialization-exception.h | 25 ++--
heron/api/src/cpp/metric/assignable-metric.h | 25 ++--
heron/api/src/cpp/metric/count-metric.h | 25 ++--
heron/api/src/cpp/metric/imetric.h | 25 ++--
heron/api/src/cpp/metric/imetrics-registrar.h | 25 ++--
heron/api/src/cpp/metric/imulti-metric.h | 25 ++--
heron/api/src/cpp/metric/mean-metric.h | 25 ++--
heron/api/src/cpp/metric/multi-count-metric.h | 25 ++--
heron/api/src/cpp/metric/multi-mean-metric.h | 25 ++--
heron/api/src/cpp/serializer/cereal-serializer.h | 25 ++--
.../src/cpp/serializer/ipluggable-serializer.cpp | 25 ++--
.../api/src/cpp/serializer/ipluggable-serializer.h | 25 ++--
heron/api/src/cpp/serializer/string-serializer.h | 25 ++--
.../src/cpp/serializer/tuple-serializer-utils.h | 25 ++--
heron/api/src/cpp/spout/base-rich-spout.h | 25 ++--
heron/api/src/cpp/spout/irich-spout.h | 25 ++--
heron/api/src/cpp/spout/ispout-output-collector.h | 25 ++--
heron/api/src/cpp/spout/ispout.h | 25 ++--
.../api/src/cpp/topology/base-component-declarer.h | 25 ++--
heron/api/src/cpp/topology/bolt-declarer.h | 25 ++--
heron/api/src/cpp/topology/heron-submitter.h | 25 ++--
heron/api/src/cpp/topology/icomponent.h | 25 ++--
.../api/src/cpp/topology/output-fields-declarer.h | 25 ++--
heron/api/src/cpp/topology/output-fields-getter.h | 25 ++--
heron/api/src/cpp/topology/spout-declarer.h | 25 ++--
heron/api/src/cpp/topology/task-context.h | 25 ++--
heron/api/src/cpp/topology/topology-builder.h | 25 ++--
heron/api/src/cpp/topology/topology-context.h | 25 ++--
heron/api/src/cpp/tuple/fields.h | 25 ++--
heron/api/src/cpp/tuple/tuple.h | 25 ++--
heron/api/src/cpp/utils/utils.cpp | 25 ++--
heron/api/src/cpp/utils/utils.h | 25 ++--
.../api/src/java/org/apache/heron/api/Config.java | 28 ++---
.../src/java/org/apache/heron/api/Constants.java | 27 ++--
.../java/org/apache/heron/api/HeronSubmitter.java | 27 ++--
.../java/org/apache/heron/api/HeronTopology.java | 28 ++---
heron/api/src/java/org/apache/heron/api/Pair.java | 27 ++--
.../org/apache/heron/api/bolt/BaseBasicBolt.java | 28 ++---
.../org/apache/heron/api/bolt/BaseRichBolt.java | 28 ++---
.../heron/api/bolt/BaseStatefulWindowedBolt.java | 32 +++--
.../apache/heron/api/bolt/BaseWindowedBolt.java | 27 ++--
.../apache/heron/api/bolt/BasicBoltExecutor.java | 28 ++---
.../heron/api/bolt/BasicOutputCollector.java | 28 ++---
.../java/org/apache/heron/api/bolt/IBasicBolt.java | 28 ++---
.../heron/api/bolt/IBasicOutputCollector.java | 28 ++---
.../src/java/org/apache/heron/api/bolt/IBolt.java | 28 ++---
.../org/apache/heron/api/bolt/IErrorReporter.java | 28 ++---
.../apache/heron/api/bolt/IOutputCollector.java | 28 ++---
.../java/org/apache/heron/api/bolt/IRichBolt.java | 28 ++---
.../heron/api/bolt/IStatefulWindowedBolt.java | 31 +++--
.../org/apache/heron/api/bolt/IWindowedBolt.java | 27 ++--
.../org/apache/heron/api/bolt/OutputCollector.java | 28 ++---
.../api/bolt/StatefulWindowedBoltExecutor.java | 32 +++--
.../heron/api/bolt/WindowedBoltExecutor.java | 27 ++--
.../heron/api/exception/AlreadyAliveException.java | 28 ++---
.../heron/api/exception/FailedException.java | 28 ++---
.../api/exception/InvalidTopologyException.java | 28 ++---
.../api/exception/ReportedFailedException.java | 28 ++---
.../api/exception/TopologySubmissionException.java | 32 +++--
.../heron/api/grouping/CustomStreamGrouping.java | 28 ++---
.../org/apache/heron/api/hooks/BaseTaskHook.java | 28 ++---
.../java/org/apache/heron/api/hooks/ITaskHook.java | 28 ++---
.../apache/heron/api/hooks/info/BoltAckInfo.java | 28 ++---
.../heron/api/hooks/info/BoltExecuteInfo.java | 28 ++---
.../apache/heron/api/hooks/info/BoltFailInfo.java | 28 ++---
.../org/apache/heron/api/hooks/info/EmitInfo.java | 28 ++---
.../apache/heron/api/hooks/info/SpoutAckInfo.java | 28 ++---
.../apache/heron/api/hooks/info/SpoutFailInfo.java | 28 ++---
.../apache/heron/api/metric/AssignableMetric.java | 28 ++---
.../apache/heron/api/metric/CombinedMetric.java | 28 ++---
.../heron/api/metric/ConcurrentCountMetric.java | 28 ++---
.../org/apache/heron/api/metric/CountMetric.java | 28 ++---
.../heron/api/metric/CountStatAndMetric.java | 28 ++---
.../org/apache/heron/api/metric/GlobalMetrics.java | 28 ++---
.../org/apache/heron/api/metric/ICombiner.java | 28 ++---
.../java/org/apache/heron/api/metric/IMetric.java | 28 ++---
.../apache/heron/api/metric/IMetricsRegister.java | 28 ++---
.../java/org/apache/heron/api/metric/IReducer.java | 28 ++---
.../heron/api/metric/LatencyStatAndMetric.java | 27 ++--
.../org/apache/heron/api/metric/MeanReducer.java | 28 ++---
.../apache/heron/api/metric/MeanReducerState.java | 28 ++---
.../apache/heron/api/metric/MetricStatTimer.java | 28 ++---
.../heron/api/metric/MultiAssignableMetric.java | 28 ++---
.../apache/heron/api/metric/MultiCountMetric.java | 28 ++---
.../heron/api/metric/MultiReducedMetric.java | 28 ++---
.../org/apache/heron/api/metric/ReducedMetric.java | 28 ++---
.../heron/api/serializer/IPluggableSerializer.java | 28 ++---
.../heron/api/serializer/JavaSerializer.java | 28 ++---
.../org/apache/heron/api/spout/BaseRichSpout.java | 28 ++---
.../heron/api/spout/IMultiSchemableSpout.java | 28 ++---
.../org/apache/heron/api/spout/IRichSpout.java | 28 ++---
.../apache/heron/api/spout/ISchemableSpout.java | 28 ++---
.../java/org/apache/heron/api/spout/ISpout.java | 28 ++---
.../heron/api/spout/ISpoutOutputCollector.java | 28 ++---
.../org/apache/heron/api/spout/MultiScheme.java | 28 ++---
.../org/apache/heron/api/spout/RawMultiScheme.java | 28 ++---
.../java/org/apache/heron/api/spout/RawScheme.java | 28 ++---
.../java/org/apache/heron/api/spout/Scheme.java | 28 ++---
.../heron/api/spout/SchemeAsMultiScheme.java | 28 ++---
.../heron/api/spout/SpoutOutputCollector.java | 28 ++---
.../org/apache/heron/api/state/HashMapState.java | 28 ++---
.../src/java/org/apache/heron/api/state/State.java | 28 ++---
.../apache/heron/api/topology/BaseComponent.java | 28 ++---
.../heron/api/topology/BaseComponentDeclarer.java | 28 ++---
.../api/topology/BaseConfigurationDeclarer.java | 28 ++---
.../apache/heron/api/topology/BoltDeclarer.java | 28 ++---
.../topology/ComponentConfigurationDeclarer.java | 28 ++---
.../heron/api/topology/GeneralTopologyContext.java | 28 ++---
.../org/apache/heron/api/topology/IComponent.java | 28 ++---
.../heron/api/topology/IStatefulComponent.java | 28 ++---
.../org/apache/heron/api/topology/IUpdatable.java | 27 ++--
.../heron/api/topology/OutputFieldsDeclarer.java | 28 ++---
.../heron/api/topology/OutputFieldsGetter.java | 28 ++---
.../apache/heron/api/topology/SpoutDeclarer.java | 28 ++---
.../apache/heron/api/topology/TopologyBuilder.java | 28 ++---
.../apache/heron/api/topology/TopologyContext.java | 28 ++---
.../java/org/apache/heron/api/tuple/Fields.java | 28 ++---
.../src/java/org/apache/heron/api/tuple/Tuple.java | 28 ++---
.../java/org/apache/heron/api/tuple/Values.java | 28 ++---
.../api/utils/DefaultMaxSpoutPendingTuner.java | 28 ++---
.../org/apache/heron/api/utils/TopologyUtils.java | 32 +++--
.../org/apache/heron/api/utils/TupleUtils.java | 27 ++--
.../src/java/org/apache/heron/api/utils/Utils.java | 28 ++---
.../api/windowing/DefaultEvictionContext.java | 27 ++--
.../java/org/apache/heron/api/windowing/Event.java | 27 ++--
.../org/apache/heron/api/windowing/EventImpl.java | 27 ++--
.../heron/api/windowing/EvictionContext.java | 27 ++--
.../apache/heron/api/windowing/EvictionPolicy.java | 28 ++---
.../heron/api/windowing/TimestampExtractor.java | 27 ++--
.../apache/heron/api/windowing/TriggerHandler.java | 27 ++--
.../apache/heron/api/windowing/TriggerPolicy.java | 27 ++--
.../windowing/TupleFieldTimestampExtractor.java | 27 ++--
.../apache/heron/api/windowing/TupleWindow.java | 27 ++--
.../heron/api/windowing/TupleWindowImpl.java | 27 ++--
.../apache/heron/api/windowing/WaterMarkEvent.java | 27 ++--
.../api/windowing/WaterMarkEventGenerator.java | 28 ++---
.../org/apache/heron/api/windowing/Window.java | 27 ++--
.../api/windowing/WindowLifecycleListener.java | 27 ++--
.../apache/heron/api/windowing/WindowManager.java | 28 ++---
.../heron/api/windowing/WindowingConfigs.java | 27 ++--
.../windowing/evictors/CountEvictionPolicy.java | 27 ++--
.../api/windowing/evictors/TimeEvictionPolicy.java | 27 ++--
.../evictors/WatermarkCountEvictionPolicy.java | 27 ++--
.../evictors/WatermarkTimeEvictionPolicy.java | 27 ++--
.../triggers/AbstractBaseTriggerPolicy.java | 27 ++--
.../api/windowing/triggers/CountTriggerPolicy.java | 27 ++--
.../api/windowing/triggers/TimeTriggerPolicy.java | 27 ++--
.../triggers/WatermarkCountTriggerPolicy.java | 27 ++--
.../triggers/WatermarkTimeTriggerPolicy.java | 27 ++--
.../classification/HeronAnnotationProcessor.java | 32 +++--
.../heron/classification/InterfaceAudience.java | 32 +++--
.../heron/classification/InterfaceStability.java | 32 +++--
.../java/org/apache/heron/streamlet/Builder.java | 32 +++--
.../java/org/apache/heron/streamlet/Config.java | 32 +++--
.../java/org/apache/heron/streamlet/Context.java | 32 +++--
.../java/org/apache/heron/streamlet/JoinType.java | 32 +++--
.../java/org/apache/heron/streamlet/KeyValue.java | 31 +++--
.../org/apache/heron/streamlet/KeyedWindow.java | 32 +++--
.../java/org/apache/heron/streamlet/Runner.java | 32 +++--
.../heron/streamlet/SerializableBiFunction.java | 32 +++--
.../streamlet/SerializableBinaryOperator.java | 32 +++--
.../heron/streamlet/SerializableConsumer.java | 32 +++--
.../heron/streamlet/SerializableFunction.java | 32 +++--
.../heron/streamlet/SerializablePredicate.java | 32 +++--
.../heron/streamlet/SerializableSupplier.java | 32 +++--
.../heron/streamlet/SerializableTransformer.java | 32 +++--
.../src/java/org/apache/heron/streamlet/Sink.java | 32 +++--
.../java/org/apache/heron/streamlet/Source.java | 32 +++--
.../java/org/apache/heron/streamlet/Streamlet.java | 31 +++--
.../java/org/apache/heron/streamlet/Window.java | 32 +++--
.../org/apache/heron/streamlet/WindowConfig.java | 32 +++--
.../apache/heron/streamlet/impl/BuilderImpl.java | 32 +++--
.../apache/heron/streamlet/impl/ContextImpl.java | 32 +++--
.../heron/streamlet/impl/KryoSerializer.java | 32 +++--
.../apache/heron/streamlet/impl/StreamletImpl.java | 32 +++--
.../heron/streamlet/impl/WindowConfigImpl.java | 32 +++--
.../impl/groupings/JoinCustomGrouping.java | 32 +++--
.../ReduceByKeyAndWindowCustomGrouping.java | 32 +++--
.../impl/groupings/RemapCustomGrouping.java | 32 +++--
.../streamlet/impl/operators/FilterOperator.java | 32 +++--
.../streamlet/impl/operators/FlatMapOperator.java | 32 +++--
.../GeneralReduceByKeyAndWindowOperator.java | 32 +++--
.../streamlet/impl/operators/JoinOperator.java | 32 +++--
.../streamlet/impl/operators/MapOperator.java | 32 +++--
.../operators/ReduceByKeyAndWindowOperator.java | 32 +++--
.../impl/operators/StreamletOperator.java | 32 +++--
.../impl/operators/StreamletWindowOperator.java | 32 +++--
.../impl/operators/TransformOperator.java | 32 +++--
.../streamlet/impl/operators/UnionOperator.java | 32 +++--
.../heron/streamlet/impl/sinks/ComplexSink.java | 32 +++--
.../heron/streamlet/impl/sinks/ConsumerSink.java | 32 +++--
.../apache/heron/streamlet/impl/sinks/LogSink.java | 32 +++--
.../streamlet/impl/sources/ComplexSource.java | 32 +++--
.../streamlet/impl/sources/StreamletSource.java | 32 +++--
.../streamlet/impl/sources/SupplierSource.java | 32 +++--
.../impl/streamlets/ConsumerStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/FilterStreamlet.java | 32 +++--
.../impl/streamlets/FlatMapStreamlet.java | 32 +++--
.../GeneralReduceByKeyAndWindowStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/JoinStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/LogStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/MapStreamlet.java | 32 +++--
.../streamlets/ReduceByKeyAndWindowStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/RemapStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/SinkStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/SourceStreamlet.java | 32 +++--
.../impl/streamlets/SupplierStreamlet.java | 32 +++--
.../impl/streamlets/TransformStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/UnionStreamlet.java | 32 +++--
heron/api/tests/cpp/serialization_unittest.cpp | 25 ++--
.../java/org/apache/heron/api/ConfigTest.java | 31 +++--
.../org/apache/heron/api/HeronSubmitterTest.java | 32 +++--
.../heron/api/bolt/BaseWindowedBoltTest.java | 32 +++--
.../heron/api/bolt/WindowedBoltExecutorTest.java | 32 +++--
.../heron/api/metric/CountStatAndMetricTest.java | 32 +++--
.../heron/api/metric/LatencyStatAndMetricTest.java | 32 +++--
.../api/windowing/WaterMarkEventGeneratorTest.java | 32 +++--
.../heron/api/windowing/WindowManagerTest.java | 32 +++--
.../heron/streamlet/impl/StreamletImplTest.java | 32 +++--
.../GeneralReduceByKeyAndWindowOperatorTest.java | 32 +++--
.../streamlet/impl/operators/JoinOperatorTest.java | 32 +++--
.../ReduceByKeyAndWindowOperatorTest.java | 32 +++--
.../apache/heron/ckptmgr/CheckpointManager.java | 31 +++--
.../heron/ckptmgr/CheckpointManagerConfig.java | 31 +++--
.../heron/ckptmgr/CheckpointManagerConfigKey.java | 32 +++--
.../heron/ckptmgr/CheckpointManagerException.java | 31 +++--
.../heron/ckptmgr/CheckpointManagerServer.java | 31 +++--
.../heron/ckptmgr/CheckpointManagerServerTest.java | 31 +++--
heron/common/src/cpp/basics/basics.cpp | 25 ++--
heron/common/src/cpp/basics/basics.h | 25 ++--
heron/common/src/cpp/basics/callback.h | 25 ++--
heron/common/src/cpp/basics/callback1.h | 25 ++--
heron/common/src/cpp/basics/classcallback.h | 25 ++--
heron/common/src/cpp/basics/classcallback1.h | 25 ++--
heron/common/src/cpp/basics/execmeta.cpp | 25 ++--
heron/common/src/cpp/basics/execmeta.h | 25 ++--
heron/common/src/cpp/basics/fileutils.cpp | 25 ++--
heron/common/src/cpp/basics/fileutils.h | 25 ++--
heron/common/src/cpp/basics/iputils.cpp | 25 ++--
heron/common/src/cpp/basics/iputils.h | 25 ++--
heron/common/src/cpp/basics/mempool.cpp | 25 ++--
heron/common/src/cpp/basics/mempool.h | 26 ++--
heron/common/src/cpp/basics/modinit.cpp | 25 ++--
heron/common/src/cpp/basics/modinit.h | 25 ++--
heron/common/src/cpp/basics/processutils.cpp | 25 ++--
heron/common/src/cpp/basics/processutils.h | 25 ++--
heron/common/src/cpp/basics/randutils.cpp | 25 ++--
heron/common/src/cpp/basics/randutils.h | 25 ++--
heron/common/src/cpp/basics/ridgen.cpp | 25 ++--
heron/common/src/cpp/basics/ridgen.h | 25 ++--
heron/common/src/cpp/basics/sockutils.cpp | 25 ++--
heron/common/src/cpp/basics/sockutils.h | 25 ++--
heron/common/src/cpp/basics/spconsts.h | 25 ++--
heron/common/src/cpp/basics/spfuncs.h | 25 ++--
heron/common/src/cpp/basics/sphash.h | 25 ++--
heron/common/src/cpp/basics/sprcodes.h | 25 ++--
heron/common/src/cpp/basics/sptest.h | 25 ++--
heron/common/src/cpp/basics/sptypes.h | 25 ++--
heron/common/src/cpp/basics/strutils.cpp | 25 ++--
heron/common/src/cpp/basics/strutils.h | 25 ++--
heron/common/src/cpp/config/allconfig.h | 25 ++--
.../src/cpp/config/cluster-config-reader.cpp | 25 ++--
.../common/src/cpp/config/cluster-config-reader.h | 25 ++--
.../common/src/cpp/config/cluster-config-vars.cpp | 25 ++--
heron/common/src/cpp/config/cluster-config-vars.h | 25 ++--
heron/common/src/cpp/config/helper.h | 25 ++--
.../cpp/config/heron-internals-config-reader.cpp | 25 ++--
.../src/cpp/config/heron-internals-config-reader.h | 25 ++--
.../src/cpp/config/heron-internals-config-vars.cpp | 25 ++--
.../src/cpp/config/heron-internals-config-vars.h | 25 ++--
.../common/src/cpp/config/metrics-sinks-reader.cpp | 25 ++--
heron/common/src/cpp/config/metrics-sinks-reader.h | 25 ++--
heron/common/src/cpp/config/metrics-sinks-vars.cpp | 25 ++--
heron/common/src/cpp/config/metrics-sinks-vars.h | 25 ++--
.../src/cpp/config/operational-config-reader.cpp | 25 ++--
.../src/cpp/config/operational-config-reader.h | 25 ++--
.../src/cpp/config/operational-config-vars.cpp | 25 ++--
.../src/cpp/config/operational-config-vars.h | 25 ++--
.../common/src/cpp/config/physical-plan-helper.cpp | 25 ++--
heron/common/src/cpp/config/physical-plan-helper.h | 25 ++--
heron/common/src/cpp/config/reader.h | 25 ++--
.../src/cpp/config/topology-config-helper.cpp | 25 ++--
.../common/src/cpp/config/topology-config-helper.h | 25 ++--
.../common/src/cpp/config/topology-config-vars.cpp | 25 ++--
heron/common/src/cpp/config/topology-config-vars.h | 25 ++--
heron/common/src/cpp/config/yaml-file-reader.cpp | 25 ++--
heron/common/src/cpp/config/yaml-file-reader.h | 25 ++--
heron/common/src/cpp/errors/errors.h | 25 ++--
heron/common/src/cpp/errors/gexception.cpp | 25 ++--
heron/common/src/cpp/errors/gexception.h | 25 ++--
heron/common/src/cpp/errors/modinit.cpp | 25 ++--
heron/common/src/cpp/errors/modinit.h | 25 ++--
heron/common/src/cpp/errors/sperrimpl.cpp | 25 ++--
heron/common/src/cpp/errors/sperrimpl.h | 25 ++--
heron/common/src/cpp/errors/sperrmod.h | 25 ++--
heron/common/src/cpp/errors/sperror.cpp | 25 ++--
heron/common/src/cpp/errors/sperror.h | 25 ++--
heron/common/src/cpp/errors/spexcept.cpp | 25 ++--
heron/common/src/cpp/errors/spexcept.h | 25 ++--
heron/common/src/cpp/errors/syserr.h | 25 ++--
heron/common/src/cpp/metrics/assignable-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/assignable-metric.h | 25 ++--
heron/common/src/cpp/metrics/count-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/count-metric.h | 25 ++--
heron/common/src/cpp/metrics/imetric.h | 25 ++--
heron/common/src/cpp/metrics/mean-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/mean-metric.h | 25 ++--
heron/common/src/cpp/metrics/metrics-mgr-st.cpp | 25 ++--
heron/common/src/cpp/metrics/metrics-mgr-st.h | 25 ++--
heron/common/src/cpp/metrics/metrics.h | 25 ++--
heron/common/src/cpp/metrics/metricsmgr-client.cpp | 25 ++--
heron/common/src/cpp/metrics/metricsmgr-client.h | 25 ++--
.../src/cpp/metrics/multi-assignable-metric.cpp | 25 ++--
.../src/cpp/metrics/multi-assignable-metric.h | 25 ++--
.../common/src/cpp/metrics/multi-count-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/multi-count-metric.h | 25 ++--
heron/common/src/cpp/metrics/multi-mean-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/multi-mean-metric.h | 25 ++--
heron/common/src/cpp/metrics/time-spent-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/time-spent-metric.h | 25 ++--
heron/common/src/cpp/metrics/tmaster-metrics.cpp | 25 ++--
heron/common/src/cpp/metrics/tmaster-metrics.h | 25 ++--
heron/common/src/cpp/network/asyncdns.cpp | 25 ++--
heron/common/src/cpp/network/asyncdns.h | 25 ++--
heron/common/src/cpp/network/baseclient.cpp | 25 ++--
heron/common/src/cpp/network/baseclient.h | 25 ++--
heron/common/src/cpp/network/baseconnection.cpp | 25 ++--
heron/common/src/cpp/network/baseconnection.h | 25 ++--
heron/common/src/cpp/network/baseserver.cpp | 25 ++--
heron/common/src/cpp/network/baseserver.h | 25 ++--
heron/common/src/cpp/network/client.cpp | 25 ++--
heron/common/src/cpp/network/client.h | 25 ++--
heron/common/src/cpp/network/connection.cpp | 25 ++--
heron/common/src/cpp/network/connection.h | 25 ++--
heron/common/src/cpp/network/event_loop.h | 25 ++--
heron/common/src/cpp/network/event_loop_impl.cpp | 25 ++--
heron/common/src/cpp/network/event_loop_impl.h | 25 ++--
heron/common/src/cpp/network/httpclient.cpp | 25 ++--
heron/common/src/cpp/network/httpclient.h | 25 ++--
heron/common/src/cpp/network/httpserver.cpp | 25 ++--
heron/common/src/cpp/network/httpserver.h | 25 ++--
heron/common/src/cpp/network/httputils.cpp | 25 ++--
heron/common/src/cpp/network/httputils.h | 25 ++--
heron/common/src/cpp/network/modinit.cpp | 25 ++--
heron/common/src/cpp/network/modinit.h | 25 ++--
heron/common/src/cpp/network/network.h | 25 ++--
heron/common/src/cpp/network/network_error.h | 25 ++--
heron/common/src/cpp/network/networkoptions.cpp | 25 ++--
heron/common/src/cpp/network/networkoptions.h | 25 ++--
heron/common/src/cpp/network/packet.cpp | 25 ++--
heron/common/src/cpp/network/packet.h | 25 ++--
heron/common/src/cpp/network/piper.cpp | 25 ++--
heron/common/src/cpp/network/piper.h | 25 ++--
heron/common/src/cpp/network/regevent.h | 25 ++--
heron/common/src/cpp/network/server.cpp | 25 ++--
heron/common/src/cpp/network/server.h | 25 ++--
heron/common/src/cpp/setup/zk-setup.cpp | 25 ++--
heron/common/src/cpp/threads/modinit.cpp | 25 ++--
heron/common/src/cpp/threads/modinit.h | 25 ++--
heron/common/src/cpp/threads/pcqueue.h | 25 ++--
heron/common/src/cpp/threads/spcountdownlatch.cpp | 25 ++--
heron/common/src/cpp/threads/spcountdownlatch.h | 25 ++--
heron/common/src/cpp/threads/threads.h | 25 ++--
heron/common/src/cpp/zookeeper/mock_zkclient.h | 25 ++--
heron/common/src/cpp/zookeeper/zkclient.cpp | 25 ++--
heron/common/src/cpp/zookeeper/zkclient.h | 25 ++--
heron/common/src/cpp/zookeeper/zkclient_factory.h | 25 ++--
.../org/apache/heron/common/basics/ByteAmount.java | 32 +++--
.../apache/heron/common/basics/Communicator.java | 31 +++--
.../heron/common/basics/DryRunFormatType.java | 31 +++--
.../org/apache/heron/common/basics/FileUtils.java | 31 +++--
.../apache/heron/common/basics/ISelectHandler.java | 31 +++--
.../org/apache/heron/common/basics/NIOLooper.java | 31 +++--
.../apache/heron/common/basics/PackageType.java | 31 +++--
.../java/org/apache/heron/common/basics/Pair.java | 31 +++--
.../heron/common/basics/SingletonRegistry.java | 31 +++--
.../apache/heron/common/basics/SlaveLooper.java | 31 +++--
.../org/apache/heron/common/basics/SysUtils.java | 31 +++--
.../org/apache/heron/common/basics/TypeUtils.java | 31 +++--
.../apache/heron/common/basics/WakeableLooper.java | 31 +++--
.../apache/heron/common/config/ConfigReader.java | 31 +++--
.../apache/heron/common/config/SystemConfig.java | 31 +++--
.../heron/common/config/SystemConfigKey.java | 32 +++--
.../apache/heron/common/network/HeronClient.java | 31 +++--
.../apache/heron/common/network/HeronServer.java | 31 +++--
.../heron/common/network/HeronSocketOptions.java | 31 +++--
.../heron/common/network/IncomingPacket.java | 31 +++--
.../heron/common/network/OutgoingPacket.java | 31 +++--
.../org/apache/heron/common/network/REQID.java | 31 +++--
.../heron/common/network/SocketChannelHelper.java | 31 +++--
.../apache/heron/common/network/StatusCode.java | 31 +++--
.../common/testhelpers/CommunicatorTestHelper.java | 32 +++--
.../common/testhelpers/HeronServerTester.java | 32 +++--
.../utils/logging/ErrorReportLoggingHandler.java | 31 +++--
.../heron/common/utils/logging/LoggingHelper.java | 31 +++--
.../heron/common/utils/metrics/BoltMetrics.java | 31 +++--
.../common/utils/metrics/ComponentMetrics.java | 32 +++--
.../common/utils/metrics/FullBoltMetrics.java | 31 +++--
.../common/utils/metrics/FullSpoutMetrics.java | 31 +++--
.../heron/common/utils/metrics/JVMMetrics.java | 31 +++--
.../common/utils/metrics/MetricsCollector.java | 31 +++--
.../heron/common/utils/metrics/SpoutMetrics.java | 31 +++--
.../utils/misc/CustomStreamGroupingHelper.java | 31 +++--
.../common/utils/misc/PhysicalPlanHelper.java | 31 +++--
.../utils/misc/SerializeDeSerializeHelper.java | 31 +++--
.../heron/common/utils/misc/ThreadNames.java | 31 +++--
.../heron/common/utils/misc/TupleKeyGenerator.java | 31 +++--
.../utils/topology/GeneralTopologyContextImpl.java | 31 +++--
.../common/utils/topology/TopologyContextImpl.java | 31 +++--
.../heron/common/utils/topology/TopologyTests.java | 32 +++--
.../apache/heron/common/utils/tuple/TickTuple.java | 31 +++--
.../apache/heron/common/utils/tuple/TupleImpl.java | 31 +++--
.../common/tests/cpp/basics/fileutils_unittest.cpp | 25 ++--
heron/common/tests/cpp/basics/rid_unittest.cpp | 25 ++--
.../common/tests/cpp/basics/strutils_unittest.cpp | 25 ++--
heron/common/tests/cpp/basics/utils_unittest.cpp | 25 ++--
.../cpp/config/topology-config-helper_unittest.cpp | 25 ++--
heron/common/tests/cpp/errors/errors_unittest.cpp | 25 ++--
heron/common/tests/cpp/errors/module_unittest.cpp | 25 ++--
heron/common/tests/cpp/errors/syserrs_unittest.cpp | 25 ++--
.../tests/cpp/metrics/count-metric_unittest.cpp | 25 ++--
.../tests/cpp/metrics/mean-metric_unittest.cpp | 25 ++--
.../cpp/metrics/multi-count-metric_unittest.cpp | 25 ++--
.../cpp/metrics/multi-mean-metric_unittest.cpp | 25 ++--
.../cpp/metrics/time-spent-metric_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/client_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/client_unittest.h | 25 ++--
heron/common/tests/cpp/network/host_unittest.h | 25 ++--
.../tests/cpp/network/http_client_unittest.cpp | 25 ++--
.../tests/cpp/network/http_server_unittest.cpp | 25 ++--
.../tests/cpp/network/http_server_unittest.h | 25 ++--
heron/common/tests/cpp/network/http_unittest.cpp | 25 ++--
.../common/tests/cpp/network/oclient_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/oclient_unittest.h | 25 ++--
heron/common/tests/cpp/network/order_unittest.cpp | 25 ++--
.../common/tests/cpp/network/oserver_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/oserver_unittest.h | 25 ++--
heron/common/tests/cpp/network/packet_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/piper_unittest.cpp | 26 ++--
.../tests/cpp/network/rate_limit_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/server_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/server_unittest.h | 25 ++--
heron/common/tests/cpp/network/switch_unittest.cpp | 25 ++--
.../cpp/threads/spcountdownlatch_unittest.cpp | 25 ++--
heron/common/tests/cpp/zookeeper/simpletest.cpp | 25 ++--
.../apache/heron/common/basics/ByteAmountTest.java | 32 +++--
.../heron/common/basics/CommunicatorTest.java | 31 +++--
.../apache/heron/common/basics/FileUtilsTest.java | 31 +++--
.../heron/common/basics/PackageTypeTest.java | 31 +++--
.../apache/heron/common/basics/SysUtilsTest.java | 31 +++--
.../heron/common/basics/WakeableLooperTest.java | 31 +++--
.../heron/common/config/ConfigReaderTest.java | 31 +++--
.../heron/common/config/SystemConfigTest.java | 31 +++--
.../org/apache/heron/common/test/EchoTest.java | 31 +++--
.../apache/heron/common/test/HeronServerTest.java | 31 +++--
.../heron/common/utils/TopologyUtilsTest.java | 31 +++--
.../org/apache/heron/downloader/DLDownloader.java | 32 +++--
.../apache/heron/downloader/DownloadRunner.java | 32 +++--
.../org/apache/heron/downloader/Downloader.java | 32 +++--
.../org/apache/heron/downloader/Extractor.java | 32 +++--
.../apache/heron/downloader/FileDownloader.java | 32 +++--
.../apache/heron/downloader/HttpDownloader.java | 32 +++--
.../java/org/apache/heron/downloader/Registry.java | 32 +++--
.../apache/heron/downloader/DLDownloaderTest.java | 32 +++--
.../apache/heron/downloader/ExtractorTests.java | 32 +++--
.../org/apache/heron/downloader/RegistryTest.java | 32 +++--
.../org/apache/heron/healthmgr/HealthManager.java | 31 +++--
.../heron/healthmgr/HealthManagerMetrics.java | 31 +++--
.../apache/heron/healthmgr/HealthPolicyConfig.java | 31 +++--
.../heron/healthmgr/HealthPolicyConfigReader.java | 31 +++--
.../healthmgr/common/HealthManagerEvents.java | 31 +++--
.../healthmgr/common/InvalidStateException.java | 31 +++--
.../heron/healthmgr/common/MetricsStats.java | 32 ++---
.../healthmgr/common/PackingPlanProvider.java | 31 +++--
.../healthmgr/common/PhysicalPlanProvider.java | 31 +++--
.../heron/healthmgr/common/TopologyProvider.java | 31 +++--
.../healthmgr/detectors/BackPressureDetector.java | 32 ++---
.../heron/healthmgr/detectors/BaseDetector.java | 31 +++--
.../detectors/GrowingWaitQueueDetector.java | 32 ++---
.../detectors/LargeWaitQueueDetector.java | 32 ++---
.../detectors/ProcessingRateSkewDetector.java | 32 ++---
.../heron/healthmgr/detectors/SkewDetector.java | 32 ++---
.../healthmgr/detectors/WaitQueueSkewDetector.java | 32 ++---
.../heron/healthmgr/diagnosers/BaseDiagnoser.java | 31 +++--
.../healthmgr/diagnosers/DataSkewDiagnoser.java | 32 ++---
.../diagnosers/SlowInstanceDiagnoser.java | 31 +++--
.../diagnosers/UnderProvisioningDiagnoser.java | 32 ++---
.../AutoRestartBackpressureContainerPolicy.java | 32 ++---
.../policy/DynamicResourceAllocationPolicy.java | 32 ++---
.../resolvers/RestartContainerResolver.java | 32 +++--
.../heron/healthmgr/resolvers/ScaleUpResolver.java | 32 +++--
.../healthmgr/sensors/BackPressureSensor.java | 32 ++---
.../apache/heron/healthmgr/sensors/BaseSensor.java | 31 +++--
.../heron/healthmgr/sensors/BufferSizeSensor.java | 32 ++---
.../healthmgr/sensors/ExecuteCountSensor.java | 32 ++---
.../sensors/MetricsCacheMetricsProvider.java | 32 ++---
.../healthmgr/sensors/TrackerMetricsProvider.java | 32 ++---
.../apache/heron/healthmgr/HealthManagerTest.java | 31 +++--
.../healthmgr/HealthPolicyConfigReaderTest.java | 31 +++--
.../healthmgr/common/PackingPlanProviderTest.java | 31 +++--
.../healthmgr/common/TopologyProviderTest.java | 31 +++--
.../detectors/BackPressureDetectorTest.java | 31 +++--
.../detectors/GrowingWaitQueueDetectorTest.java | 31 +++--
.../detectors/LargeWaitQueueDetectorTest.java | 31 +++--
.../detectors/ProcessingRateSkewDetectorTest.java | 31 +++--
.../detectors/WaitQueueSkewDetectorTest.java | 31 +++--
.../diagnosers/DataSkewDiagnoserTest.java | 31 +++--
.../diagnosers/SlowInstanceDiagnoserTest.java | 31 +++--
.../diagnosers/UnderProvisioningDiagnoserTest.java | 31 +++--
.../healthmgr/resolvers/ScaleUpResolverTest.java | 31 +++--
.../healthmgr/sensors/BackPressureSensorTest.java | 31 +++--
.../healthmgr/sensors/BufferSizeSensorTest.java | 31 +++--
.../healthmgr/sensors/ExecuteCountSensorTest.java | 31 +++--
.../sensors/MetricsCacheMetricsProviderTest.java | 31 +++--
.../sensors/TrackerMetricsProviderTest.java | 31 +++--
heron/instance/src/cpp/boltimpl/bolt-instance.cpp | 25 ++--
heron/instance/src/cpp/boltimpl/bolt-instance.h | 25 ++--
heron/instance/src/cpp/boltimpl/bolt-metrics.cpp | 25 ++--
heron/instance/src/cpp/boltimpl/bolt-metrics.h | 25 ++--
.../cpp/boltimpl/bolt-output-collector-impl.cpp | 25 ++--
.../src/cpp/boltimpl/bolt-output-collector-impl.h | 25 ++--
heron/instance/src/cpp/boltimpl/tick-tuple.cpp | 25 ++--
heron/instance/src/cpp/boltimpl/tick-tuple.h | 25 ++--
heron/instance/src/cpp/boltimpl/tuple-impl.cpp | 25 ++--
heron/instance/src/cpp/boltimpl/tuple-impl.h | 25 ++--
heron/instance/src/cpp/gateway/gateway-metrics.cpp | 25 ++--
heron/instance/src/cpp/gateway/gateway-metrics.h | 25 ++--
heron/instance/src/cpp/gateway/gateway.cpp | 25 ++--
heron/instance/src/cpp/gateway/gateway.h | 25 ++--
heron/instance/src/cpp/gateway/stmgr-client.cpp | 25 ++--
heron/instance/src/cpp/gateway/stmgr-client.h | 25 ++--
heron/instance/src/cpp/instance-main.cpp | 25 ++--
.../src/cpp/slave/imetrics-registrar-impl.cpp | 25 ++--
.../src/cpp/slave/imetrics-registrar-impl.h | 25 ++--
heron/instance/src/cpp/slave/instance-base.h | 25 ++--
.../src/cpp/slave/outgoing-tuple-collection.cpp | 25 ++--
.../src/cpp/slave/outgoing-tuple-collection.h | 25 ++--
heron/instance/src/cpp/slave/slave.cpp | 25 ++--
heron/instance/src/cpp/slave/slave.h | 25 ++--
heron/instance/src/cpp/slave/task-context-impl.cpp | 25 ++--
heron/instance/src/cpp/slave/task-context-impl.h | 25 ++--
heron/instance/src/cpp/spoutimpl/root-tuple-info.h | 25 ++--
.../instance/src/cpp/spoutimpl/spout-instance.cpp | 25 ++--
heron/instance/src/cpp/spoutimpl/spout-instance.h | 25 ++--
heron/instance/src/cpp/spoutimpl/spout-metrics.cpp | 25 ++--
heron/instance/src/cpp/spoutimpl/spout-metrics.h | 25 ++--
.../cpp/spoutimpl/spout-output-collector-impl.cpp | 25 ++--
.../cpp/spoutimpl/spout-output-collector-impl.h | 25 ++--
heron/instance/src/cpp/utils/communicator.h | 25 ++--
.../src/cpp/utils/notifying-communicator.h | 25 ++--
.../heron/instance/AbstractOutputCollector.java | 32 +++--
.../java/org/apache/heron/instance/Gateway.java | 31 +++--
.../org/apache/heron/instance/HeronInstance.java | 31 +++--
.../java/org/apache/heron/instance/IInstance.java | 31 +++--
.../apache/heron/instance/InstanceControlMsg.java | 31 +++--
.../heron/instance/OutgoingTupleCollection.java | 31 +++--
.../src/java/org/apache/heron/instance/Slave.java | 31 +++--
.../apache/heron/instance/bolt/BoltInstance.java | 31 +++--
.../instance/bolt/BoltOutputCollectorImpl.java | 31 +++--
.../apache/heron/instance/spout/RootTupleInfo.java | 31 +++--
.../apache/heron/instance/spout/SpoutInstance.java | 31 +++--
.../instance/spout/SpoutOutputCollectorImpl.java | 31 +++--
.../apache/heron/instance/util/InstanceUtils.java | 32 +++--
.../org/apache/heron/instance/util/JvmVersion.java | 32 +++--
.../org/apache/heron/metrics/GatewayMetrics.java | 31 +++--
.../apache/heron/network/MetricsManagerClient.java | 31 +++--
.../apache/heron/network/StreamManagerClient.java | 31 +++--
.../heron/grouping/AbstractTupleRoutingTest.java | 31 +++--
.../apache/heron/grouping/CustomGroupingTest.java | 32 +++--
.../apache/heron/grouping/EmitDirectBoltTest.java | 32 +++--
.../heron/grouping/EmitDirectRoundRobinBolt.java | 32 +++--
.../heron/grouping/EmitDirectRoundRobinSpout.java | 32 +++--
.../apache/heron/grouping/EmitDirectSpoutTest.java | 32 +++--
.../apache/heron/instance/CommunicatorTester.java | 32 +++--
.../org/apache/heron/instance/SlaveTester.java | 32 +++--
.../heron/instance/bolt/BoltInstanceTest.java | 31 +++--
.../instance/spout/ActivateDeactivateTest.java | 31 +++--
.../heron/instance/spout/SpoutInstanceTest.java | 31 +++--
.../apache/heron/metrics/GlobalMetricsTest.java | 31 +++--
.../heron/metrics/MultiAssignableMetricTest.java | 31 +++--
.../apache/heron/network/AbstractNetworkTest.java | 32 +++--
.../java/org/apache/heron/network/ConnectTest.java | 31 +++--
.../org/apache/heron/network/HandleReadTest.java | 31 +++--
.../org/apache/heron/network/HandleWriteTest.java | 31 +++--
.../java/org/apache/heron/resource/Constants.java | 31 +++--
.../java/org/apache/heron/resource/TestBolt.java | 31 +++--
.../java/org/apache/heron/resource/TestSpout.java | 31 +++--
.../org/apache/heron/resource/UnitTestHelper.java | 31 +++--
.../java/org/apache/heron/dlog/DLInputStream.java | 32 +++--
.../java/org/apache/heron/dlog/DLOutputStream.java | 32 +++--
.../dlog/src/java/org/apache/heron/dlog/Util.java | 32 +++--
.../org/apache/heron/dlog/DLInputStreamTest.java | 32 +++--
.../org/apache/heron/dlog/DLOutputStreamTest.java | 32 +++--
.../heron/metricscachemgr/MetricsCacheManager.java | 32 ++---
.../MetricsCacheManagerHttpServer.java | 31 +++--
.../metricscachemgr/MetricsCacheManagerServer.java | 31 +++--
.../metricscachemgr/metricscache/CacheCore.java | 31 +++--
.../metricscachemgr/metricscache/MetricsCache.java | 31 +++--
.../metricscache/MetricsCacheQueryUtils.java | 31 +++--
.../metricscache/query/ExceptionDatum.java | 31 +++--
.../metricscache/query/ExceptionRequest.java | 31 +++--
.../metricscache/query/ExceptionResponse.java | 31 +++--
.../metricscache/query/MetricDatum.java | 31 +++--
.../metricscache/query/MetricGranularity.java | 31 +++--
.../metricscache/query/MetricRequest.java | 31 +++--
.../metricscache/query/MetricResponse.java | 31 +++--
.../metricscache/query/MetricTimeRangeValue.java | 31 +++--
.../metricscache/store/ExceptionDatapoint.java | 31 +++--
.../metricscache/store/MetricDatapoint.java | 31 +++--
.../metricscache/CacheCoreTest.java | 32 ++---
.../metricscache/MetricsCacheQueryUtilsTest.java | 31 +++--
.../metricscache/MetricsCacheTest.java | 31 +++--
.../apache/heron/metricsmgr/MetricsManager.java | 31 +++--
.../heron/metricsmgr/MetricsManagerServer.java | 31 +++--
.../heron/metricsmgr/MetricsSinksConfig.java | 31 +++--
.../org/apache/heron/metricsmgr/MetricsUtil.java | 32 +++--
.../heron/metricsmgr/executor/SinkExecutor.java | 31 +++--
.../heron/metricsmgr/sink/AbstractWebSink.java | 32 +++--
.../org/apache/heron/metricsmgr/sink/FileSink.java | 31 +++--
.../apache/heron/metricsmgr/sink/GraphiteSink.java | 31 +++--
.../heron/metricsmgr/sink/PrometheusSink.java | 32 +++--
.../heron/metricsmgr/sink/SinkContextImpl.java | 31 +++--
.../org/apache/heron/metricsmgr/sink/WebSink.java | 31 +++--
.../sink/metricscache/MetricsCacheClient.java | 31 +++--
.../sink/metricscache/MetricsCacheSink.java | 31 +++--
.../metricsmgr/sink/tmaster/TMasterClient.java | 31 +++--
.../heron/metricsmgr/sink/tmaster/TMasterSink.java | 31 +++--
.../metricsmgr/HandleTMasterLocationTest.java | 31 +++--
.../heron/metricsmgr/LatchedMultiCountMetric.java | 32 +++--
.../heron/metricsmgr/MetricsManagerServerTest.java | 31 +++--
.../apache/heron/metricsmgr/MetricsUtilTests.java | 32 +++--
.../metricsmgr/executor/SinkExecutorTest.java | 31 +++--
.../apache/heron/metricsmgr/sink/FileSinkTest.java | 31 +++--
.../heron/metricsmgr/sink/PrometheusSinkTests.java | 32 +++--
.../apache/heron/metricsmgr/sink/WebSinkTest.java | 31 +++--
.../sink/metricscache/MetricsCacheSinkTest.java | 31 +++--
.../metricsmgr/sink/tmaster/TMasterSinkTest.java | 31 +++--
.../org/apache/heron/packing/RamRequirement.java | 31 +++--
.../heron/packing/ResourceExceededException.java | 32 +++--
.../binpacking/FirstFitDecreasingPacking.java | 31 +++--
.../apache/heron/packing/builder/Container.java | 32 +++--
.../heron/packing/builder/ContainerIdScorer.java | 32 +++--
.../heron/packing/builder/HomogeneityScorer.java | 32 +++--
.../heron/packing/builder/InstanceCountScorer.java | 32 +++--
.../heron/packing/builder/PackingPlanBuilder.java | 32 +++--
.../org/apache/heron/packing/builder/Scorer.java | 32 +++--
.../roundrobin/ResourceCompliantRRPacking.java | 31 +++--
.../packing/roundrobin/RoundRobinPacking.java | 31 +++--
.../apache/heron/packing/utils/PackingUtils.java | 32 +++--
.../org/apache/heron/packing/AssertPacking.java | 32 +++--
.../apache/heron/packing/CommonPackingTests.java | 32 +++--
.../apache/heron/packing/PackingTestHelper.java | 32 +++--
.../binpacking/FirstFitDecreasingPackingTest.java | 31 +++--
.../packing/builder/PackingPlanBuilderTest.java | 32 +++--
.../apache/heron/packing/builder/ScorerTest.java | 32 +++--
.../roundrobin/ResourceCompliantRRPackingTest.java | 31 +++--
.../packing/roundrobin/RoundRobinPackingTest.java | 31 +++--
.../heron/packing/utils/PackingUtilsTest.java | 32 +++--
heron/proto/Empty.java | 31 +++--
heron/proto/messages.h | 25 ++--
.../java/org/apache/heron/scheduler/Command.java | 32 +++--
.../org/apache/heron/scheduler/ExecutorFlag.java | 32 +++--
.../org/apache/heron/scheduler/LaunchRunner.java | 31 +++--
.../apache/heron/scheduler/RuntimeManagerMain.java | 31 +++--
.../heron/scheduler/RuntimeManagerRunner.java | 31 +++--
.../org/apache/heron/scheduler/SchedulerMain.java | 31 +++--
.../org/apache/heron/scheduler/SubmitterMain.java | 31 +++--
.../TopologyRuntimeManagementException.java | 31 +++--
.../scheduler/TopologySubmissionException.java | 31 +++--
.../heron/scheduler/UpdateTopologyManager.java | 32 +++--
.../client/HttpServiceSchedulerClient.java | 31 +++--
.../heron/scheduler/client/ISchedulerClient.java | 31 +++--
.../scheduler/client/LibrarySchedulerClient.java | 31 +++--
.../scheduler/client/SchedulerClientFactory.java | 31 +++--
.../heron/scheduler/dryrun/DryRunRender.java | 32 +++--
.../heron/scheduler/dryrun/DryRunResponse.java | 32 +++--
.../heron/scheduler/dryrun/FormatterUtils.java | 32 +++--
.../heron/scheduler/dryrun/JsonFormatterUtils.java | 32 +++--
.../scheduler/dryrun/SubmitDryRunResponse.java | 32 +++--
.../scheduler/dryrun/SubmitJsonDryRunRenderer.java | 32 +++--
.../scheduler/dryrun/SubmitRawDryRunRenderer.java | 32 +++--
.../dryrun/SubmitTableDryRunRenderer.java | 32 +++--
.../scheduler/dryrun/UpdateDryRunResponse.java | 32 +++--
.../scheduler/dryrun/UpdateJsonDryRunRenderer.java | 32 +++--
.../scheduler/dryrun/UpdateRawDryRunRenderer.java | 32 +++--
.../dryrun/UpdateTableDryRunRenderer.java | 32 +++--
.../server/ExceptionalRequestHandler.java | 32 +++--
.../heron/scheduler/server/KillRequestHandler.java | 31 +++--
.../scheduler/server/RestartRequestHandler.java | 31 +++--
.../heron/scheduler/server/SchedulerServer.java | 31 +++--
.../server/TerminateSchedulerException.java | 32 +++--
.../scheduler/server/UpdateRequestHandler.java | 32 +++--
.../heron/scheduler/utils/DryRunRenders.java | 32 +++--
.../heron/scheduler/utils/LauncherUtils.java | 31 +++--
.../org/apache/heron/scheduler/utils/Runtime.java | 31 +++--
.../scheduler/utils/SchedulerConfigUtils.java | 31 +++--
.../heron/scheduler/utils/SchedulerUtils.java | 31 +++--
.../org/apache/heron/scheduler/utils/Shutdown.java | 31 +++--
.../heron/scheduler/utils/SubmitterUtils.java | 32 +++--
.../apache/heron/scheduler/LaunchRunnerTest.java | 31 +++--
.../heron/scheduler/RuntimeManagerMainTest.java | 31 +++--
.../heron/scheduler/RuntimeManagerRunnerTest.java | 31 +++--
.../apache/heron/scheduler/SchedulerMainTest.java | 31 +++--
.../apache/heron/scheduler/SubmitterMainTest.java | 31 +++--
.../heron/scheduler/UpdateTopologyManagerTest.java | 32 +++--
.../client/HttpServiceSchedulerClientTest.java | 31 +++--
.../client/LibrarySchedulerClientTest.java | 31 +++--
.../client/SchedulerClientFactoryTest.java | 31 +++--
.../scheduler/dryrun/JsonFormatterUtilsTest.java | 32 +++--
.../scheduler/dryrun/SubmitDryRunRenderTest.java | 32 +++--
.../scheduler/dryrun/UpdateDryRunRenderTest.java | 32 +++--
.../scheduler/server/SchedulerServerTest.java | 31 +++--
.../heron/scheduler/utils/LauncherUtilsTest.java | 31 +++--
.../heron/scheduler/utils/SchedulerUtilsTest.java | 31 +++--
.../org/apache/heron/scheduler/NullLauncher.java | 31 +++--
.../org/apache/heron/scheduler/NullScheduler.java | 31 +++--
.../scheduler/aurora/AuroraCLIController.java | 31 +++--
.../heron/scheduler/aurora/AuroraContext.java | 31 +++--
.../heron/scheduler/aurora/AuroraController.java | 32 +++--
.../apache/heron/scheduler/aurora/AuroraField.java | 32 +++--
.../aurora/AuroraHeronShellController.java | 31 +++--
.../heron/scheduler/aurora/AuroraLauncher.java | 31 +++--
.../heron/scheduler/aurora/AuroraScheduler.java | 31 +++--
.../kubernetes/AppsV1beta1Controller.java | 32 +++--
.../scheduler/kubernetes/KubernetesCompat.java | 32 +++--
.../scheduler/kubernetes/KubernetesConstants.java | 31 +++--
.../scheduler/kubernetes/KubernetesContext.java | 31 +++--
.../scheduler/kubernetes/KubernetesController.java | 32 +++--
.../scheduler/kubernetes/KubernetesLauncher.java | 31 +++--
.../scheduler/kubernetes/KubernetesScheduler.java | 31 +++--
.../scheduler/kubernetes/KubernetesUtils.java | 32 +++--
.../apache/heron/scheduler/kubernetes/Volumes.java | 32 +++--
.../apache/heron/scheduler/local/LocalContext.java | 31 +++--
.../org/apache/heron/scheduler/local/LocalKey.java | 32 +++--
.../heron/scheduler/local/LocalLauncher.java | 31 +++--
.../heron/scheduler/local/LocalScheduler.java | 31 +++--
.../scheduler/marathon/MarathonConstants.java | 31 +++--
.../heron/scheduler/marathon/MarathonContext.java | 31 +++--
.../scheduler/marathon/MarathonController.java | 31 +++--
.../heron/scheduler/marathon/MarathonLauncher.java | 31 +++--
.../scheduler/marathon/MarathonScheduler.java | 31 +++--
.../apache/heron/scheduler/mesos/MesosContext.java | 31 +++--
.../heron/scheduler/mesos/MesosLauncher.java | 31 +++--
.../heron/scheduler/mesos/MesosScheduler.java | 31 +++--
.../scheduler/mesos/framework/BaseContainer.java | 31 +++--
.../scheduler/mesos/framework/LaunchableTask.java | 31 +++--
.../scheduler/mesos/framework/MesosFramework.java | 31 +++--
.../scheduler/mesos/framework/TaskResources.java | 31 +++--
.../heron/scheduler/mesos/framework/TaskUtils.java | 31 +++--
.../heron/scheduler/nomad/NomadConstants.java | 32 +++--
.../apache/heron/scheduler/nomad/NomadContext.java | 32 +++--
.../org/apache/heron/scheduler/nomad/NomadKey.java | 32 +++--
.../heron/scheduler/nomad/NomadLauncher.java | 32 +++--
.../heron/scheduler/nomad/NomadScheduler.java | 32 +++--
.../apache/heron/scheduler/slurm/SlurmContext.java | 31 +++--
.../heron/scheduler/slurm/SlurmController.java | 31 +++--
.../heron/scheduler/slurm/SlurmLauncher.java | 31 +++--
.../heron/scheduler/slurm/SlurmScheduler.java | 31 +++--
.../heron/scheduler/utils/HttpJsonClient.java | 31 +++--
.../scheduler/yarn/HeronClientConfiguration.java | 31 +++--
.../scheduler/yarn/HeronConfigurationOptions.java | 31 +++--
.../scheduler/yarn/HeronDriverConfiguration.java | 31 +++--
.../heron/scheduler/yarn/HeronExecutorTask.java | 31 +++--
.../heron/scheduler/yarn/HeronMasterDriver.java | 31 +++--
.../scheduler/yarn/HeronMasterDriverProvider.java | 31 +++--
.../heron/scheduler/yarn/HeronReefUtils.java | 31 +++--
.../scheduler/yarn/HeronTaskConfiguration.java | 31 +++--
.../scheduler/yarn/ReefClientSideHandlers.java | 31 +++--
.../apache/heron/scheduler/yarn/YarnContext.java | 31 +++--
.../org/apache/heron/scheduler/yarn/YarnKey.java | 31 +++--
.../apache/heron/scheduler/yarn/YarnLauncher.java | 31 +++--
.../apache/heron/scheduler/yarn/YarnScheduler.java | 31 +++--
.../scheduler/aurora/AuroraCLIControllerTest.java | 31 +++--
.../heron/scheduler/aurora/AuroraContextTest.java | 32 +++--
.../heron/scheduler/aurora/AuroraLauncherTest.java | 31 +++--
.../scheduler/aurora/AuroraSchedulerTest.java | 31 +++--
.../kubernetes/KubernetesControllerTest.java | 31 +++--
.../kubernetes/KubernetesLauncherTest.java | 31 +++--
.../kubernetes/KubernetesSchedulerTest.java | 31 +++--
.../heron/scheduler/kubernetes/VolumesTests.java | 32 +++--
.../heron/scheduler/local/LocalLauncherTest.java | 31 +++--
.../heron/scheduler/local/LocalSchedulerTest.java | 31 +++--
.../scheduler/marathon/MarathonControllerTest.java | 31 +++--
.../scheduler/marathon/MarathonLauncherTest.java | 31 +++--
.../scheduler/marathon/MarathonSchedulerTest.java | 31 +++--
.../heron/scheduler/mesos/MesosLauncherTest.java | 31 +++--
.../heron/scheduler/mesos/MesosSchedulerTest.java | 31 +++--
.../mesos/framework/LaunchableTaskTest.java | 31 +++--
.../mesos/framework/MesosFrameworkTest.java | 31 +++--
.../mesos/framework/TaskResourcesTest.java | 31 +++--
.../scheduler/mesos/framework/TaskUtilsTest.java | 31 +++--
.../heron/scheduler/nomad/NomadSchedulerTest.java | 32 +++--
.../heron/scheduler/slurm/SlurmControllerTest.java | 31 +++--
.../heron/scheduler/slurm/SlurmLauncherTest.java | 31 +++--
.../heron/scheduler/slurm/SlurmSchedulerTest.java | 31 +++--
.../scheduler/yarn/HeronExecutorTaskTest.java | 31 +++--
.../scheduler/yarn/HeronMasterDriverTest.java | 31 +++--
.../heron/scheduler/yarn/YarnLauncherTest.java | 31 +++--
.../heron/scheduler/yarn/YarnSchedulerTest.java | 31 +++--
.../java/org/apache/heron/simulator/Simulator.java | 31 +++--
.../simulator/executors/InstanceExecutor.java | 31 +++--
.../heron/simulator/executors/MetricsExecutor.java | 31 +++--
.../heron/simulator/executors/StreamExecutor.java | 31 +++--
.../heron/simulator/grouping/AllGrouping.java | 31 +++--
.../heron/simulator/grouping/CustomGrouping.java | 31 +++--
.../heron/simulator/grouping/FieldsGrouping.java | 31 +++--
.../apache/heron/simulator/grouping/Grouping.java | 31 +++--
.../heron/simulator/grouping/LowestGrouping.java | 31 +++--
.../heron/simulator/grouping/ShuffleGrouping.java | 31 +++--
.../heron/simulator/instance/BoltInstance.java | 31 +++--
.../heron/simulator/instance/RootTupleInfo.java | 31 +++--
.../heron/simulator/instance/SpoutInstance.java | 31 +++--
.../apache/heron/simulator/utils/RotatingMap.java | 31 +++--
.../heron/simulator/utils/TopologyManager.java | 31 +++--
.../apache/heron/simulator/utils/TupleCache.java | 31 +++--
.../apache/heron/simulator/utils/XORManager.java | 31 +++--
.../org/apache/heron/simulator/SimulatorTest.java | 31 +++--
.../simulator/executors/InstanceExecutorTest.java | 31 +++--
.../heron/simulator/grouping/AllGroupingTest.java | 31 +++--
.../simulator/grouping/CustomGroupingTest.java | 31 +++--
.../simulator/grouping/FieldsGroupingTest.java | 31 +++--
.../simulator/grouping/LowestGroupingTest.java | 31 +++--
.../simulator/grouping/ShuffleGroupingTest.java | 31 +++--
.../heron/simulator/utils/RotatingMapTest.java | 31 +++--
.../heron/simulator/utils/TopologyManagerTest.java | 31 +++--
.../heron/simulator/utils/TupleCacheTest.java | 31 +++--
.../heron/simulator/utils/XORManagerTest.java | 31 +++--
.../java/org/apache/heron/spi/common/Config.java | 31 +++--
.../org/apache/heron/spi/common/ConfigLoader.java | 31 +++--
.../java/org/apache/heron/spi/common/Context.java | 31 +++--
.../src/java/org/apache/heron/spi/common/Key.java | 32 +++--
.../java/org/apache/heron/spi/common/TokenSub.java | 31 +++--
.../spi/metricsmgr/metrics/ExceptionInfo.java | 31 +++--
.../spi/metricsmgr/metrics/MetricsFilter.java | 31 +++--
.../heron/spi/metricsmgr/metrics/MetricsInfo.java | 31 +++--
.../spi/metricsmgr/metrics/MetricsRecord.java | 31 +++--
.../heron/spi/metricsmgr/sink/IMetricsSink.java | 31 +++--
.../heron/spi/metricsmgr/sink/SinkContext.java | 31 +++--
.../org/apache/heron/spi/packing/IPacking.java | 31 +++--
.../org/apache/heron/spi/packing/IRepacking.java | 32 +++--
.../org/apache/heron/spi/packing/InstanceId.java | 32 +++--
.../apache/heron/spi/packing/PackingException.java | 32 +++--
.../org/apache/heron/spi/packing/PackingPlan.java | 31 +++--
.../spi/packing/PackingPlanProtoDeserializer.java | 32 +++--
.../spi/packing/PackingPlanProtoSerializer.java | 32 +++--
.../org/apache/heron/spi/packing/Resource.java | 31 +++--
.../org/apache/heron/spi/scheduler/ILauncher.java | 31 +++--
.../org/apache/heron/spi/scheduler/IScalable.java | 32 +++--
.../org/apache/heron/spi/scheduler/IScheduler.java | 31 +++--
.../heron/spi/scheduler/LauncherException.java | 32 +++--
.../heron/spi/scheduler/SchedulerException.java | 31 +++--
.../heron/spi/statefulstorage/Checkpoint.java | 31 +++--
.../spi/statefulstorage/IStatefulStorage.java | 31 +++--
.../statefulstorage/StatefulStorageException.java | 31 +++--
.../apache/heron/spi/statemgr/IStateManager.java | 31 +++--
.../java/org/apache/heron/spi/statemgr/Lock.java | 32 +++--
.../spi/statemgr/SchedulerStateManagerAdaptor.java | 31 +++--
.../apache/heron/spi/statemgr/WatchCallback.java | 31 +++--
.../org/apache/heron/spi/uploader/IUploader.java | 31 +++--
.../heron/spi/uploader/UploaderException.java | 32 +++--
.../org/apache/heron/spi/utils/NetworkUtils.java | 31 +++--
.../apache/heron/spi/utils/PackingTestUtils.java | 32 +++--
.../apache/heron/spi/utils/ReflectionUtils.java | 31 +++--
.../org/apache/heron/spi/utils/ShellUtils.java | 31 +++--
.../apache/heron/spi/utils/TMasterException.java | 31 +++--
.../org/apache/heron/spi/utils/TMasterUtils.java | 31 +++--
.../org/apache/heron/spi/utils/UploaderUtils.java | 31 +++--
.../apache/heron/spi/common/ConfigLoaderTest.java | 31 +++--
.../org/apache/heron/spi/common/ConfigTest.java | 32 +++--
.../org/apache/heron/spi/common/ContextTest.java | 31 +++--
.../java/org/apache/heron/spi/common/KeysTest.java | 31 +++--
.../org/apache/heron/spi/common/TokenSubTest.java | 31 +++--
.../spi/metricsmgr/metrics/ExceptionInfoTest.java | 31 +++--
.../spi/metricsmgr/metrics/MetricsInfoTest.java | 31 +++--
.../spi/metricsmgr/metrics/MetricsRecordTest.java | 31 +++--
.../apache/heron/spi/packing/PackingPlanTest.java | 31 +++--
.../org/apache/heron/spi/packing/ResourceTest.java | 31 +++--
.../apache/heron/spi/utils/NetworkUtilsTest.java | 31 +++--
.../org/apache/heron/spi/utils/ShellUtilsTest.java | 31 +++--
.../apache/heron/spi/utils/UploaderUtilsTest.java | 31 +++--
.../heron/statefulstorage/dlog/DlogStorage.java | 32 +++--
.../heron/statefulstorage/hdfs/HDFSStorage.java | 31 +++--
.../localfs/LocalFileSystemStorage.java | 31 +++--
.../StatefulStorageTestContext.java | 31 +++--
.../statefulstorage/dlog/DlogStorageTest.java | 32 +++--
.../statefulstorage/hdfs/HDFSStorageTest.java | 31 +++--
.../localfs/LocalFileSystemStorageTest.java | 31 +++--
.../src/cpp/statemgr/heron-localfilestatemgr.cpp | 25 ++--
.../src/cpp/statemgr/heron-localfilestatemgr.h | 25 ++--
.../statemgrs/src/cpp/statemgr/heron-statemgr.cpp | 25 ++--
heron/statemgrs/src/cpp/statemgr/heron-statemgr.h | 25 ++--
.../src/cpp/statemgr/heron-zkstatemgr.cpp | 25 ++--
.../statemgrs/src/cpp/statemgr/heron-zkstatemgr.h | 25 ++--
.../heron/statemgr/FileSystemStateManager.java | 31 +++--
.../apache/heron/statemgr/NullStateManager.java | 31 +++--
.../statemgr/localfs/LocalFileSystemContext.java | 31 +++--
.../heron/statemgr/localfs/LocalFileSystemKey.java | 32 +++--
.../localfs/LocalFileSystemStateManager.java | 31 +++--
.../apache/heron/statemgr/zookeeper/ZkContext.java | 31 +++--
.../apache/heron/statemgr/zookeeper/ZkUtils.java | 31 +++--
.../statemgr/zookeeper/ZkWatcherCallback.java | 31 +++--
.../zookeeper/curator/CuratorStateManager.java | 31 +++--
heron/statemgrs/tests/cpp/statetest.cpp | 25 ++--
heron/statemgrs/tests/cpp/zkstatemgr_unittest.cpp | 25 ++--
.../localfs/LocalFileSystemStateManagerTest.java | 31 +++--
.../heron/statemgr/zookeeper/ZkUtilsTest.java | 31 +++--
.../zookeeper/curator/CuratorStateManagerTest.java | 31 +++--
heron/stmgr/src/cpp/grouping/all-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/all-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/custom-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/custom-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/direct-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/direct-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/fields-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/fields-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/lowest-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/lowest-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/shuffle-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/shuffle-grouping.h | 25 ++--
heron/stmgr/src/cpp/manager/checkpoint-gateway.cpp | 25 ++--
heron/stmgr/src/cpp/manager/checkpoint-gateway.h | 25 ++--
heron/stmgr/src/cpp/manager/ckptmgr-client.cpp | 25 ++--
heron/stmgr/src/cpp/manager/ckptmgr-client.h | 25 ++--
heron/stmgr/src/cpp/manager/instance-server.cpp | 25 ++--
heron/stmgr/src/cpp/manager/instance-server.h | 25 ++--
heron/stmgr/src/cpp/manager/stateful-restorer.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stateful-restorer.h | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-client.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-client.h | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-clientmgr.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-clientmgr.h | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-server.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-server.h | 25 ++--
heron/stmgr/src/cpp/manager/stmgr.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stmgr.h | 25 ++--
heron/stmgr/src/cpp/manager/stream-consumers.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stream-consumers.h | 25 ++--
heron/stmgr/src/cpp/manager/tmaster-client.cpp | 25 ++--
heron/stmgr/src/cpp/manager/tmaster-client.h | 25 ++--
heron/stmgr/src/cpp/server/stmgr-main.cpp | 25 ++--
heron/stmgr/src/cpp/util/neighbour-calculator.cpp | 25 ++--
heron/stmgr/src/cpp/util/neighbour-calculator.h | 25 ++--
heron/stmgr/src/cpp/util/rotating-map.cpp | 25 ++--
heron/stmgr/src/cpp/util/rotating-map.h | 25 ++--
heron/stmgr/src/cpp/util/tuple-cache.cpp | 25 ++--
heron/stmgr/src/cpp/util/tuple-cache.h | 25 ++--
heron/stmgr/src/cpp/util/xor-manager.cpp | 25 ++--
heron/stmgr/src/cpp/util/xor-manager.h | 25 ++--
.../tests/cpp/grouping/all-grouping_unittest.cpp | 25 ++--
.../cpp/grouping/custom-grouping_unittest.cpp | 25 ++--
.../cpp/grouping/fields-grouping_unittest.cpp | 25 ++--
.../cpp/grouping/lowest-grouping_unittest.cpp | 25 ++--
.../cpp/grouping/shuffle-grouping_unittest.cpp | 25 ++--
.../cpp/server/checkpoint-gateway_unittest.cpp | 25 ++--
.../tests/cpp/server/dummy_ckptmgr_client.cpp | 25 ++--
.../stmgr/tests/cpp/server/dummy_ckptmgr_client.h | 25 ++--
heron/stmgr/tests/cpp/server/dummy_instance.cpp | 25 ++--
heron/stmgr/tests/cpp/server/dummy_instance.h | 25 ++--
.../stmgr/tests/cpp/server/dummy_instance_server.h | 25 ++--
heron/stmgr/tests/cpp/server/dummy_metricsmgr.cpp | 25 ++--
heron/stmgr/tests/cpp/server/dummy_metricsmgr.h | 25 ++--
heron/stmgr/tests/cpp/server/dummy_stmgr.cpp | 25 ++--
heron/stmgr/tests/cpp/server/dummy_stmgr.h | 25 ++--
.../stmgr/tests/cpp/server/dummy_stmgr_clientmgr.h | 25 ++--
heron/stmgr/tests/cpp/server/dummy_tuple_cache.h | 25 ++--
.../cpp/server/stateful-restorer_unittest.cpp | 25 ++--
heron/stmgr/tests/cpp/server/stmgr_unittest.cpp | 25 ++--
.../cpp/util/neighbour_calculator_unittest.cpp | 25 ++--
.../stmgr/tests/cpp/util/rotating-map_unittest.cpp | 25 ++--
.../stmgr/tests/cpp/util/tuple-cache_unittest.cpp | 25 ++--
.../stmgr/tests/cpp/util/xor-manager_unittest.cpp | 25 ++--
heron/tmaster/src/cpp/manager/ckptmgr-client.cpp | 25 ++--
heron/tmaster/src/cpp/manager/ckptmgr-client.h | 25 ++--
.../src/cpp/manager/stateful-checkpointer.cpp | 25 ++--
.../src/cpp/manager/stateful-checkpointer.h | 25 ++--
.../src/cpp/manager/stateful-controller.cpp | 25 ++--
.../tmaster/src/cpp/manager/stateful-controller.h | 25 ++--
.../tmaster/src/cpp/manager/stateful-restorer.cpp | 25 ++--
heron/tmaster/src/cpp/manager/stateful-restorer.h | 25 ++--
heron/tmaster/src/cpp/manager/stats-interface.cpp | 25 ++--
heron/tmaster/src/cpp/manager/stats-interface.h | 25 ++--
heron/tmaster/src/cpp/manager/stmgrstate.cpp | 25 ++--
heron/tmaster/src/cpp/manager/stmgrstate.h | 25 ++--
heron/tmaster/src/cpp/manager/tcontroller.cpp | 25 ++--
heron/tmaster/src/cpp/manager/tcontroller.h | 25 ++--
heron/tmaster/src/cpp/manager/tmaster.cpp | 25 ++--
heron/tmaster/src/cpp/manager/tmaster.h | 25 ++--
heron/tmaster/src/cpp/manager/tmasterserver.cpp | 25 ++--
heron/tmaster/src/cpp/manager/tmasterserver.h | 25 ++--
.../tmaster/src/cpp/manager/tmetrics-collector.cpp | 25 ++--
heron/tmaster/src/cpp/manager/tmetrics-collector.h | 25 ++--
heron/tmaster/src/cpp/processor/processor.h | 25 ++--
.../cpp/processor/stmgr-heartbeat-processor.cpp | 25 ++--
.../src/cpp/processor/stmgr-heartbeat-processor.h | 25 ++--
.../src/cpp/processor/stmgr-register-processor.cpp | 25 ++--
.../src/cpp/processor/stmgr-register-processor.h | 25 ++--
.../src/cpp/processor/tmaster-processor.cpp | 25 ++--
.../tmaster/src/cpp/processor/tmaster-processor.h | 25 ++--
heron/tmaster/src/cpp/server/tmaster-main.cpp | 25 ++--
heron/tmaster/tests/cpp/server/dummystmgr.cpp | 25 ++--
heron/tmaster/tests/cpp/server/dummystmgr.h | 25 ++--
heron/tmaster/tests/cpp/server/dummytmaster.cpp | 25 ++--
heron/tmaster/tests/cpp/server/dummytmaster.h | 25 ++--
.../cpp/server/stateful_checkpointer_unittest.cpp | 25 ++--
.../cpp/server/stateful_restorer_unittest.cpp | 25 ++--
.../tests/cpp/server/tcontroller_unittest.cpp | 25 ++--
.../tmaster/tests/cpp/server/tmaster_unittest.cpp | 25 ++--
.../java/org/apache/heron/apiserver/Constants.java | 32 +++--
.../java/org/apache/heron/apiserver/Resources.java | 32 +++--
.../java/org/apache/heron/apiserver/Runtime.java | 32 +++--
.../org/apache/heron/apiserver/actions/Action.java | 32 +++--
.../heron/apiserver/actions/ActionFactory.java | 32 +++--
.../heron/apiserver/actions/ActionFactoryImpl.java | 32 +++--
.../apache/heron/apiserver/actions/ActionType.java | 32 +++--
.../org/apache/heron/apiserver/actions/Keys.java | 32 +++--
.../apiserver/actions/SubmitTopologyAction.java | 32 +++--
.../apiserver/actions/TopologyRuntimeAction.java | 32 +++--
.../apiserver/resources/ConfigurationResource.java | 32 +++--
.../heron/apiserver/resources/FileResource.java | 32 +++--
.../apache/heron/apiserver/resources/Forms.java | 32 +++--
.../heron/apiserver/resources/HeronResource.java | 32 +++--
.../resources/NotFoundExceptionHandler.java | 32 +++--
.../apiserver/resources/TopologyResource.java | 32 +++--
.../apache/heron/apiserver/utils/ConfigUtils.java | 32 +++--
.../apache/heron/apiserver/utils/FileHelper.java | 32 +++--
.../org/apache/heron/apiserver/utils/Logging.java | 32 +++--
.../org/apache/heron/apiserver/utils/Utils.java | 32 +++--
.../apiserver/resources/TopologyResourceTests.java | 32 +++--
.../heron/apiserver/utils/ConfigUtilsTests.java | 32 +++--
.../org/apache/heron/uploader/NullUploader.java | 31 +++--
.../org/apache/heron/uploader/dlog/Copier.java | 32 +++--
.../org/apache/heron/uploader/dlog/DLContext.java | 32 +++--
.../org/apache/heron/uploader/dlog/DLCopier.java | 32 +++--
.../org/apache/heron/uploader/dlog/DLUploader.java | 32 +++--
.../org/apache/heron/uploader/gcs/GcsContext.java | 32 +++--
.../apache/heron/uploader/gcs/GcsController.java | 32 +++--
.../org/apache/heron/uploader/gcs/GcsUploader.java | 32 +++--
.../apache/heron/uploader/hdfs/HdfsContext.java | 31 +++--
.../apache/heron/uploader/hdfs/HdfsController.java | 31 +++--
.../apache/heron/uploader/hdfs/HdfsUploader.java | 31 +++--
.../apache/heron/uploader/http/HttpUploader.java | 32 +++--
.../heron/uploader/http/HttpUploaderContext.java | 32 +++--
.../uploader/localfs/LocalFileSystemContext.java | 31 +++--
.../heron/uploader/localfs/LocalFileSystemKey.java | 32 +++--
.../uploader/localfs/LocalFileSystemUploader.java | 31 +++--
.../org/apache/heron/uploader/s3/S3Context.java | 31 +++--
.../org/apache/heron/uploader/s3/S3Uploader.java | 31 +++--
.../org/apache/heron/uploader/scp/ScpContext.java | 31 +++--
.../apache/heron/uploader/scp/ScpController.java | 31 +++--
.../org/apache/heron/uploader/scp/ScpUploader.java | 31 +++--
.../heron/uploader/dlog/DlogUploaderTest.java | 32 +++--
.../heron/uploader/gcs/GcsUploaderTests.java | 32 +++--
.../heron/uploader/hdfs/HdfsUploaderTest.java | 31 +++--
.../heron/uploader/http/HttpUploaderTest.java | 32 +++--
.../localfs/LocalFileSystemConfigTest.java | 31 +++--
.../localfs/LocalFileSystemConstantsTest.java | 31 +++--
.../localfs/LocalFileSystemContextTest.java | 32 +++--
.../localfs/LocalFileSystemUploaderTest.java | 31 +++--
.../apache/heron/uploader/s3/S3UploaderTest.java | 31 +++--
.../apache/heron/uploader/scp/ScpUploaderTest.java | 31 +++--
.../common/AbstractTestTopology.java | 32 +++--
.../heron/integration_test/common/BasicConfig.java | 32 +++--
.../heron/integration_test/common/HdfsHelper.java | 32 +++--
.../common/bolt/CountAggregatorBolt.java | 32 +++--
.../common/bolt/DoubleTuplesBolt.java | 32 +++--
.../integration_test/common/bolt/IdentityBolt.java | 32 +++--
.../common/bolt/IncrementBolt.java | 32 +++--
.../common/bolt/JSONTweetFilterBolt.java | 32 +++--
.../common/bolt/LocalWriteBolt.java | 32 +++--
.../common/bolt/MapAggregatorBolt.java | 32 +++--
.../common/bolt/PartialUniquerBolt.java | 32 +++--
.../common/bolt/TweetPropertyBolt.java | 32 +++--
.../common/bolt/WordCountBolt.java | 32 +++--
.../integration_test/common/spout/ABSpout.java | 32 +++--
.../common/spout/HdfsStringSpout.java | 32 +++--
.../common/spout/LocalFileSpout.java | 32 +++--
.../common/spout/PausedLocalFileSpout.java | 32 +++--
.../integration_test/core/AggregatorBolt.java | 32 +++--
.../heron/integration_test/core/BaseBatchBolt.java | 32 +++--
.../heron/integration_test/core/Condition.java | 32 +++--
.../heron/integration_test/core/Constants.java | 32 +++--
.../core/EmitUntilConditionTestSpout.java | 32 +++--
.../integration_test/core/HttpGetCondition.java | 32 +++--
.../heron/integration_test/core/HttpUtils.java | 32 +++--
.../heron/integration_test/core/IBatchBolt.java | 32 +++--
.../heron/integration_test/core/ITerminalBolt.java | 32 +++--
.../integration_test/core/IntegrationTestBolt.java | 32 +++--
.../core/IntegrationTestSpout.java | 32 +++--
.../integration_test/core/LocalAggregatorBolt.java | 32 +++--
.../integration_test/core/MultiPhaseTestSpout.java | 32 +++--
.../core/StatefulIntegrationTestBolt.java | 31 +++--
.../core/StatefulIntegrationTestSpout.java | 32 +++--
.../integration_test/core/TestTopologyBuilder.java | 32 +++--
.../integration_test/core/TestTopologyContext.java | 32 +++--
.../topology/all_grouping/AllGrouping.java | 32 +++--
.../BasicTopologyOneTask.java | 32 +++--
.../BoltDoubleEmitTuples.java | 32 +++--
.../topology/fields_grouping/FieldsGrouping.java | 32 +++--
.../topology/global_grouping/GlobalGrouping.java | 32 +++--
.../MultiSpoutsMultiTasks.java | 32 +++--
.../topology/non_grouping/NonGrouping.java | 32 +++--
.../one_bolt_multi_tasks/OneBoltMultiTasks.java | 32 +++--
.../OneSpoutBoltMultiTasks.java | 32 +++--
.../one_spout_multi_tasks/OneSpoutMultiTasks.java | 32 +++--
.../one_spout_two_bolts/OneSpoutTwoBolts.java | 32 +++--
.../topology/serialization/CustomCheckBolt.java | 32 +++--
.../topology/serialization/CustomObject.java | 32 +++--
.../topology/serialization/CustomSpout.java | 32 +++--
.../serialization/SerializationTopology.java | 32 +++--
.../topology/shuffle_grouping/ShuffleGrouping.java | 32 +++--
.../topology/windowing/WindowTestBase.java | 32 +++--
.../windowing/count/SlidingCountWindowTest1.java | 32 +++--
.../windowing/count/SlidingCountWindowTest2.java | 32 +++--
.../windowing/count/SlidingCountWindowTest3.java | 32 +++--
.../windowing/count/TumblingCountWindowTest1.java | 32 +++--
.../windowing/count/TumblingCountWindowTest2.java | 32 +++--
.../windowing/count/TumblingCountWindowTest3.java | 32 +++--
.../windowing/stateful/StatefulWindowingTest.java | 31 +++--
.../windowing/time/SlidingTimeWindowTest1.java | 32 +++--
.../SlidingWatermarkEventTimeWindowTest1.java | 32 +++--
.../local_readwrite/LocalReadWriteTopology.java | 32 +++--
third_party/java/bazel/Empty.java | 31 +++--
.../org/apache/bazel/checkstyle/CppCheckstyle.java | 32 +++--
.../apache/bazel/checkstyle/ExtraActionUtils.java | 32 +++--
.../apache/bazel/checkstyle/JavaCheckstyle.java | 32 +++--
.../apache/bazel/checkstyle/PythonCheckstyle.java | 32 +++--
.../org/apache/bazel/checkstyle/heron_header.txt | 31 +++--
1241 files changed, 20012 insertions(+), 16385 deletions(-)
--
To stop receiving notification emails like this one, please contact
karthikz@apache.org.
[incubator-heron] 01/01: Merge branch 'master' into karthik/scribe
Posted by ka...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
karthikz pushed a commit to branch karthik/scribe
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git
commit abcd160d23650576025ac19257f29c6db88b612a
Merge: 2c69caa 1e7e35a
Author: Karthik Ramasamy <ka...@streaml.io>
AuthorDate: Wed May 2 23:01:32 2018 -0700
Merge branch 'master' into karthik/scribe
NOTICE | 8 +-
.../apache/heron/examples/eco/EvenAndOddBolt.java | 32 +++--
.../org/apache/heron/examples/eco/LogInfoBolt.java | 32 +++--
.../apache/heron/examples/eco/RandomString.java | 32 +++--
.../heron/examples/eco/StatefulConsumerBolt.java | 32 +++--
.../heron/examples/eco/StatefulNumberSpout.java | 32 +++--
.../heron/examples/eco/StatefulRandomIntSpout.java | 32 +++--
.../heron/examples/eco/StatefulWindowSumBolt.java | 32 +++--
.../heron/examples/eco/TestFibonacciSpout.java | 32 +++--
.../heron/examples/eco/TestIBasicPrintBolt.java | 32 +++--
.../apache/heron/examples/eco/TestNameCounter.java | 32 +++--
.../apache/heron/examples/eco/TestNameSpout.java | 32 +++--
.../apache/heron/examples/eco/TestPrintBolt.java | 32 +++--
.../heron/examples/eco/TestPropertyHolder.java | 32 +++--
.../org/apache/heron/examples/eco/TestUnits.java | 32 +++--
.../apache/heron/examples/eco/TestWindowBolt.java | 32 +++--
.../org/apache/heron/examples/eco/WordSpout.java | 32 +++--
.../apache/heron/examples/eco/EvenAndOddBolt.java | 32 +++--
.../org/apache/heron/examples/eco/LogInfoBolt.java | 32 +++--
.../heron/examples/eco/TestFibonacciSpout.java | 32 +++--
.../heron/examples/eco/TestIBasicPrintBolt.java | 32 +++--
.../apache/heron/examples/eco/TestNameCounter.java | 32 +++--
.../apache/heron/examples/eco/TestNameSpout.java | 32 +++--
.../apache/heron/examples/eco/TestPrintBolt.java | 32 +++--
.../heron/examples/eco/TestPropertyHolder.java | 32 +++--
.../org/apache/heron/examples/eco/TestUnits.java | 32 +++--
.../apache/heron/examples/eco/TestWindowBolt.java | 32 +++--
eco/src/java/org/apache/heron/eco/Eco.java | 32 +++--
.../org/apache/heron/eco/builder/BoltBuilder.java | 32 +++--
.../apache/heron/eco/builder/BuilderUtility.java | 32 +++--
.../apache/heron/eco/builder/ComponentBuilder.java | 32 +++--
.../apache/heron/eco/builder/ConfigBuilder.java | 32 +++--
.../apache/heron/eco/builder/ObjectBuilder.java | 32 +++--
.../apache/heron/eco/builder/heron/EcoBuilder.java | 32 +++--
.../heron/eco/builder/heron/SpoutBuilder.java | 32 +++--
.../heron/eco/builder/heron/StreamBuilder.java | 32 +++--
.../apache/heron/eco/builder/storm/EcoBuilder.java | 32 +++--
.../heron/eco/builder/storm/SpoutBuilder.java | 32 +++--
.../heron/eco/builder/storm/StreamBuilder.java | 32 +++--
.../heron/eco/definition/BeanDefinition.java | 32 +++--
.../heron/eco/definition/BeanListReference.java | 32 +++--
.../apache/heron/eco/definition/BeanReference.java | 32 +++--
.../heron/eco/definition/BoltDefinition.java | 32 +++--
.../heron/eco/definition/ComponentStream.java | 32 +++--
.../definition/ConfigurationMethodDefinition.java | 32 +++--
.../heron/eco/definition/EcoExecutionContext.java | 32 +++--
.../eco/definition/EcoTopologyDefinition.java | 32 +++--
.../heron/eco/definition/GroupingDefinition.java | 32 +++--
.../heron/eco/definition/ObjectDefinition.java | 32 +++--
.../heron/eco/definition/PropertyDefinition.java | 32 +++--
.../heron/eco/definition/SpoutDefinition.java | 32 +++--
.../heron/eco/definition/StreamDefinition.java | 32 +++--
.../org/apache/heron/eco/parser/EcoParser.java | 32 +++--
.../org/apache/heron/eco/submit/EcoSubmitter.java | 32 +++--
eco/tests/java/org/apache/heron/eco/EcoTest.java | 32 +++--
.../apache/heron/eco/builder/BoltBuilderTest.java | 32 +++--
.../heron/eco/builder/BuilderUtilityTest.java | 32 +++--
.../heron/eco/builder/ComponentBuilderTest.java | 32 +++--
.../heron/eco/builder/ConfigBuilderTest.java | 32 +++--
.../heron/eco/builder/ObjectBuilderTest.java | 32 +++--
.../eco/builder/heron/HeronEcoBuilderTest.java | 32 +++--
.../eco/builder/heron/HeronSpoutBuilderTest.java | 32 +++--
.../eco/builder/heron/HeronStreamBuilderTest.java | 32 +++--
.../eco/builder/storm/StormEcoBuilderTest.java | 32 +++--
.../eco/builder/storm/StormSpoutBuilderTest.java | 32 +++--
.../eco/builder/storm/StormStreamBuilderTest.java | 32 +++--
.../org/apache/heron/eco/parser/EcoParserTest.java | 139 +++------------------
.../apache/heron/eco/submit/EcoSubmitterTest.java | 32 +++--
examples/src/cpp/ackfail/ackfail-topology.cpp | 25 ++--
.../src/cpp/exclamation/exclamation-topology.cpp | 25 ++--
examples/src/cpp/spouts/test-word-spout.h | 25 ++--
.../apache/heron/examples/api/AckingTopology.java | 32 +++--
.../examples/api/ComponentJVMOptionsTopology.java | 32 +++--
.../heron/examples/api/CustomGroupingTopology.java | 32 +++--
.../heron/examples/api/ExampleResources.java | 32 +++--
.../heron/examples/api/ExclamationTopology.java | 32 +++--
.../api/MultiSpoutExclamationTopology.java | 32 +++--
.../examples/api/MultiStageAckingTopology.java | 32 +++--
.../examples/api/SentenceWordCountTopology.java | 32 +++--
.../heron/examples/api/SlidingWindowTopology.java | 32 +++--
.../api/StatefulSlidingWindowTopology.java | 32 +++--
.../examples/api/StatefulWordCountTopology.java | 32 +++--
.../heron/examples/api/TaskHookTopology.java | 32 +++--
.../examples/api/WindowedWordCountTopology.java | 32 +++--
.../heron/examples/api/WordCountTopology.java | 32 +++--
.../heron/examples/api/bolt/PrinterBolt.java | 32 +++--
.../examples/api/bolt/SlidingWindowSumBolt.java | 32 +++--
.../examples/api/spout/RandomIntegerSpout.java | 32 +++--
.../heron/examples/api/spout/TestWordSpout.java | 32 +++--
.../examples/streamlet/FilesystemSinkTopology.java | 32 +++--
.../streamlet/FormattedOutputTopology.java | 32 +++--
.../streamlet/ImpressionsAndClicksTopology.java | 32 +++--
.../streamlet/IntegerProcessingTopology.java | 32 +++--
.../examples/streamlet/RepartitionTopology.java | 32 +++--
.../streamlet/SimplePulsarSourceTopology.java | 32 +++--
.../examples/streamlet/SmartWatchTopology.java | 32 +++--
.../examples/streamlet/StreamletCloneTopology.java | 32 +++--
.../examples/streamlet/TransformsTopology.java | 32 +++--
.../streamlet/WindowedWordCountTopology.java | 32 +++--
.../examples/streamlet/WireRequestsTopology.java | 32 +++--
.../examples/streamlet/utils/StreamletUtils.java | 32 +++--
heron/api/src/cpp/bolt/base-basic-bolt.h | 25 ++--
heron/api/src/cpp/bolt/base-rich-bolt.h | 25 ++--
heron/api/src/cpp/bolt/basic-bolt-collector.h | 25 ++--
heron/api/src/cpp/bolt/ibasic-bolt.h | 25 ++--
heron/api/src/cpp/bolt/ibolt-output-collector.h | 25 ++--
heron/api/src/cpp/bolt/ibolt.h | 25 ++--
heron/api/src/cpp/bolt/irich-bolt.h | 25 ++--
heron/api/src/cpp/config/config.cpp | 25 ++--
heron/api/src/cpp/config/config.h | 25 ++--
.../src/cpp/exceptions/already-alive-exception.h | 25 ++--
.../cpp/exceptions/invalid-topology-exception.h | 25 ++--
.../src/cpp/exceptions/serialization-exception.h | 25 ++--
heron/api/src/cpp/metric/assignable-metric.h | 25 ++--
heron/api/src/cpp/metric/count-metric.h | 25 ++--
heron/api/src/cpp/metric/imetric.h | 25 ++--
heron/api/src/cpp/metric/imetrics-registrar.h | 25 ++--
heron/api/src/cpp/metric/imulti-metric.h | 25 ++--
heron/api/src/cpp/metric/mean-metric.h | 25 ++--
heron/api/src/cpp/metric/multi-count-metric.h | 25 ++--
heron/api/src/cpp/metric/multi-mean-metric.h | 25 ++--
heron/api/src/cpp/serializer/cereal-serializer.h | 25 ++--
.../src/cpp/serializer/ipluggable-serializer.cpp | 25 ++--
.../api/src/cpp/serializer/ipluggable-serializer.h | 25 ++--
heron/api/src/cpp/serializer/string-serializer.h | 25 ++--
.../src/cpp/serializer/tuple-serializer-utils.h | 25 ++--
heron/api/src/cpp/spout/base-rich-spout.h | 25 ++--
heron/api/src/cpp/spout/irich-spout.h | 25 ++--
heron/api/src/cpp/spout/ispout-output-collector.h | 25 ++--
heron/api/src/cpp/spout/ispout.h | 25 ++--
.../api/src/cpp/topology/base-component-declarer.h | 25 ++--
heron/api/src/cpp/topology/bolt-declarer.h | 25 ++--
heron/api/src/cpp/topology/heron-submitter.h | 25 ++--
heron/api/src/cpp/topology/icomponent.h | 25 ++--
.../api/src/cpp/topology/output-fields-declarer.h | 25 ++--
heron/api/src/cpp/topology/output-fields-getter.h | 25 ++--
heron/api/src/cpp/topology/spout-declarer.h | 25 ++--
heron/api/src/cpp/topology/task-context.h | 25 ++--
heron/api/src/cpp/topology/topology-builder.h | 25 ++--
heron/api/src/cpp/topology/topology-context.h | 25 ++--
heron/api/src/cpp/tuple/fields.h | 25 ++--
heron/api/src/cpp/tuple/tuple.h | 25 ++--
heron/api/src/cpp/utils/utils.cpp | 25 ++--
heron/api/src/cpp/utils/utils.h | 25 ++--
.../api/src/java/org/apache/heron/api/Config.java | 28 ++---
.../src/java/org/apache/heron/api/Constants.java | 27 ++--
.../java/org/apache/heron/api/HeronSubmitter.java | 27 ++--
.../java/org/apache/heron/api/HeronTopology.java | 28 ++---
heron/api/src/java/org/apache/heron/api/Pair.java | 27 ++--
.../org/apache/heron/api/bolt/BaseBasicBolt.java | 28 ++---
.../org/apache/heron/api/bolt/BaseRichBolt.java | 28 ++---
.../heron/api/bolt/BaseStatefulWindowedBolt.java | 32 +++--
.../apache/heron/api/bolt/BaseWindowedBolt.java | 27 ++--
.../apache/heron/api/bolt/BasicBoltExecutor.java | 28 ++---
.../heron/api/bolt/BasicOutputCollector.java | 28 ++---
.../java/org/apache/heron/api/bolt/IBasicBolt.java | 28 ++---
.../heron/api/bolt/IBasicOutputCollector.java | 28 ++---
.../src/java/org/apache/heron/api/bolt/IBolt.java | 28 ++---
.../org/apache/heron/api/bolt/IErrorReporter.java | 28 ++---
.../apache/heron/api/bolt/IOutputCollector.java | 28 ++---
.../java/org/apache/heron/api/bolt/IRichBolt.java | 28 ++---
.../heron/api/bolt/IStatefulWindowedBolt.java | 31 +++--
.../org/apache/heron/api/bolt/IWindowedBolt.java | 27 ++--
.../org/apache/heron/api/bolt/OutputCollector.java | 28 ++---
.../api/bolt/StatefulWindowedBoltExecutor.java | 32 +++--
.../heron/api/bolt/WindowedBoltExecutor.java | 27 ++--
.../heron/api/exception/AlreadyAliveException.java | 28 ++---
.../heron/api/exception/FailedException.java | 28 ++---
.../api/exception/InvalidTopologyException.java | 28 ++---
.../api/exception/ReportedFailedException.java | 28 ++---
.../api/exception/TopologySubmissionException.java | 32 +++--
.../heron/api/grouping/CustomStreamGrouping.java | 28 ++---
.../org/apache/heron/api/hooks/BaseTaskHook.java | 28 ++---
.../java/org/apache/heron/api/hooks/ITaskHook.java | 28 ++---
.../apache/heron/api/hooks/info/BoltAckInfo.java | 28 ++---
.../heron/api/hooks/info/BoltExecuteInfo.java | 28 ++---
.../apache/heron/api/hooks/info/BoltFailInfo.java | 28 ++---
.../org/apache/heron/api/hooks/info/EmitInfo.java | 28 ++---
.../apache/heron/api/hooks/info/SpoutAckInfo.java | 28 ++---
.../apache/heron/api/hooks/info/SpoutFailInfo.java | 28 ++---
.../apache/heron/api/metric/AssignableMetric.java | 28 ++---
.../apache/heron/api/metric/CombinedMetric.java | 28 ++---
.../heron/api/metric/ConcurrentCountMetric.java | 28 ++---
.../org/apache/heron/api/metric/CountMetric.java | 28 ++---
.../heron/api/metric/CountStatAndMetric.java | 28 ++---
.../org/apache/heron/api/metric/GlobalMetrics.java | 28 ++---
.../org/apache/heron/api/metric/ICombiner.java | 28 ++---
.../java/org/apache/heron/api/metric/IMetric.java | 28 ++---
.../apache/heron/api/metric/IMetricsRegister.java | 28 ++---
.../java/org/apache/heron/api/metric/IReducer.java | 28 ++---
.../heron/api/metric/LatencyStatAndMetric.java | 27 ++--
.../org/apache/heron/api/metric/MeanReducer.java | 28 ++---
.../apache/heron/api/metric/MeanReducerState.java | 28 ++---
.../apache/heron/api/metric/MetricStatTimer.java | 28 ++---
.../heron/api/metric/MultiAssignableMetric.java | 28 ++---
.../apache/heron/api/metric/MultiCountMetric.java | 28 ++---
.../heron/api/metric/MultiReducedMetric.java | 28 ++---
.../org/apache/heron/api/metric/ReducedMetric.java | 28 ++---
.../heron/api/serializer/IPluggableSerializer.java | 28 ++---
.../heron/api/serializer/JavaSerializer.java | 28 ++---
.../org/apache/heron/api/spout/BaseRichSpout.java | 28 ++---
.../heron/api/spout/IMultiSchemableSpout.java | 28 ++---
.../org/apache/heron/api/spout/IRichSpout.java | 28 ++---
.../apache/heron/api/spout/ISchemableSpout.java | 28 ++---
.../java/org/apache/heron/api/spout/ISpout.java | 28 ++---
.../heron/api/spout/ISpoutOutputCollector.java | 28 ++---
.../org/apache/heron/api/spout/MultiScheme.java | 28 ++---
.../org/apache/heron/api/spout/RawMultiScheme.java | 28 ++---
.../java/org/apache/heron/api/spout/RawScheme.java | 28 ++---
.../java/org/apache/heron/api/spout/Scheme.java | 28 ++---
.../heron/api/spout/SchemeAsMultiScheme.java | 28 ++---
.../heron/api/spout/SpoutOutputCollector.java | 28 ++---
.../org/apache/heron/api/state/HashMapState.java | 28 ++---
.../src/java/org/apache/heron/api/state/State.java | 28 ++---
.../apache/heron/api/topology/BaseComponent.java | 28 ++---
.../heron/api/topology/BaseComponentDeclarer.java | 28 ++---
.../api/topology/BaseConfigurationDeclarer.java | 28 ++---
.../apache/heron/api/topology/BoltDeclarer.java | 28 ++---
.../topology/ComponentConfigurationDeclarer.java | 28 ++---
.../heron/api/topology/GeneralTopologyContext.java | 28 ++---
.../org/apache/heron/api/topology/IComponent.java | 28 ++---
.../heron/api/topology/IStatefulComponent.java | 28 ++---
.../org/apache/heron/api/topology/IUpdatable.java | 27 ++--
.../heron/api/topology/OutputFieldsDeclarer.java | 28 ++---
.../heron/api/topology/OutputFieldsGetter.java | 28 ++---
.../apache/heron/api/topology/SpoutDeclarer.java | 28 ++---
.../apache/heron/api/topology/TopologyBuilder.java | 28 ++---
.../apache/heron/api/topology/TopologyContext.java | 28 ++---
.../java/org/apache/heron/api/tuple/Fields.java | 28 ++---
.../src/java/org/apache/heron/api/tuple/Tuple.java | 28 ++---
.../java/org/apache/heron/api/tuple/Values.java | 28 ++---
.../api/utils/DefaultMaxSpoutPendingTuner.java | 28 ++---
.../org/apache/heron/api/utils/TopologyUtils.java | 32 +++--
.../org/apache/heron/api/utils/TupleUtils.java | 27 ++--
.../src/java/org/apache/heron/api/utils/Utils.java | 28 ++---
.../api/windowing/DefaultEvictionContext.java | 27 ++--
.../java/org/apache/heron/api/windowing/Event.java | 27 ++--
.../org/apache/heron/api/windowing/EventImpl.java | 27 ++--
.../heron/api/windowing/EvictionContext.java | 27 ++--
.../apache/heron/api/windowing/EvictionPolicy.java | 28 ++---
.../heron/api/windowing/TimestampExtractor.java | 27 ++--
.../apache/heron/api/windowing/TriggerHandler.java | 27 ++--
.../apache/heron/api/windowing/TriggerPolicy.java | 27 ++--
.../windowing/TupleFieldTimestampExtractor.java | 27 ++--
.../apache/heron/api/windowing/TupleWindow.java | 27 ++--
.../heron/api/windowing/TupleWindowImpl.java | 27 ++--
.../apache/heron/api/windowing/WaterMarkEvent.java | 27 ++--
.../api/windowing/WaterMarkEventGenerator.java | 28 ++---
.../org/apache/heron/api/windowing/Window.java | 27 ++--
.../api/windowing/WindowLifecycleListener.java | 27 ++--
.../apache/heron/api/windowing/WindowManager.java | 28 ++---
.../heron/api/windowing/WindowingConfigs.java | 27 ++--
.../windowing/evictors/CountEvictionPolicy.java | 27 ++--
.../api/windowing/evictors/TimeEvictionPolicy.java | 27 ++--
.../evictors/WatermarkCountEvictionPolicy.java | 27 ++--
.../evictors/WatermarkTimeEvictionPolicy.java | 27 ++--
.../triggers/AbstractBaseTriggerPolicy.java | 27 ++--
.../api/windowing/triggers/CountTriggerPolicy.java | 27 ++--
.../api/windowing/triggers/TimeTriggerPolicy.java | 27 ++--
.../triggers/WatermarkCountTriggerPolicy.java | 27 ++--
.../triggers/WatermarkTimeTriggerPolicy.java | 27 ++--
.../classification/HeronAnnotationProcessor.java | 32 +++--
.../heron/classification/InterfaceAudience.java | 32 +++--
.../heron/classification/InterfaceStability.java | 32 +++--
.../java/org/apache/heron/streamlet/Builder.java | 32 +++--
.../java/org/apache/heron/streamlet/Config.java | 32 +++--
.../java/org/apache/heron/streamlet/Context.java | 32 +++--
.../java/org/apache/heron/streamlet/JoinType.java | 32 +++--
.../java/org/apache/heron/streamlet/KeyValue.java | 31 +++--
.../org/apache/heron/streamlet/KeyedWindow.java | 32 +++--
.../java/org/apache/heron/streamlet/Runner.java | 32 +++--
.../heron/streamlet/SerializableBiFunction.java | 32 +++--
.../streamlet/SerializableBinaryOperator.java | 32 +++--
.../heron/streamlet/SerializableConsumer.java | 32 +++--
.../heron/streamlet/SerializableFunction.java | 32 +++--
.../heron/streamlet/SerializablePredicate.java | 32 +++--
.../heron/streamlet/SerializableSupplier.java | 32 +++--
.../heron/streamlet/SerializableTransformer.java | 32 +++--
.../src/java/org/apache/heron/streamlet/Sink.java | 32 +++--
.../java/org/apache/heron/streamlet/Source.java | 32 +++--
.../java/org/apache/heron/streamlet/Streamlet.java | 31 +++--
.../java/org/apache/heron/streamlet/Window.java | 32 +++--
.../org/apache/heron/streamlet/WindowConfig.java | 32 +++--
.../apache/heron/streamlet/impl/BuilderImpl.java | 32 +++--
.../apache/heron/streamlet/impl/ContextImpl.java | 32 +++--
.../heron/streamlet/impl/KryoSerializer.java | 32 +++--
.../apache/heron/streamlet/impl/StreamletImpl.java | 32 +++--
.../heron/streamlet/impl/WindowConfigImpl.java | 32 +++--
.../impl/groupings/JoinCustomGrouping.java | 32 +++--
.../ReduceByKeyAndWindowCustomGrouping.java | 32 +++--
.../impl/groupings/RemapCustomGrouping.java | 32 +++--
.../streamlet/impl/operators/FilterOperator.java | 32 +++--
.../streamlet/impl/operators/FlatMapOperator.java | 32 +++--
.../GeneralReduceByKeyAndWindowOperator.java | 32 +++--
.../streamlet/impl/operators/JoinOperator.java | 32 +++--
.../streamlet/impl/operators/MapOperator.java | 32 +++--
.../operators/ReduceByKeyAndWindowOperator.java | 32 +++--
.../impl/operators/StreamletOperator.java | 32 +++--
.../impl/operators/StreamletWindowOperator.java | 32 +++--
.../impl/operators/TransformOperator.java | 32 +++--
.../streamlet/impl/operators/UnionOperator.java | 32 +++--
.../heron/streamlet/impl/sinks/ComplexSink.java | 32 +++--
.../heron/streamlet/impl/sinks/ConsumerSink.java | 32 +++--
.../apache/heron/streamlet/impl/sinks/LogSink.java | 32 +++--
.../streamlet/impl/sources/ComplexSource.java | 32 +++--
.../streamlet/impl/sources/StreamletSource.java | 32 +++--
.../streamlet/impl/sources/SupplierSource.java | 32 +++--
.../impl/streamlets/ConsumerStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/FilterStreamlet.java | 32 +++--
.../impl/streamlets/FlatMapStreamlet.java | 32 +++--
.../GeneralReduceByKeyAndWindowStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/JoinStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/LogStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/MapStreamlet.java | 32 +++--
.../streamlets/ReduceByKeyAndWindowStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/RemapStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/SinkStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/SourceStreamlet.java | 32 +++--
.../impl/streamlets/SupplierStreamlet.java | 32 +++--
.../impl/streamlets/TransformStreamlet.java | 32 +++--
.../streamlet/impl/streamlets/UnionStreamlet.java | 32 +++--
heron/api/tests/cpp/serialization_unittest.cpp | 25 ++--
.../java/org/apache/heron/api/ConfigTest.java | 31 +++--
.../org/apache/heron/api/HeronSubmitterTest.java | 32 +++--
.../heron/api/bolt/BaseWindowedBoltTest.java | 32 +++--
.../heron/api/bolt/WindowedBoltExecutorTest.java | 32 +++--
.../heron/api/metric/CountStatAndMetricTest.java | 32 +++--
.../heron/api/metric/LatencyStatAndMetricTest.java | 32 +++--
.../api/windowing/WaterMarkEventGeneratorTest.java | 32 +++--
.../heron/api/windowing/WindowManagerTest.java | 32 +++--
.../heron/streamlet/impl/StreamletImplTest.java | 32 +++--
.../GeneralReduceByKeyAndWindowOperatorTest.java | 32 +++--
.../streamlet/impl/operators/JoinOperatorTest.java | 32 +++--
.../ReduceByKeyAndWindowOperatorTest.java | 32 +++--
.../apache/heron/ckptmgr/CheckpointManager.java | 31 +++--
.../heron/ckptmgr/CheckpointManagerConfig.java | 31 +++--
.../heron/ckptmgr/CheckpointManagerConfigKey.java | 32 +++--
.../heron/ckptmgr/CheckpointManagerException.java | 31 +++--
.../heron/ckptmgr/CheckpointManagerServer.java | 31 +++--
.../heron/ckptmgr/CheckpointManagerServerTest.java | 31 +++--
heron/common/src/cpp/basics/basics.cpp | 25 ++--
heron/common/src/cpp/basics/basics.h | 25 ++--
heron/common/src/cpp/basics/callback.h | 25 ++--
heron/common/src/cpp/basics/callback1.h | 25 ++--
heron/common/src/cpp/basics/classcallback.h | 25 ++--
heron/common/src/cpp/basics/classcallback1.h | 25 ++--
heron/common/src/cpp/basics/execmeta.cpp | 25 ++--
heron/common/src/cpp/basics/execmeta.h | 25 ++--
heron/common/src/cpp/basics/fileutils.cpp | 25 ++--
heron/common/src/cpp/basics/fileutils.h | 25 ++--
heron/common/src/cpp/basics/iputils.cpp | 25 ++--
heron/common/src/cpp/basics/iputils.h | 25 ++--
heron/common/src/cpp/basics/mempool.cpp | 25 ++--
heron/common/src/cpp/basics/mempool.h | 26 ++--
heron/common/src/cpp/basics/modinit.cpp | 25 ++--
heron/common/src/cpp/basics/modinit.h | 25 ++--
heron/common/src/cpp/basics/processutils.cpp | 25 ++--
heron/common/src/cpp/basics/processutils.h | 25 ++--
heron/common/src/cpp/basics/randutils.cpp | 25 ++--
heron/common/src/cpp/basics/randutils.h | 25 ++--
heron/common/src/cpp/basics/ridgen.cpp | 25 ++--
heron/common/src/cpp/basics/ridgen.h | 25 ++--
heron/common/src/cpp/basics/sockutils.cpp | 25 ++--
heron/common/src/cpp/basics/sockutils.h | 25 ++--
heron/common/src/cpp/basics/spconsts.h | 25 ++--
heron/common/src/cpp/basics/spfuncs.h | 25 ++--
heron/common/src/cpp/basics/sphash.h | 25 ++--
heron/common/src/cpp/basics/sprcodes.h | 25 ++--
heron/common/src/cpp/basics/sptest.h | 25 ++--
heron/common/src/cpp/basics/sptypes.h | 25 ++--
heron/common/src/cpp/basics/strutils.cpp | 25 ++--
heron/common/src/cpp/basics/strutils.h | 25 ++--
heron/common/src/cpp/config/allconfig.h | 25 ++--
.../src/cpp/config/cluster-config-reader.cpp | 25 ++--
.../common/src/cpp/config/cluster-config-reader.h | 25 ++--
.../common/src/cpp/config/cluster-config-vars.cpp | 25 ++--
heron/common/src/cpp/config/cluster-config-vars.h | 25 ++--
heron/common/src/cpp/config/helper.h | 25 ++--
.../cpp/config/heron-internals-config-reader.cpp | 25 ++--
.../src/cpp/config/heron-internals-config-reader.h | 25 ++--
.../src/cpp/config/heron-internals-config-vars.cpp | 25 ++--
.../src/cpp/config/heron-internals-config-vars.h | 25 ++--
.../common/src/cpp/config/metrics-sinks-reader.cpp | 25 ++--
heron/common/src/cpp/config/metrics-sinks-reader.h | 25 ++--
heron/common/src/cpp/config/metrics-sinks-vars.cpp | 25 ++--
heron/common/src/cpp/config/metrics-sinks-vars.h | 25 ++--
.../src/cpp/config/operational-config-reader.cpp | 25 ++--
.../src/cpp/config/operational-config-reader.h | 25 ++--
.../src/cpp/config/operational-config-vars.cpp | 25 ++--
.../src/cpp/config/operational-config-vars.h | 25 ++--
.../common/src/cpp/config/physical-plan-helper.cpp | 25 ++--
heron/common/src/cpp/config/physical-plan-helper.h | 25 ++--
heron/common/src/cpp/config/reader.h | 25 ++--
.../src/cpp/config/topology-config-helper.cpp | 25 ++--
.../common/src/cpp/config/topology-config-helper.h | 25 ++--
.../common/src/cpp/config/topology-config-vars.cpp | 25 ++--
heron/common/src/cpp/config/topology-config-vars.h | 25 ++--
heron/common/src/cpp/config/yaml-file-reader.cpp | 25 ++--
heron/common/src/cpp/config/yaml-file-reader.h | 25 ++--
heron/common/src/cpp/errors/errors.h | 25 ++--
heron/common/src/cpp/errors/gexception.cpp | 25 ++--
heron/common/src/cpp/errors/gexception.h | 25 ++--
heron/common/src/cpp/errors/modinit.cpp | 25 ++--
heron/common/src/cpp/errors/modinit.h | 25 ++--
heron/common/src/cpp/errors/sperrimpl.cpp | 25 ++--
heron/common/src/cpp/errors/sperrimpl.h | 25 ++--
heron/common/src/cpp/errors/sperrmod.h | 25 ++--
heron/common/src/cpp/errors/sperror.cpp | 25 ++--
heron/common/src/cpp/errors/sperror.h | 25 ++--
heron/common/src/cpp/errors/spexcept.cpp | 25 ++--
heron/common/src/cpp/errors/spexcept.h | 25 ++--
heron/common/src/cpp/errors/syserr.h | 25 ++--
heron/common/src/cpp/metrics/assignable-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/assignable-metric.h | 25 ++--
heron/common/src/cpp/metrics/count-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/count-metric.h | 25 ++--
heron/common/src/cpp/metrics/imetric.h | 25 ++--
heron/common/src/cpp/metrics/mean-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/mean-metric.h | 25 ++--
heron/common/src/cpp/metrics/metrics-mgr-st.cpp | 25 ++--
heron/common/src/cpp/metrics/metrics-mgr-st.h | 25 ++--
heron/common/src/cpp/metrics/metrics.h | 25 ++--
heron/common/src/cpp/metrics/metricsmgr-client.cpp | 25 ++--
heron/common/src/cpp/metrics/metricsmgr-client.h | 25 ++--
.../src/cpp/metrics/multi-assignable-metric.cpp | 25 ++--
.../src/cpp/metrics/multi-assignable-metric.h | 25 ++--
.../common/src/cpp/metrics/multi-count-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/multi-count-metric.h | 25 ++--
heron/common/src/cpp/metrics/multi-mean-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/multi-mean-metric.h | 25 ++--
heron/common/src/cpp/metrics/time-spent-metric.cpp | 25 ++--
heron/common/src/cpp/metrics/time-spent-metric.h | 25 ++--
heron/common/src/cpp/metrics/tmaster-metrics.cpp | 25 ++--
heron/common/src/cpp/metrics/tmaster-metrics.h | 25 ++--
heron/common/src/cpp/network/asyncdns.cpp | 25 ++--
heron/common/src/cpp/network/asyncdns.h | 25 ++--
heron/common/src/cpp/network/baseclient.cpp | 25 ++--
heron/common/src/cpp/network/baseclient.h | 25 ++--
heron/common/src/cpp/network/baseconnection.cpp | 25 ++--
heron/common/src/cpp/network/baseconnection.h | 25 ++--
heron/common/src/cpp/network/baseserver.cpp | 25 ++--
heron/common/src/cpp/network/baseserver.h | 25 ++--
heron/common/src/cpp/network/client.cpp | 25 ++--
heron/common/src/cpp/network/client.h | 25 ++--
heron/common/src/cpp/network/connection.cpp | 25 ++--
heron/common/src/cpp/network/connection.h | 25 ++--
heron/common/src/cpp/network/event_loop.h | 25 ++--
heron/common/src/cpp/network/event_loop_impl.cpp | 25 ++--
heron/common/src/cpp/network/event_loop_impl.h | 25 ++--
heron/common/src/cpp/network/httpclient.cpp | 25 ++--
heron/common/src/cpp/network/httpclient.h | 25 ++--
heron/common/src/cpp/network/httpserver.cpp | 25 ++--
heron/common/src/cpp/network/httpserver.h | 25 ++--
heron/common/src/cpp/network/httputils.cpp | 25 ++--
heron/common/src/cpp/network/httputils.h | 25 ++--
heron/common/src/cpp/network/modinit.cpp | 25 ++--
heron/common/src/cpp/network/modinit.h | 25 ++--
heron/common/src/cpp/network/network.h | 25 ++--
heron/common/src/cpp/network/network_error.h | 25 ++--
heron/common/src/cpp/network/networkoptions.cpp | 25 ++--
heron/common/src/cpp/network/networkoptions.h | 25 ++--
heron/common/src/cpp/network/packet.cpp | 25 ++--
heron/common/src/cpp/network/packet.h | 25 ++--
heron/common/src/cpp/network/piper.cpp | 25 ++--
heron/common/src/cpp/network/piper.h | 25 ++--
heron/common/src/cpp/network/regevent.h | 25 ++--
heron/common/src/cpp/network/server.cpp | 25 ++--
heron/common/src/cpp/network/server.h | 25 ++--
heron/common/src/cpp/setup/zk-setup.cpp | 25 ++--
heron/common/src/cpp/threads/modinit.cpp | 25 ++--
heron/common/src/cpp/threads/modinit.h | 25 ++--
heron/common/src/cpp/threads/pcqueue.h | 25 ++--
heron/common/src/cpp/threads/spcountdownlatch.cpp | 25 ++--
heron/common/src/cpp/threads/spcountdownlatch.h | 25 ++--
heron/common/src/cpp/threads/threads.h | 25 ++--
heron/common/src/cpp/zookeeper/mock_zkclient.h | 25 ++--
heron/common/src/cpp/zookeeper/zkclient.cpp | 25 ++--
heron/common/src/cpp/zookeeper/zkclient.h | 25 ++--
heron/common/src/cpp/zookeeper/zkclient_factory.h | 25 ++--
.../org/apache/heron/common/basics/ByteAmount.java | 32 +++--
.../apache/heron/common/basics/Communicator.java | 31 +++--
.../heron/common/basics/DryRunFormatType.java | 31 +++--
.../org/apache/heron/common/basics/FileUtils.java | 31 +++--
.../apache/heron/common/basics/ISelectHandler.java | 31 +++--
.../org/apache/heron/common/basics/NIOLooper.java | 31 +++--
.../apache/heron/common/basics/PackageType.java | 31 +++--
.../java/org/apache/heron/common/basics/Pair.java | 31 +++--
.../heron/common/basics/SingletonRegistry.java | 31 +++--
.../apache/heron/common/basics/SlaveLooper.java | 31 +++--
.../org/apache/heron/common/basics/SysUtils.java | 31 +++--
.../org/apache/heron/common/basics/TypeUtils.java | 31 +++--
.../apache/heron/common/basics/WakeableLooper.java | 31 +++--
.../apache/heron/common/config/ConfigReader.java | 31 +++--
.../apache/heron/common/config/SystemConfig.java | 31 +++--
.../heron/common/config/SystemConfigKey.java | 32 +++--
.../apache/heron/common/network/HeronClient.java | 31 +++--
.../apache/heron/common/network/HeronServer.java | 31 +++--
.../heron/common/network/HeronSocketOptions.java | 31 +++--
.../heron/common/network/IncomingPacket.java | 31 +++--
.../heron/common/network/OutgoingPacket.java | 31 +++--
.../org/apache/heron/common/network/REQID.java | 31 +++--
.../heron/common/network/SocketChannelHelper.java | 31 +++--
.../apache/heron/common/network/StatusCode.java | 31 +++--
.../common/testhelpers/CommunicatorTestHelper.java | 32 +++--
.../common/testhelpers/HeronServerTester.java | 32 +++--
.../utils/logging/ErrorReportLoggingHandler.java | 31 +++--
.../heron/common/utils/logging/LoggingHelper.java | 31 +++--
.../heron/common/utils/metrics/BoltMetrics.java | 31 +++--
.../common/utils/metrics/ComponentMetrics.java | 32 +++--
.../common/utils/metrics/FullBoltMetrics.java | 31 +++--
.../common/utils/metrics/FullSpoutMetrics.java | 31 +++--
.../heron/common/utils/metrics/JVMMetrics.java | 31 +++--
.../common/utils/metrics/MetricsCollector.java | 31 +++--
.../heron/common/utils/metrics/SpoutMetrics.java | 31 +++--
.../utils/misc/CustomStreamGroupingHelper.java | 31 +++--
.../common/utils/misc/PhysicalPlanHelper.java | 31 +++--
.../utils/misc/SerializeDeSerializeHelper.java | 31 +++--
.../heron/common/utils/misc/ThreadNames.java | 31 +++--
.../heron/common/utils/misc/TupleKeyGenerator.java | 31 +++--
.../utils/topology/GeneralTopologyContextImpl.java | 31 +++--
.../common/utils/topology/TopologyContextImpl.java | 31 +++--
.../heron/common/utils/topology/TopologyTests.java | 32 +++--
.../apache/heron/common/utils/tuple/TickTuple.java | 31 +++--
.../apache/heron/common/utils/tuple/TupleImpl.java | 31 +++--
.../common/tests/cpp/basics/fileutils_unittest.cpp | 25 ++--
heron/common/tests/cpp/basics/rid_unittest.cpp | 25 ++--
.../common/tests/cpp/basics/strutils_unittest.cpp | 25 ++--
heron/common/tests/cpp/basics/utils_unittest.cpp | 25 ++--
.../cpp/config/topology-config-helper_unittest.cpp | 25 ++--
heron/common/tests/cpp/errors/errors_unittest.cpp | 25 ++--
heron/common/tests/cpp/errors/module_unittest.cpp | 25 ++--
heron/common/tests/cpp/errors/syserrs_unittest.cpp | 25 ++--
.../tests/cpp/metrics/count-metric_unittest.cpp | 25 ++--
.../tests/cpp/metrics/mean-metric_unittest.cpp | 25 ++--
.../cpp/metrics/multi-count-metric_unittest.cpp | 25 ++--
.../cpp/metrics/multi-mean-metric_unittest.cpp | 25 ++--
.../cpp/metrics/time-spent-metric_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/client_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/client_unittest.h | 25 ++--
heron/common/tests/cpp/network/host_unittest.h | 25 ++--
.../tests/cpp/network/http_client_unittest.cpp | 25 ++--
.../tests/cpp/network/http_server_unittest.cpp | 25 ++--
.../tests/cpp/network/http_server_unittest.h | 25 ++--
heron/common/tests/cpp/network/http_unittest.cpp | 25 ++--
.../common/tests/cpp/network/oclient_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/oclient_unittest.h | 25 ++--
heron/common/tests/cpp/network/order_unittest.cpp | 25 ++--
.../common/tests/cpp/network/oserver_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/oserver_unittest.h | 25 ++--
heron/common/tests/cpp/network/packet_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/piper_unittest.cpp | 26 ++--
.../tests/cpp/network/rate_limit_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/server_unittest.cpp | 25 ++--
heron/common/tests/cpp/network/server_unittest.h | 25 ++--
heron/common/tests/cpp/network/switch_unittest.cpp | 25 ++--
.../cpp/threads/spcountdownlatch_unittest.cpp | 25 ++--
heron/common/tests/cpp/zookeeper/simpletest.cpp | 25 ++--
.../apache/heron/common/basics/ByteAmountTest.java | 32 +++--
.../heron/common/basics/CommunicatorTest.java | 31 +++--
.../apache/heron/common/basics/FileUtilsTest.java | 31 +++--
.../heron/common/basics/PackageTypeTest.java | 31 +++--
.../apache/heron/common/basics/SysUtilsTest.java | 31 +++--
.../heron/common/basics/WakeableLooperTest.java | 31 +++--
.../heron/common/config/ConfigReaderTest.java | 31 +++--
.../heron/common/config/SystemConfigTest.java | 31 +++--
.../org/apache/heron/common/test/EchoTest.java | 31 +++--
.../apache/heron/common/test/HeronServerTest.java | 31 +++--
.../heron/common/utils/TopologyUtilsTest.java | 31 +++--
.../org/apache/heron/downloader/DLDownloader.java | 32 +++--
.../apache/heron/downloader/DownloadRunner.java | 32 +++--
.../org/apache/heron/downloader/Downloader.java | 32 +++--
.../org/apache/heron/downloader/Extractor.java | 32 +++--
.../apache/heron/downloader/FileDownloader.java | 32 +++--
.../apache/heron/downloader/HttpDownloader.java | 32 +++--
.../java/org/apache/heron/downloader/Registry.java | 32 +++--
.../apache/heron/downloader/DLDownloaderTest.java | 32 +++--
.../apache/heron/downloader/ExtractorTests.java | 32 +++--
.../org/apache/heron/downloader/RegistryTest.java | 32 +++--
.../org/apache/heron/healthmgr/HealthManager.java | 31 +++--
.../heron/healthmgr/HealthManagerMetrics.java | 31 +++--
.../apache/heron/healthmgr/HealthPolicyConfig.java | 31 +++--
.../heron/healthmgr/HealthPolicyConfigReader.java | 31 +++--
.../healthmgr/common/HealthManagerEvents.java | 31 +++--
.../healthmgr/common/InvalidStateException.java | 31 +++--
.../heron/healthmgr/common/MetricsStats.java | 32 ++---
.../healthmgr/common/PackingPlanProvider.java | 31 +++--
.../healthmgr/common/PhysicalPlanProvider.java | 31 +++--
.../heron/healthmgr/common/TopologyProvider.java | 31 +++--
.../healthmgr/detectors/BackPressureDetector.java | 32 ++---
.../heron/healthmgr/detectors/BaseDetector.java | 31 +++--
.../detectors/GrowingWaitQueueDetector.java | 32 ++---
.../detectors/LargeWaitQueueDetector.java | 32 ++---
.../detectors/ProcessingRateSkewDetector.java | 32 ++---
.../heron/healthmgr/detectors/SkewDetector.java | 32 ++---
.../healthmgr/detectors/WaitQueueSkewDetector.java | 32 ++---
.../heron/healthmgr/diagnosers/BaseDiagnoser.java | 31 +++--
.../healthmgr/diagnosers/DataSkewDiagnoser.java | 32 ++---
.../diagnosers/SlowInstanceDiagnoser.java | 31 +++--
.../diagnosers/UnderProvisioningDiagnoser.java | 32 ++---
.../AutoRestartBackpressureContainerPolicy.java | 32 ++---
.../policy/DynamicResourceAllocationPolicy.java | 32 ++---
.../resolvers/RestartContainerResolver.java | 32 +++--
.../heron/healthmgr/resolvers/ScaleUpResolver.java | 32 +++--
.../healthmgr/sensors/BackPressureSensor.java | 32 ++---
.../apache/heron/healthmgr/sensors/BaseSensor.java | 31 +++--
.../heron/healthmgr/sensors/BufferSizeSensor.java | 32 ++---
.../healthmgr/sensors/ExecuteCountSensor.java | 32 ++---
.../sensors/MetricsCacheMetricsProvider.java | 32 ++---
.../healthmgr/sensors/TrackerMetricsProvider.java | 32 ++---
.../apache/heron/healthmgr/HealthManagerTest.java | 31 +++--
.../healthmgr/HealthPolicyConfigReaderTest.java | 31 +++--
.../healthmgr/common/PackingPlanProviderTest.java | 31 +++--
.../healthmgr/common/TopologyProviderTest.java | 31 +++--
.../detectors/BackPressureDetectorTest.java | 31 +++--
.../detectors/GrowingWaitQueueDetectorTest.java | 31 +++--
.../detectors/LargeWaitQueueDetectorTest.java | 31 +++--
.../detectors/ProcessingRateSkewDetectorTest.java | 31 +++--
.../detectors/WaitQueueSkewDetectorTest.java | 31 +++--
.../diagnosers/DataSkewDiagnoserTest.java | 31 +++--
.../diagnosers/SlowInstanceDiagnoserTest.java | 31 +++--
.../diagnosers/UnderProvisioningDiagnoserTest.java | 31 +++--
.../healthmgr/resolvers/ScaleUpResolverTest.java | 31 +++--
.../healthmgr/sensors/BackPressureSensorTest.java | 31 +++--
.../healthmgr/sensors/BufferSizeSensorTest.java | 31 +++--
.../healthmgr/sensors/ExecuteCountSensorTest.java | 31 +++--
.../sensors/MetricsCacheMetricsProviderTest.java | 31 +++--
.../sensors/TrackerMetricsProviderTest.java | 31 +++--
heron/instance/src/cpp/boltimpl/bolt-instance.cpp | 25 ++--
heron/instance/src/cpp/boltimpl/bolt-instance.h | 25 ++--
heron/instance/src/cpp/boltimpl/bolt-metrics.cpp | 25 ++--
heron/instance/src/cpp/boltimpl/bolt-metrics.h | 25 ++--
.../cpp/boltimpl/bolt-output-collector-impl.cpp | 25 ++--
.../src/cpp/boltimpl/bolt-output-collector-impl.h | 25 ++--
heron/instance/src/cpp/boltimpl/tick-tuple.cpp | 25 ++--
heron/instance/src/cpp/boltimpl/tick-tuple.h | 25 ++--
heron/instance/src/cpp/boltimpl/tuple-impl.cpp | 25 ++--
heron/instance/src/cpp/boltimpl/tuple-impl.h | 25 ++--
heron/instance/src/cpp/gateway/gateway-metrics.cpp | 25 ++--
heron/instance/src/cpp/gateway/gateway-metrics.h | 25 ++--
heron/instance/src/cpp/gateway/gateway.cpp | 25 ++--
heron/instance/src/cpp/gateway/gateway.h | 25 ++--
heron/instance/src/cpp/gateway/stmgr-client.cpp | 25 ++--
heron/instance/src/cpp/gateway/stmgr-client.h | 25 ++--
heron/instance/src/cpp/instance-main.cpp | 25 ++--
.../src/cpp/slave/imetrics-registrar-impl.cpp | 25 ++--
.../src/cpp/slave/imetrics-registrar-impl.h | 25 ++--
heron/instance/src/cpp/slave/instance-base.h | 25 ++--
.../src/cpp/slave/outgoing-tuple-collection.cpp | 25 ++--
.../src/cpp/slave/outgoing-tuple-collection.h | 25 ++--
heron/instance/src/cpp/slave/slave.cpp | 25 ++--
heron/instance/src/cpp/slave/slave.h | 25 ++--
heron/instance/src/cpp/slave/task-context-impl.cpp | 25 ++--
heron/instance/src/cpp/slave/task-context-impl.h | 25 ++--
heron/instance/src/cpp/spoutimpl/root-tuple-info.h | 25 ++--
.../instance/src/cpp/spoutimpl/spout-instance.cpp | 25 ++--
heron/instance/src/cpp/spoutimpl/spout-instance.h | 25 ++--
heron/instance/src/cpp/spoutimpl/spout-metrics.cpp | 25 ++--
heron/instance/src/cpp/spoutimpl/spout-metrics.h | 25 ++--
.../cpp/spoutimpl/spout-output-collector-impl.cpp | 25 ++--
.../cpp/spoutimpl/spout-output-collector-impl.h | 25 ++--
heron/instance/src/cpp/utils/communicator.h | 25 ++--
.../src/cpp/utils/notifying-communicator.h | 25 ++--
.../heron/instance/AbstractOutputCollector.java | 32 +++--
.../java/org/apache/heron/instance/Gateway.java | 31 +++--
.../org/apache/heron/instance/HeronInstance.java | 31 +++--
.../java/org/apache/heron/instance/IInstance.java | 31 +++--
.../apache/heron/instance/InstanceControlMsg.java | 31 +++--
.../heron/instance/OutgoingTupleCollection.java | 31 +++--
.../src/java/org/apache/heron/instance/Slave.java | 31 +++--
.../apache/heron/instance/bolt/BoltInstance.java | 31 +++--
.../instance/bolt/BoltOutputCollectorImpl.java | 31 +++--
.../apache/heron/instance/spout/RootTupleInfo.java | 31 +++--
.../apache/heron/instance/spout/SpoutInstance.java | 31 +++--
.../instance/spout/SpoutOutputCollectorImpl.java | 31 +++--
.../apache/heron/instance/util/InstanceUtils.java | 32 +++--
.../org/apache/heron/instance/util/JvmVersion.java | 32 +++--
.../org/apache/heron/metrics/GatewayMetrics.java | 31 +++--
.../apache/heron/network/MetricsManagerClient.java | 31 +++--
.../apache/heron/network/StreamManagerClient.java | 31 +++--
.../heron/grouping/AbstractTupleRoutingTest.java | 31 +++--
.../apache/heron/grouping/CustomGroupingTest.java | 32 +++--
.../apache/heron/grouping/EmitDirectBoltTest.java | 32 +++--
.../heron/grouping/EmitDirectRoundRobinBolt.java | 32 +++--
.../heron/grouping/EmitDirectRoundRobinSpout.java | 32 +++--
.../apache/heron/grouping/EmitDirectSpoutTest.java | 32 +++--
.../apache/heron/instance/CommunicatorTester.java | 32 +++--
.../org/apache/heron/instance/SlaveTester.java | 32 +++--
.../heron/instance/bolt/BoltInstanceTest.java | 31 +++--
.../instance/spout/ActivateDeactivateTest.java | 31 +++--
.../heron/instance/spout/SpoutInstanceTest.java | 31 +++--
.../apache/heron/metrics/GlobalMetricsTest.java | 31 +++--
.../heron/metrics/MultiAssignableMetricTest.java | 31 +++--
.../apache/heron/network/AbstractNetworkTest.java | 32 +++--
.../java/org/apache/heron/network/ConnectTest.java | 31 +++--
.../org/apache/heron/network/HandleReadTest.java | 31 +++--
.../org/apache/heron/network/HandleWriteTest.java | 31 +++--
.../java/org/apache/heron/resource/Constants.java | 31 +++--
.../java/org/apache/heron/resource/TestBolt.java | 31 +++--
.../java/org/apache/heron/resource/TestSpout.java | 31 +++--
.../org/apache/heron/resource/UnitTestHelper.java | 31 +++--
.../java/org/apache/heron/dlog/DLInputStream.java | 32 +++--
.../java/org/apache/heron/dlog/DLOutputStream.java | 32 +++--
.../dlog/src/java/org/apache/heron/dlog/Util.java | 32 +++--
.../org/apache/heron/dlog/DLInputStreamTest.java | 32 +++--
.../org/apache/heron/dlog/DLOutputStreamTest.java | 32 +++--
.../heron/metricscachemgr/MetricsCacheManager.java | 32 ++---
.../MetricsCacheManagerHttpServer.java | 31 +++--
.../metricscachemgr/MetricsCacheManagerServer.java | 31 +++--
.../metricscachemgr/metricscache/CacheCore.java | 31 +++--
.../metricscachemgr/metricscache/MetricsCache.java | 31 +++--
.../metricscache/MetricsCacheQueryUtils.java | 31 +++--
.../metricscache/query/ExceptionDatum.java | 31 +++--
.../metricscache/query/ExceptionRequest.java | 31 +++--
.../metricscache/query/ExceptionResponse.java | 31 +++--
.../metricscache/query/MetricDatum.java | 31 +++--
.../metricscache/query/MetricGranularity.java | 31 +++--
.../metricscache/query/MetricRequest.java | 31 +++--
.../metricscache/query/MetricResponse.java | 31 +++--
.../metricscache/query/MetricTimeRangeValue.java | 31 +++--
.../metricscache/store/ExceptionDatapoint.java | 31 +++--
.../metricscache/store/MetricDatapoint.java | 31 +++--
.../metricscache/CacheCoreTest.java | 32 ++---
.../metricscache/MetricsCacheQueryUtilsTest.java | 31 +++--
.../metricscache/MetricsCacheTest.java | 31 +++--
.../apache/heron/metricsmgr/MetricsManager.java | 31 +++--
.../heron/metricsmgr/MetricsManagerServer.java | 31 +++--
.../heron/metricsmgr/MetricsSinksConfig.java | 31 +++--
.../org/apache/heron/metricsmgr/MetricsUtil.java | 32 +++--
.../heron/metricsmgr/executor/SinkExecutor.java | 31 +++--
.../heron/metricsmgr/sink/AbstractWebSink.java | 32 +++--
.../org/apache/heron/metricsmgr/sink/FileSink.java | 31 +++--
.../apache/heron/metricsmgr/sink/GraphiteSink.java | 31 +++--
.../heron/metricsmgr/sink/PrometheusSink.java | 32 +++--
.../heron/metricsmgr/sink/SinkContextImpl.java | 31 +++--
.../org/apache/heron/metricsmgr/sink/WebSink.java | 31 +++--
.../sink/metricscache/MetricsCacheClient.java | 31 +++--
.../sink/metricscache/MetricsCacheSink.java | 31 +++--
.../metricsmgr/sink/tmaster/TMasterClient.java | 31 +++--
.../heron/metricsmgr/sink/tmaster/TMasterSink.java | 31 +++--
.../metricsmgr/HandleTMasterLocationTest.java | 31 +++--
.../heron/metricsmgr/LatchedMultiCountMetric.java | 32 +++--
.../heron/metricsmgr/MetricsManagerServerTest.java | 31 +++--
.../apache/heron/metricsmgr/MetricsUtilTests.java | 32 +++--
.../metricsmgr/executor/SinkExecutorTest.java | 31 +++--
.../apache/heron/metricsmgr/sink/FileSinkTest.java | 31 +++--
.../heron/metricsmgr/sink/PrometheusSinkTests.java | 32 +++--
.../apache/heron/metricsmgr/sink/WebSinkTest.java | 31 +++--
.../sink/metricscache/MetricsCacheSinkTest.java | 31 +++--
.../metricsmgr/sink/tmaster/TMasterSinkTest.java | 31 +++--
.../org/apache/heron/packing/RamRequirement.java | 31 +++--
.../heron/packing/ResourceExceededException.java | 32 +++--
.../binpacking/FirstFitDecreasingPacking.java | 31 +++--
.../apache/heron/packing/builder/Container.java | 32 +++--
.../heron/packing/builder/ContainerIdScorer.java | 32 +++--
.../heron/packing/builder/HomogeneityScorer.java | 32 +++--
.../heron/packing/builder/InstanceCountScorer.java | 32 +++--
.../heron/packing/builder/PackingPlanBuilder.java | 32 +++--
.../org/apache/heron/packing/builder/Scorer.java | 32 +++--
.../roundrobin/ResourceCompliantRRPacking.java | 31 +++--
.../packing/roundrobin/RoundRobinPacking.java | 31 +++--
.../apache/heron/packing/utils/PackingUtils.java | 32 +++--
.../org/apache/heron/packing/AssertPacking.java | 32 +++--
.../apache/heron/packing/CommonPackingTests.java | 32 +++--
.../apache/heron/packing/PackingTestHelper.java | 32 +++--
.../binpacking/FirstFitDecreasingPackingTest.java | 31 +++--
.../packing/builder/PackingPlanBuilderTest.java | 32 +++--
.../apache/heron/packing/builder/ScorerTest.java | 32 +++--
.../roundrobin/ResourceCompliantRRPackingTest.java | 31 +++--
.../packing/roundrobin/RoundRobinPackingTest.java | 31 +++--
.../heron/packing/utils/PackingUtilsTest.java | 32 +++--
heron/proto/Empty.java | 31 +++--
heron/proto/messages.h | 25 ++--
.../java/org/apache/heron/scheduler/Command.java | 32 +++--
.../org/apache/heron/scheduler/ExecutorFlag.java | 32 +++--
.../org/apache/heron/scheduler/LaunchRunner.java | 31 +++--
.../apache/heron/scheduler/RuntimeManagerMain.java | 31 +++--
.../heron/scheduler/RuntimeManagerRunner.java | 31 +++--
.../org/apache/heron/scheduler/SchedulerMain.java | 31 +++--
.../org/apache/heron/scheduler/SubmitterMain.java | 31 +++--
.../TopologyRuntimeManagementException.java | 31 +++--
.../scheduler/TopologySubmissionException.java | 31 +++--
.../heron/scheduler/UpdateTopologyManager.java | 32 +++--
.../client/HttpServiceSchedulerClient.java | 31 +++--
.../heron/scheduler/client/ISchedulerClient.java | 31 +++--
.../scheduler/client/LibrarySchedulerClient.java | 31 +++--
.../scheduler/client/SchedulerClientFactory.java | 31 +++--
.../heron/scheduler/dryrun/DryRunRender.java | 32 +++--
.../heron/scheduler/dryrun/DryRunResponse.java | 32 +++--
.../heron/scheduler/dryrun/FormatterUtils.java | 32 +++--
.../heron/scheduler/dryrun/JsonFormatterUtils.java | 32 +++--
.../scheduler/dryrun/SubmitDryRunResponse.java | 32 +++--
.../scheduler/dryrun/SubmitJsonDryRunRenderer.java | 32 +++--
.../scheduler/dryrun/SubmitRawDryRunRenderer.java | 32 +++--
.../dryrun/SubmitTableDryRunRenderer.java | 32 +++--
.../scheduler/dryrun/UpdateDryRunResponse.java | 32 +++--
.../scheduler/dryrun/UpdateJsonDryRunRenderer.java | 32 +++--
.../scheduler/dryrun/UpdateRawDryRunRenderer.java | 32 +++--
.../dryrun/UpdateTableDryRunRenderer.java | 32 +++--
.../server/ExceptionalRequestHandler.java | 32 +++--
.../heron/scheduler/server/KillRequestHandler.java | 31 +++--
.../scheduler/server/RestartRequestHandler.java | 31 +++--
.../heron/scheduler/server/SchedulerServer.java | 31 +++--
.../server/TerminateSchedulerException.java | 32 +++--
.../scheduler/server/UpdateRequestHandler.java | 32 +++--
.../heron/scheduler/utils/DryRunRenders.java | 32 +++--
.../heron/scheduler/utils/LauncherUtils.java | 31 +++--
.../org/apache/heron/scheduler/utils/Runtime.java | 31 +++--
.../scheduler/utils/SchedulerConfigUtils.java | 31 +++--
.../heron/scheduler/utils/SchedulerUtils.java | 31 +++--
.../org/apache/heron/scheduler/utils/Shutdown.java | 31 +++--
.../heron/scheduler/utils/SubmitterUtils.java | 32 +++--
.../apache/heron/scheduler/LaunchRunnerTest.java | 31 +++--
.../heron/scheduler/RuntimeManagerMainTest.java | 31 +++--
.../heron/scheduler/RuntimeManagerRunnerTest.java | 31 +++--
.../apache/heron/scheduler/SchedulerMainTest.java | 31 +++--
.../apache/heron/scheduler/SubmitterMainTest.java | 31 +++--
.../heron/scheduler/UpdateTopologyManagerTest.java | 32 +++--
.../client/HttpServiceSchedulerClientTest.java | 31 +++--
.../client/LibrarySchedulerClientTest.java | 31 +++--
.../client/SchedulerClientFactoryTest.java | 31 +++--
.../scheduler/dryrun/JsonFormatterUtilsTest.java | 32 +++--
.../scheduler/dryrun/SubmitDryRunRenderTest.java | 32 +++--
.../scheduler/dryrun/UpdateDryRunRenderTest.java | 32 +++--
.../scheduler/server/SchedulerServerTest.java | 31 +++--
.../heron/scheduler/utils/LauncherUtilsTest.java | 31 +++--
.../heron/scheduler/utils/SchedulerUtilsTest.java | 31 +++--
.../org/apache/heron/scheduler/NullLauncher.java | 31 +++--
.../org/apache/heron/scheduler/NullScheduler.java | 31 +++--
.../scheduler/aurora/AuroraCLIController.java | 31 +++--
.../heron/scheduler/aurora/AuroraContext.java | 31 +++--
.../heron/scheduler/aurora/AuroraController.java | 32 +++--
.../apache/heron/scheduler/aurora/AuroraField.java | 32 +++--
.../aurora/AuroraHeronShellController.java | 31 +++--
.../heron/scheduler/aurora/AuroraLauncher.java | 31 +++--
.../heron/scheduler/aurora/AuroraScheduler.java | 31 +++--
.../kubernetes/AppsV1beta1Controller.java | 32 +++--
.../scheduler/kubernetes/KubernetesCompat.java | 32 +++--
.../scheduler/kubernetes/KubernetesConstants.java | 31 +++--
.../scheduler/kubernetes/KubernetesContext.java | 31 +++--
.../scheduler/kubernetes/KubernetesController.java | 32 +++--
.../scheduler/kubernetes/KubernetesLauncher.java | 31 +++--
.../scheduler/kubernetes/KubernetesScheduler.java | 31 +++--
.../scheduler/kubernetes/KubernetesUtils.java | 32 +++--
.../apache/heron/scheduler/kubernetes/Volumes.java | 32 +++--
.../apache/heron/scheduler/local/LocalContext.java | 31 +++--
.../org/apache/heron/scheduler/local/LocalKey.java | 32 +++--
.../heron/scheduler/local/LocalLauncher.java | 31 +++--
.../heron/scheduler/local/LocalScheduler.java | 31 +++--
.../scheduler/marathon/MarathonConstants.java | 31 +++--
.../heron/scheduler/marathon/MarathonContext.java | 31 +++--
.../scheduler/marathon/MarathonController.java | 31 +++--
.../heron/scheduler/marathon/MarathonLauncher.java | 31 +++--
.../scheduler/marathon/MarathonScheduler.java | 31 +++--
.../apache/heron/scheduler/mesos/MesosContext.java | 31 +++--
.../heron/scheduler/mesos/MesosLauncher.java | 31 +++--
.../heron/scheduler/mesos/MesosScheduler.java | 31 +++--
.../scheduler/mesos/framework/BaseContainer.java | 31 +++--
.../scheduler/mesos/framework/LaunchableTask.java | 31 +++--
.../scheduler/mesos/framework/MesosFramework.java | 31 +++--
.../scheduler/mesos/framework/TaskResources.java | 31 +++--
.../heron/scheduler/mesos/framework/TaskUtils.java | 31 +++--
.../heron/scheduler/nomad/NomadConstants.java | 32 +++--
.../apache/heron/scheduler/nomad/NomadContext.java | 32 +++--
.../org/apache/heron/scheduler/nomad/NomadKey.java | 32 +++--
.../heron/scheduler/nomad/NomadLauncher.java | 32 +++--
.../heron/scheduler/nomad/NomadScheduler.java | 32 +++--
.../apache/heron/scheduler/slurm/SlurmContext.java | 31 +++--
.../heron/scheduler/slurm/SlurmController.java | 31 +++--
.../heron/scheduler/slurm/SlurmLauncher.java | 31 +++--
.../heron/scheduler/slurm/SlurmScheduler.java | 31 +++--
.../heron/scheduler/utils/HttpJsonClient.java | 31 +++--
.../scheduler/yarn/HeronClientConfiguration.java | 31 +++--
.../scheduler/yarn/HeronConfigurationOptions.java | 31 +++--
.../scheduler/yarn/HeronDriverConfiguration.java | 31 +++--
.../heron/scheduler/yarn/HeronExecutorTask.java | 31 +++--
.../heron/scheduler/yarn/HeronMasterDriver.java | 31 +++--
.../scheduler/yarn/HeronMasterDriverProvider.java | 31 +++--
.../heron/scheduler/yarn/HeronReefUtils.java | 31 +++--
.../scheduler/yarn/HeronTaskConfiguration.java | 31 +++--
.../scheduler/yarn/ReefClientSideHandlers.java | 31 +++--
.../apache/heron/scheduler/yarn/YarnContext.java | 31 +++--
.../org/apache/heron/scheduler/yarn/YarnKey.java | 31 +++--
.../apache/heron/scheduler/yarn/YarnLauncher.java | 31 +++--
.../apache/heron/scheduler/yarn/YarnScheduler.java | 31 +++--
.../scheduler/aurora/AuroraCLIControllerTest.java | 31 +++--
.../heron/scheduler/aurora/AuroraContextTest.java | 32 +++--
.../heron/scheduler/aurora/AuroraLauncherTest.java | 31 +++--
.../scheduler/aurora/AuroraSchedulerTest.java | 31 +++--
.../kubernetes/KubernetesControllerTest.java | 31 +++--
.../kubernetes/KubernetesLauncherTest.java | 31 +++--
.../kubernetes/KubernetesSchedulerTest.java | 31 +++--
.../heron/scheduler/kubernetes/VolumesTests.java | 32 +++--
.../heron/scheduler/local/LocalLauncherTest.java | 31 +++--
.../heron/scheduler/local/LocalSchedulerTest.java | 31 +++--
.../scheduler/marathon/MarathonControllerTest.java | 31 +++--
.../scheduler/marathon/MarathonLauncherTest.java | 31 +++--
.../scheduler/marathon/MarathonSchedulerTest.java | 31 +++--
.../heron/scheduler/mesos/MesosLauncherTest.java | 31 +++--
.../heron/scheduler/mesos/MesosSchedulerTest.java | 31 +++--
.../mesos/framework/LaunchableTaskTest.java | 31 +++--
.../mesos/framework/MesosFrameworkTest.java | 31 +++--
.../mesos/framework/TaskResourcesTest.java | 31 +++--
.../scheduler/mesos/framework/TaskUtilsTest.java | 31 +++--
.../heron/scheduler/nomad/NomadSchedulerTest.java | 32 +++--
.../heron/scheduler/slurm/SlurmControllerTest.java | 31 +++--
.../heron/scheduler/slurm/SlurmLauncherTest.java | 31 +++--
.../heron/scheduler/slurm/SlurmSchedulerTest.java | 31 +++--
.../scheduler/yarn/HeronExecutorTaskTest.java | 31 +++--
.../scheduler/yarn/HeronMasterDriverTest.java | 31 +++--
.../heron/scheduler/yarn/YarnLauncherTest.java | 31 +++--
.../heron/scheduler/yarn/YarnSchedulerTest.java | 31 +++--
.../java/org/apache/heron/simulator/Simulator.java | 31 +++--
.../simulator/executors/InstanceExecutor.java | 31 +++--
.../heron/simulator/executors/MetricsExecutor.java | 31 +++--
.../heron/simulator/executors/StreamExecutor.java | 31 +++--
.../heron/simulator/grouping/AllGrouping.java | 31 +++--
.../heron/simulator/grouping/CustomGrouping.java | 31 +++--
.../heron/simulator/grouping/FieldsGrouping.java | 31 +++--
.../apache/heron/simulator/grouping/Grouping.java | 31 +++--
.../heron/simulator/grouping/LowestGrouping.java | 31 +++--
.../heron/simulator/grouping/ShuffleGrouping.java | 31 +++--
.../heron/simulator/instance/BoltInstance.java | 31 +++--
.../heron/simulator/instance/RootTupleInfo.java | 31 +++--
.../heron/simulator/instance/SpoutInstance.java | 31 +++--
.../apache/heron/simulator/utils/RotatingMap.java | 31 +++--
.../heron/simulator/utils/TopologyManager.java | 31 +++--
.../apache/heron/simulator/utils/TupleCache.java | 31 +++--
.../apache/heron/simulator/utils/XORManager.java | 31 +++--
.../org/apache/heron/simulator/SimulatorTest.java | 31 +++--
.../simulator/executors/InstanceExecutorTest.java | 31 +++--
.../heron/simulator/grouping/AllGroupingTest.java | 31 +++--
.../simulator/grouping/CustomGroupingTest.java | 31 +++--
.../simulator/grouping/FieldsGroupingTest.java | 31 +++--
.../simulator/grouping/LowestGroupingTest.java | 31 +++--
.../simulator/grouping/ShuffleGroupingTest.java | 31 +++--
.../heron/simulator/utils/RotatingMapTest.java | 31 +++--
.../heron/simulator/utils/TopologyManagerTest.java | 31 +++--
.../heron/simulator/utils/TupleCacheTest.java | 31 +++--
.../heron/simulator/utils/XORManagerTest.java | 31 +++--
.../java/org/apache/heron/spi/common/Config.java | 31 +++--
.../org/apache/heron/spi/common/ConfigLoader.java | 31 +++--
.../java/org/apache/heron/spi/common/Context.java | 31 +++--
.../src/java/org/apache/heron/spi/common/Key.java | 32 +++--
.../java/org/apache/heron/spi/common/TokenSub.java | 31 +++--
.../spi/metricsmgr/metrics/ExceptionInfo.java | 31 +++--
.../spi/metricsmgr/metrics/MetricsFilter.java | 31 +++--
.../heron/spi/metricsmgr/metrics/MetricsInfo.java | 31 +++--
.../spi/metricsmgr/metrics/MetricsRecord.java | 31 +++--
.../heron/spi/metricsmgr/sink/IMetricsSink.java | 31 +++--
.../heron/spi/metricsmgr/sink/SinkContext.java | 31 +++--
.../org/apache/heron/spi/packing/IPacking.java | 31 +++--
.../org/apache/heron/spi/packing/IRepacking.java | 32 +++--
.../org/apache/heron/spi/packing/InstanceId.java | 32 +++--
.../apache/heron/spi/packing/PackingException.java | 32 +++--
.../org/apache/heron/spi/packing/PackingPlan.java | 31 +++--
.../spi/packing/PackingPlanProtoDeserializer.java | 32 +++--
.../spi/packing/PackingPlanProtoSerializer.java | 32 +++--
.../org/apache/heron/spi/packing/Resource.java | 31 +++--
.../org/apache/heron/spi/scheduler/ILauncher.java | 31 +++--
.../org/apache/heron/spi/scheduler/IScalable.java | 32 +++--
.../org/apache/heron/spi/scheduler/IScheduler.java | 31 +++--
.../heron/spi/scheduler/LauncherException.java | 32 +++--
.../heron/spi/scheduler/SchedulerException.java | 31 +++--
.../heron/spi/statefulstorage/Checkpoint.java | 31 +++--
.../spi/statefulstorage/IStatefulStorage.java | 31 +++--
.../statefulstorage/StatefulStorageException.java | 31 +++--
.../apache/heron/spi/statemgr/IStateManager.java | 31 +++--
.../java/org/apache/heron/spi/statemgr/Lock.java | 32 +++--
.../spi/statemgr/SchedulerStateManagerAdaptor.java | 31 +++--
.../apache/heron/spi/statemgr/WatchCallback.java | 31 +++--
.../org/apache/heron/spi/uploader/IUploader.java | 31 +++--
.../heron/spi/uploader/UploaderException.java | 32 +++--
.../org/apache/heron/spi/utils/NetworkUtils.java | 31 +++--
.../apache/heron/spi/utils/PackingTestUtils.java | 32 +++--
.../apache/heron/spi/utils/ReflectionUtils.java | 31 +++--
.../org/apache/heron/spi/utils/ShellUtils.java | 31 +++--
.../apache/heron/spi/utils/TMasterException.java | 31 +++--
.../org/apache/heron/spi/utils/TMasterUtils.java | 31 +++--
.../org/apache/heron/spi/utils/UploaderUtils.java | 31 +++--
.../apache/heron/spi/common/ConfigLoaderTest.java | 31 +++--
.../org/apache/heron/spi/common/ConfigTest.java | 32 +++--
.../org/apache/heron/spi/common/ContextTest.java | 31 +++--
.../java/org/apache/heron/spi/common/KeysTest.java | 31 +++--
.../org/apache/heron/spi/common/TokenSubTest.java | 31 +++--
.../spi/metricsmgr/metrics/ExceptionInfoTest.java | 31 +++--
.../spi/metricsmgr/metrics/MetricsInfoTest.java | 31 +++--
.../spi/metricsmgr/metrics/MetricsRecordTest.java | 31 +++--
.../apache/heron/spi/packing/PackingPlanTest.java | 31 +++--
.../org/apache/heron/spi/packing/ResourceTest.java | 31 +++--
.../apache/heron/spi/utils/NetworkUtilsTest.java | 31 +++--
.../org/apache/heron/spi/utils/ShellUtilsTest.java | 31 +++--
.../apache/heron/spi/utils/UploaderUtilsTest.java | 31 +++--
.../heron/statefulstorage/dlog/DlogStorage.java | 32 +++--
.../heron/statefulstorage/hdfs/HDFSStorage.java | 31 +++--
.../localfs/LocalFileSystemStorage.java | 31 +++--
.../StatefulStorageTestContext.java | 31 +++--
.../statefulstorage/dlog/DlogStorageTest.java | 32 +++--
.../statefulstorage/hdfs/HDFSStorageTest.java | 31 +++--
.../localfs/LocalFileSystemStorageTest.java | 31 +++--
.../src/cpp/statemgr/heron-localfilestatemgr.cpp | 25 ++--
.../src/cpp/statemgr/heron-localfilestatemgr.h | 25 ++--
.../statemgrs/src/cpp/statemgr/heron-statemgr.cpp | 25 ++--
heron/statemgrs/src/cpp/statemgr/heron-statemgr.h | 25 ++--
.../src/cpp/statemgr/heron-zkstatemgr.cpp | 25 ++--
.../statemgrs/src/cpp/statemgr/heron-zkstatemgr.h | 25 ++--
.../heron/statemgr/FileSystemStateManager.java | 31 +++--
.../apache/heron/statemgr/NullStateManager.java | 31 +++--
.../statemgr/localfs/LocalFileSystemContext.java | 31 +++--
.../heron/statemgr/localfs/LocalFileSystemKey.java | 32 +++--
.../localfs/LocalFileSystemStateManager.java | 31 +++--
.../apache/heron/statemgr/zookeeper/ZkContext.java | 31 +++--
.../apache/heron/statemgr/zookeeper/ZkUtils.java | 31 +++--
.../statemgr/zookeeper/ZkWatcherCallback.java | 31 +++--
.../zookeeper/curator/CuratorStateManager.java | 31 +++--
heron/statemgrs/tests/cpp/statetest.cpp | 25 ++--
heron/statemgrs/tests/cpp/zkstatemgr_unittest.cpp | 25 ++--
.../localfs/LocalFileSystemStateManagerTest.java | 31 +++--
.../heron/statemgr/zookeeper/ZkUtilsTest.java | 31 +++--
.../zookeeper/curator/CuratorStateManagerTest.java | 31 +++--
heron/stmgr/src/cpp/grouping/all-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/all-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/custom-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/custom-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/direct-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/direct-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/fields-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/fields-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/lowest-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/lowest-grouping.h | 25 ++--
heron/stmgr/src/cpp/grouping/shuffle-grouping.cpp | 25 ++--
heron/stmgr/src/cpp/grouping/shuffle-grouping.h | 25 ++--
heron/stmgr/src/cpp/manager/checkpoint-gateway.cpp | 25 ++--
heron/stmgr/src/cpp/manager/checkpoint-gateway.h | 25 ++--
heron/stmgr/src/cpp/manager/ckptmgr-client.cpp | 25 ++--
heron/stmgr/src/cpp/manager/ckptmgr-client.h | 25 ++--
heron/stmgr/src/cpp/manager/instance-server.cpp | 25 ++--
heron/stmgr/src/cpp/manager/instance-server.h | 25 ++--
heron/stmgr/src/cpp/manager/stateful-restorer.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stateful-restorer.h | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-client.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-client.h | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-clientmgr.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-clientmgr.h | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-server.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stmgr-server.h | 25 ++--
heron/stmgr/src/cpp/manager/stmgr.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stmgr.h | 25 ++--
heron/stmgr/src/cpp/manager/stream-consumers.cpp | 25 ++--
heron/stmgr/src/cpp/manager/stream-consumers.h | 25 ++--
heron/stmgr/src/cpp/manager/tmaster-client.cpp | 25 ++--
heron/stmgr/src/cpp/manager/tmaster-client.h | 25 ++--
heron/stmgr/src/cpp/server/stmgr-main.cpp | 25 ++--
heron/stmgr/src/cpp/util/neighbour-calculator.cpp | 25 ++--
heron/stmgr/src/cpp/util/neighbour-calculator.h | 25 ++--
heron/stmgr/src/cpp/util/rotating-map.cpp | 25 ++--
heron/stmgr/src/cpp/util/rotating-map.h | 25 ++--
heron/stmgr/src/cpp/util/tuple-cache.cpp | 25 ++--
heron/stmgr/src/cpp/util/tuple-cache.h | 25 ++--
heron/stmgr/src/cpp/util/xor-manager.cpp | 25 ++--
heron/stmgr/src/cpp/util/xor-manager.h | 25 ++--
.../tests/cpp/grouping/all-grouping_unittest.cpp | 25 ++--
.../cpp/grouping/custom-grouping_unittest.cpp | 25 ++--
.../cpp/grouping/fields-grouping_unittest.cpp | 25 ++--
.../cpp/grouping/lowest-grouping_unittest.cpp | 25 ++--
.../cpp/grouping/shuffle-grouping_unittest.cpp | 25 ++--
.../cpp/server/checkpoint-gateway_unittest.cpp | 25 ++--
.../tests/cpp/server/dummy_ckptmgr_client.cpp | 25 ++--
.../stmgr/tests/cpp/server/dummy_ckptmgr_client.h | 25 ++--
heron/stmgr/tests/cpp/server/dummy_instance.cpp | 25 ++--
heron/stmgr/tests/cpp/server/dummy_instance.h | 25 ++--
.../stmgr/tests/cpp/server/dummy_instance_server.h | 25 ++--
heron/stmgr/tests/cpp/server/dummy_metricsmgr.cpp | 25 ++--
heron/stmgr/tests/cpp/server/dummy_metricsmgr.h | 25 ++--
heron/stmgr/tests/cpp/server/dummy_stmgr.cpp | 25 ++--
heron/stmgr/tests/cpp/server/dummy_stmgr.h | 25 ++--
.../stmgr/tests/cpp/server/dummy_stmgr_clientmgr.h | 25 ++--
heron/stmgr/tests/cpp/server/dummy_tuple_cache.h | 25 ++--
.../cpp/server/stateful-restorer_unittest.cpp | 25 ++--
heron/stmgr/tests/cpp/server/stmgr_unittest.cpp | 25 ++--
.../cpp/util/neighbour_calculator_unittest.cpp | 25 ++--
.../stmgr/tests/cpp/util/rotating-map_unittest.cpp | 25 ++--
.../stmgr/tests/cpp/util/tuple-cache_unittest.cpp | 25 ++--
.../stmgr/tests/cpp/util/xor-manager_unittest.cpp | 25 ++--
heron/tmaster/src/cpp/manager/ckptmgr-client.cpp | 25 ++--
heron/tmaster/src/cpp/manager/ckptmgr-client.h | 25 ++--
.../src/cpp/manager/stateful-checkpointer.cpp | 25 ++--
.../src/cpp/manager/stateful-checkpointer.h | 25 ++--
.../src/cpp/manager/stateful-controller.cpp | 25 ++--
.../tmaster/src/cpp/manager/stateful-controller.h | 25 ++--
.../tmaster/src/cpp/manager/stateful-restorer.cpp | 25 ++--
heron/tmaster/src/cpp/manager/stateful-restorer.h | 25 ++--
heron/tmaster/src/cpp/manager/stats-interface.cpp | 25 ++--
heron/tmaster/src/cpp/manager/stats-interface.h | 25 ++--
heron/tmaster/src/cpp/manager/stmgrstate.cpp | 25 ++--
heron/tmaster/src/cpp/manager/stmgrstate.h | 25 ++--
heron/tmaster/src/cpp/manager/tcontroller.cpp | 25 ++--
heron/tmaster/src/cpp/manager/tcontroller.h | 25 ++--
heron/tmaster/src/cpp/manager/tmaster.cpp | 25 ++--
heron/tmaster/src/cpp/manager/tmaster.h | 25 ++--
heron/tmaster/src/cpp/manager/tmasterserver.cpp | 25 ++--
heron/tmaster/src/cpp/manager/tmasterserver.h | 25 ++--
.../tmaster/src/cpp/manager/tmetrics-collector.cpp | 25 ++--
heron/tmaster/src/cpp/manager/tmetrics-collector.h | 25 ++--
heron/tmaster/src/cpp/processor/processor.h | 25 ++--
.../cpp/processor/stmgr-heartbeat-processor.cpp | 25 ++--
.../src/cpp/processor/stmgr-heartbeat-processor.h | 25 ++--
.../src/cpp/processor/stmgr-register-processor.cpp | 25 ++--
.../src/cpp/processor/stmgr-register-processor.h | 25 ++--
.../src/cpp/processor/tmaster-processor.cpp | 25 ++--
.../tmaster/src/cpp/processor/tmaster-processor.h | 25 ++--
heron/tmaster/src/cpp/server/tmaster-main.cpp | 25 ++--
heron/tmaster/tests/cpp/server/dummystmgr.cpp | 25 ++--
heron/tmaster/tests/cpp/server/dummystmgr.h | 25 ++--
heron/tmaster/tests/cpp/server/dummytmaster.cpp | 25 ++--
heron/tmaster/tests/cpp/server/dummytmaster.h | 25 ++--
.../cpp/server/stateful_checkpointer_unittest.cpp | 25 ++--
.../cpp/server/stateful_restorer_unittest.cpp | 25 ++--
.../tests/cpp/server/tcontroller_unittest.cpp | 25 ++--
.../tmaster/tests/cpp/server/tmaster_unittest.cpp | 25 ++--
.../java/org/apache/heron/apiserver/Constants.java | 32 +++--
.../java/org/apache/heron/apiserver/Resources.java | 32 +++--
.../java/org/apache/heron/apiserver/Runtime.java | 32 +++--
.../org/apache/heron/apiserver/actions/Action.java | 32 +++--
.../heron/apiserver/actions/ActionFactory.java | 32 +++--
.../heron/apiserver/actions/ActionFactoryImpl.java | 32 +++--
.../apache/heron/apiserver/actions/ActionType.java | 32 +++--
.../org/apache/heron/apiserver/actions/Keys.java | 32 +++--
.../apiserver/actions/SubmitTopologyAction.java | 32 +++--
.../apiserver/actions/TopologyRuntimeAction.java | 32 +++--
.../apiserver/resources/ConfigurationResource.java | 32 +++--
.../heron/apiserver/resources/FileResource.java | 32 +++--
.../apache/heron/apiserver/resources/Forms.java | 32 +++--
.../heron/apiserver/resources/HeronResource.java | 32 +++--
.../resources/NotFoundExceptionHandler.java | 32 +++--
.../apiserver/resources/TopologyResource.java | 32 +++--
.../apache/heron/apiserver/utils/ConfigUtils.java | 32 +++--
.../apache/heron/apiserver/utils/FileHelper.java | 32 +++--
.../org/apache/heron/apiserver/utils/Logging.java | 32 +++--
.../org/apache/heron/apiserver/utils/Utils.java | 32 +++--
.../apiserver/resources/TopologyResourceTests.java | 32 +++--
.../heron/apiserver/utils/ConfigUtilsTests.java | 32 +++--
.../org/apache/heron/uploader/NullUploader.java | 31 +++--
.../org/apache/heron/uploader/dlog/Copier.java | 32 +++--
.../org/apache/heron/uploader/dlog/DLContext.java | 32 +++--
.../org/apache/heron/uploader/dlog/DLCopier.java | 32 +++--
.../org/apache/heron/uploader/dlog/DLUploader.java | 32 +++--
.../org/apache/heron/uploader/gcs/GcsContext.java | 32 +++--
.../apache/heron/uploader/gcs/GcsController.java | 32 +++--
.../org/apache/heron/uploader/gcs/GcsUploader.java | 32 +++--
.../apache/heron/uploader/hdfs/HdfsContext.java | 31 +++--
.../apache/heron/uploader/hdfs/HdfsController.java | 31 +++--
.../apache/heron/uploader/hdfs/HdfsUploader.java | 31 +++--
.../apache/heron/uploader/http/HttpUploader.java | 32 +++--
.../heron/uploader/http/HttpUploaderContext.java | 32 +++--
.../uploader/localfs/LocalFileSystemContext.java | 31 +++--
.../heron/uploader/localfs/LocalFileSystemKey.java | 32 +++--
.../uploader/localfs/LocalFileSystemUploader.java | 31 +++--
.../org/apache/heron/uploader/s3/S3Context.java | 31 +++--
.../org/apache/heron/uploader/s3/S3Uploader.java | 31 +++--
.../org/apache/heron/uploader/scp/ScpContext.java | 31 +++--
.../apache/heron/uploader/scp/ScpController.java | 31 +++--
.../org/apache/heron/uploader/scp/ScpUploader.java | 31 +++--
.../heron/uploader/dlog/DlogUploaderTest.java | 32 +++--
.../heron/uploader/gcs/GcsUploaderTests.java | 32 +++--
.../heron/uploader/hdfs/HdfsUploaderTest.java | 31 +++--
.../heron/uploader/http/HttpUploaderTest.java | 32 +++--
.../localfs/LocalFileSystemConfigTest.java | 31 +++--
.../localfs/LocalFileSystemConstantsTest.java | 31 +++--
.../localfs/LocalFileSystemContextTest.java | 32 +++--
.../localfs/LocalFileSystemUploaderTest.java | 31 +++--
.../apache/heron/uploader/s3/S3UploaderTest.java | 31 +++--
.../apache/heron/uploader/scp/ScpUploaderTest.java | 31 +++--
.../common/AbstractTestTopology.java | 32 +++--
.../heron/integration_test/common/BasicConfig.java | 32 +++--
.../heron/integration_test/common/HdfsHelper.java | 32 +++--
.../common/bolt/CountAggregatorBolt.java | 32 +++--
.../common/bolt/DoubleTuplesBolt.java | 32 +++--
.../integration_test/common/bolt/IdentityBolt.java | 32 +++--
.../common/bolt/IncrementBolt.java | 32 +++--
.../common/bolt/JSONTweetFilterBolt.java | 32 +++--
.../common/bolt/LocalWriteBolt.java | 32 +++--
.../common/bolt/MapAggregatorBolt.java | 32 +++--
.../common/bolt/PartialUniquerBolt.java | 32 +++--
.../common/bolt/TweetPropertyBolt.java | 32 +++--
.../common/bolt/WordCountBolt.java | 32 +++--
.../integration_test/common/spout/ABSpout.java | 32 +++--
.../common/spout/HdfsStringSpout.java | 32 +++--
.../common/spout/LocalFileSpout.java | 32 +++--
.../common/spout/PausedLocalFileSpout.java | 32 +++--
.../integration_test/core/AggregatorBolt.java | 32 +++--
.../heron/integration_test/core/BaseBatchBolt.java | 32 +++--
.../heron/integration_test/core/Condition.java | 32 +++--
.../heron/integration_test/core/Constants.java | 32 +++--
.../core/EmitUntilConditionTestSpout.java | 32 +++--
.../integration_test/core/HttpGetCondition.java | 32 +++--
.../heron/integration_test/core/HttpUtils.java | 32 +++--
.../heron/integration_test/core/IBatchBolt.java | 32 +++--
.../heron/integration_test/core/ITerminalBolt.java | 32 +++--
.../integration_test/core/IntegrationTestBolt.java | 32 +++--
.../core/IntegrationTestSpout.java | 32 +++--
.../integration_test/core/LocalAggregatorBolt.java | 32 +++--
.../integration_test/core/MultiPhaseTestSpout.java | 32 +++--
.../core/StatefulIntegrationTestBolt.java | 31 +++--
.../core/StatefulIntegrationTestSpout.java | 32 +++--
.../integration_test/core/TestTopologyBuilder.java | 32 +++--
.../integration_test/core/TestTopologyContext.java | 32 +++--
.../topology/all_grouping/AllGrouping.java | 32 +++--
.../BasicTopologyOneTask.java | 32 +++--
.../BoltDoubleEmitTuples.java | 32 +++--
.../topology/fields_grouping/FieldsGrouping.java | 32 +++--
.../topology/global_grouping/GlobalGrouping.java | 32 +++--
.../MultiSpoutsMultiTasks.java | 32 +++--
.../topology/non_grouping/NonGrouping.java | 32 +++--
.../one_bolt_multi_tasks/OneBoltMultiTasks.java | 32 +++--
.../OneSpoutBoltMultiTasks.java | 32 +++--
.../one_spout_multi_tasks/OneSpoutMultiTasks.java | 32 +++--
.../one_spout_two_bolts/OneSpoutTwoBolts.java | 32 +++--
.../topology/serialization/CustomCheckBolt.java | 32 +++--
.../topology/serialization/CustomObject.java | 32 +++--
.../topology/serialization/CustomSpout.java | 32 +++--
.../serialization/SerializationTopology.java | 32 +++--
.../topology/shuffle_grouping/ShuffleGrouping.java | 32 +++--
.../topology/windowing/WindowTestBase.java | 32 +++--
.../windowing/count/SlidingCountWindowTest1.java | 32 +++--
.../windowing/count/SlidingCountWindowTest2.java | 32 +++--
.../windowing/count/SlidingCountWindowTest3.java | 32 +++--
.../windowing/count/TumblingCountWindowTest1.java | 32 +++--
.../windowing/count/TumblingCountWindowTest2.java | 32 +++--
.../windowing/count/TumblingCountWindowTest3.java | 32 +++--
.../windowing/stateful/StatefulWindowingTest.java | 31 +++--
.../windowing/time/SlidingTimeWindowTest1.java | 32 +++--
.../SlidingWatermarkEventTimeWindowTest1.java | 32 +++--
.../local_readwrite/LocalReadWriteTopology.java | 32 +++--
third_party/java/bazel/Empty.java | 31 +++--
.../org/apache/bazel/checkstyle/CppCheckstyle.java | 32 +++--
.../apache/bazel/checkstyle/ExtraActionUtils.java | 32 +++--
.../apache/bazel/checkstyle/JavaCheckstyle.java | 32 +++--
.../apache/bazel/checkstyle/PythonCheckstyle.java | 32 +++--
.../org/apache/bazel/checkstyle/heron_header.txt | 31 +++--
1241 files changed, 20012 insertions(+), 16385 deletions(-)
--
To stop receiving notification emails like this one, please contact
karthikz@apache.org.