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 <kart...@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 karth...@apache.org.