eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject [51/84] [partial] eagle git commit: Clean repo for eagle site
Date Mon, 03 Apr 2017 11:54:59 GMT
Clean repo for eagle site


Project: http://git-wip-us.apache.org/repos/asf/eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/eagle/commit/6fd95d5c
Tree: http://git-wip-us.apache.org/repos/asf/eagle/tree/6fd95d5c
Diff: http://git-wip-us.apache.org/repos/asf/eagle/diff/6fd95d5c

Branch: refs/heads/site
Commit: 6fd95d5c85c0c868c781cc294dd14ebf34b8c267
Parents: ee55054
Author: Hao Chen <hchen9@ebay.com>
Authored: Mon Apr 3 19:51:47 2017 +0800
Committer: Hao Chen <hchen9@ebay.com>
Committed: Mon Apr 3 19:51:47 2017 +0800

----------------------------------------------------------------------
 CONTRIBUTING.md                                 |     30 -
 DISCLAIMER                                      |     11 -
 KEYS                                            |    144 -
 LICENSE                                         |    237 -
 NOTICE                                          |      5 -
 README.md                                       |     98 -
 docs/README.md                                  |      2 -
 docs/bin/demo-service.sh                        |    127 -
 docs/bin/doc-env.conf                           |      7 -
 docs/docs/applications.md                       |    378 -
 docs/docs/developing-application.md             |    285 -
 docs/docs/getting-started.md                    |    233 -
 docs/docs/hadoop-jmx-metrics-list.txt           |   1936 -
 docs/docs/include/images/add_publisher.png      |    Bin 24212 -> 0 bytes
 docs/docs/include/images/alert_alerts.png       |    Bin 153760 -> 0 bytes
 .../docs/include/images/alert_define_policy.png |    Bin 109258 -> 0 bytes
 docs/docs/include/images/alert_details.png      |    Bin 72058 -> 0 bytes
 docs/docs/include/images/alert_engine.png       |    Bin 142662 -> 0 bytes
 .../images/alert_engine_coordination.png        |    Bin 141897 -> 0 bytes
 .../include/images/alert_engine_policy_spec.png |    Bin 146211 -> 0 bytes
 docs/docs/include/images/alert_policies.png     |    Bin 52873 -> 0 bytes
 docs/docs/include/images/configure_site.png     |    Bin 91752 -> 0 bytes
 docs/docs/include/images/dashboard.png          |    Bin 35788 -> 0 bytes
 .../include/images/define_jmx_alert_policy.png  |    Bin 318973 -> 0 bytes
 docs/docs/include/images/delete_icon.png        |    Bin 4330 -> 0 bytes
 docs/docs/include/images/eagle_arch_v0.5.0.png  |    Bin 408403 -> 0 bytes
 docs/docs/include/images/eagle_ecosystem.png    |    Bin 274201 -> 0 bytes
 .../docs/include/images/eagle_web_interface.png |    Bin 72605 -> 0 bytes
 docs/docs/include/images/edit_icon.png          |    Bin 4224 -> 0 bytes
 docs/docs/include/images/favicon.png            |    Bin 4209 -> 0 bytes
 .../include/images/hadoop_queue_monitor_1.png   |    Bin 90402 -> 0 bytes
 .../include/images/hadoop_queue_monitor_2.png   |    Bin 250649 -> 0 bytes
 .../include/images/hadoop_queue_monitor_3.png   |    Bin 156044 -> 0 bytes
 .../include/images/hadoop_queue_monitor_4.png   |    Bin 162481 -> 0 bytes
 .../include/images/hadoop_queue_monitor_5.png   |    Bin 156116 -> 0 bytes
 .../include/images/hadoop_queue_monitor_6.png   |    Bin 93578 -> 0 bytes
 .../include/images/hadoop_queue_monitor_7.png   |    Bin 300928 -> 0 bytes
 docs/docs/include/images/hdfs_audit_log.png     |    Bin 183176 -> 0 bytes
 docs/docs/include/images/hdfs_install_1.png     |    Bin 397610 -> 0 bytes
 docs/docs/include/images/hdfs_install_2.png     |    Bin 292470 -> 0 bytes
 docs/docs/include/images/hdfs_install_3.png     |    Bin 264754 -> 0 bytes
 docs/docs/include/images/hdfs_policy_1.png      |    Bin 301293 -> 0 bytes
 .../images/health_check_installation.png        |    Bin 49680 -> 0 bytes
 .../docs/include/images/health_check_policy.png |    Bin 85461 -> 0 bytes
 .../include/images/health_check_settings.png    |    Bin 38682 -> 0 bytes
 .../docs/include/images/health_check_stream.png |    Bin 43105 -> 0 bytes
 docs/docs/include/images/install_jmx_2.png      |    Bin 301008 -> 0 bytes
 docs/docs/include/images/install_jmx_3.png      |    Bin 239960 -> 0 bytes
 docs/docs/include/images/install_jmx_6.png      |    Bin 226890 -> 0 bytes
 .../include/images/integration_applications.png |    Bin 98769 -> 0 bytes
 docs/docs/include/images/integration_sites.png  |    Bin 67355 -> 0 bytes
 docs/docs/include/images/jpm.jpg                |    Bin 40457 -> 0 bytes
 docs/docs/include/images/jpm_configure.png      |    Bin 360754 -> 0 bytes
 docs/docs/include/images/jpm_define_policy.png  |    Bin 769852 -> 0 bytes
 docs/docs/include/images/jpm_streams.png        |    Bin 333994 -> 0 bytes
 docs/docs/include/images/new_site.png           |    Bin 25714 -> 0 bytes
 docs/docs/include/images/overview.png           |    Bin 98222 -> 0 bytes
 docs/docs/include/images/site_list.png          |    Bin 76104 -> 0 bytes
 docs/docs/include/images/start_icon.png         |    Bin 4091 -> 0 bytes
 docs/docs/include/images/stop_icon.png          |    Bin 3872 -> 0 bytes
 docs/docs/include/images/storage_engine.png     |    Bin 70546 -> 0 bytes
 docs/docs/index.html                            |      6 -
 docs/docs/index.md                              |     93 -
 docs/docs/reference.md                          |    325 -
 docs/docs/underlying-design.md                  |    231 -
 docs/docs/using-eagle.md                        |    347 -
 docs/eagle-theme/__init__.py                    |      0
 docs/eagle-theme/base.html                      |    118 -
 docs/eagle-theme/breadcrumbs.html               |     25 -
 docs/eagle-theme/css/highlight.css              |    125 -
 docs/eagle-theme/css/theme.css                  |     12 -
 docs/eagle-theme/css/theme_extra.css            |    150 -
 docs/eagle-theme/fonts/fontawesome-webfont.eot  |    Bin 37405 -> 0 bytes
 docs/eagle-theme/fonts/fontawesome-webfont.svg  |    399 -
 docs/eagle-theme/fonts/fontawesome-webfont.ttf  |    Bin 79076 -> 0 bytes
 docs/eagle-theme/fonts/fontawesome-webfont.woff |    Bin 43572 -> 0 bytes
 docs/eagle-theme/footer.html                    |     23 -
 docs/eagle-theme/img/favicon.ico                |    Bin 1150 -> 0 bytes
 docs/eagle-theme/js/highlight.pack.js           |      2 -
 docs/eagle-theme/js/jquery-2.1.1.min.js         |      4 -
 docs/eagle-theme/js/modernizr-2.8.3.min.js      |      1 -
 docs/eagle-theme/js/theme.js                    |     55 -
 docs/eagle-theme/license/highlight.js/LICENSE   |     24 -
 docs/eagle-theme/search.html                    |     21 -
 docs/eagle-theme/searchbox.html                 |      5 -
 docs/eagle-theme/toc.html                       |     83 -
 docs/eagle-theme/versions.html                  |     15 -
 docs/mkdocs.yml                                 |     20 -
 eagle-assembly/pom.xml                          |     75 -
 eagle-assembly/src/assembly/eagle-bin.xml       |    110 -
 eagle-assembly/src/main/bin/eagle-env.sh        |     44 -
 eagle-assembly/src/main/bin/eagle-server.sh     |    136 -
 eagle-assembly/src/main/conf/eagle.conf         |    172 -
 eagle-assembly/src/main/conf/server.yml         |     97 -
 eagle-assembly/src/main/doc/README.md           |     99 -
 eagle-assembly/src/main/doc/metadata-ddl.sql    |    173 -
 .../eagle-alert-parent/eagle-alert-app/pom.xml  |     45 -
 .../eagle/alert/app/AlertEagleStorePlugin.java  |    107 -
 .../eagle/alert/app/AlertUnitTopologyApp.java   |     40 -
 .../alert/app/AlertUnitTopologyAppListener.java |     97 -
 .../alert/app/AlertUnitTopologyAppProvider.java |     37 -
 ...e.alert.app.AlertUnitTopologyAppProvider.xml |    142 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     18 -
 .../src/main/resources/application.conf         |     61 -
 .../app/AlertUnitTopologyAppProviderTest.java   |     69 -
 .../src/test/resource/application.conf          |     72 -
 .../eagle-alert-service/pom.xml                 |     64 -
 .../alert/resolver/AttributeResolvable.java     |     44 -
 .../resolver/AttributeResolveException.java     |     34 -
 .../resolver/AttributeResolveResource.java      |    100 -
 .../resolver/AttributeResolverFactory.java      |     54 -
 .../BadAttributeResolveRequestException.java    |     31 -
 .../GenericAttributeResolveRequest.java         |     54 -
 .../resolver/impl/BooleanAttributeResolver.java |     43 -
 .../resolver/impl/EntityAttributeResolver.java  |    149 -
 .../eagle-alert-parent/eagle-alert/.gitignore   |     80 -
 .../eagle-alert-parent/eagle-alert/README.md    |    155 -
 .../eagle-alert/alert-assembly/pom.xml          |    105 -
 .../src/assembly/alert-assembly.xml             |     53 -
 .../eagle-alert/alert-common/.gitignore         |      2 -
 .../eagle-alert/alert-common/pom.xml            |    176 -
 .../eagle/alert/config/ConfigBusBase.java       |     55 -
 .../eagle/alert/config/ConfigBusConsumer.java   |     66 -
 .../eagle/alert/config/ConfigBusProducer.java   |     48 -
 .../alert/config/ConfigChangeCallback.java      |     23 -
 .../apache/eagle/alert/config/ConfigValue.java  |     51 -
 .../org/apache/eagle/alert/config/ZKConfig.java |     35 -
 .../eagle/alert/config/ZKConfigBuilder.java     |     38 -
 .../alert/coordination/model/AlertBoltSpec.java |    133 -
 .../coordination/model/Kafka2TupleMetadata.java |     98 -
 .../coordination/model/PolicyWorkerQueue.java   |     84 -
 .../alert/coordination/model/PublishSpec.java   |     82 -
 .../alert/coordination/model/RouterSpec.java    |     98 -
 .../alert/coordination/model/ScheduleState.java |    223 -
 .../alert/coordination/model/SpoutSpec.java     |    126 -
 .../coordination/model/StreamNameSelector.java  |     29 -
 .../model/StreamRepartitionMetadata.java        |     72 -
 .../model/StreamRepartitionStrategy.java        |     82 -
 .../coordination/model/StreamRouterSpec.java    |     90 -
 .../model/Tuple2StreamConverter.java            |     94 -
 .../model/Tuple2StreamMetadata.java             |     89 -
 .../model/VersionedPolicyDefinition.java        |     49 -
 .../model/VersionedStreamDefinition.java        |     49 -
 .../alert/coordination/model/WorkSlot.java      |     78 -
 .../model/internal/MonitoredStream.java         |     88 -
 .../model/internal/PolicyAssignment.java        |     68 -
 .../model/internal/ScheduleStateBase.java       |     81 -
 .../model/internal/StreamGroup.java             |     93 -
 .../model/internal/StreamWorkSlotQueue.java     |    114 -
 .../coordination/model/internal/Topology.java   |    172 -
 .../alert/engine/codec/IEventSerializer.java    |     26 -
 .../engine/coordinator/AlertDefinition.java     |    106 -
 .../alert/engine/coordinator/AlertSeverity.java |     21 -
 .../coordinator/OverrideDeduplicatorSpec.java   |     66 -
 .../engine/coordinator/PolicyDefinition.java    |    312 -
 .../engine/coordinator/PublishPartition.java    |    121 -
 .../alert/engine/coordinator/Publishment.java   |    178 -
 .../engine/coordinator/PublishmentType.java     |    151 -
 .../alert/engine/coordinator/StreamColumn.java  |    237 -
 .../engine/coordinator/StreamDefinition.java    |    210 -
 .../engine/coordinator/StreamPartition.java     |    151 -
 .../engine/coordinator/StreamSortSpec.java      |    106 -
 .../engine/coordinator/StreamingCluster.java    |     87 -
 .../alert/engine/model/AlertPublishEvent.java   |    184 -
 .../alert/engine/model/AlertStreamEvent.java    |    190 -
 .../alert/engine/model/PartitionedEvent.java    |    153 -
 .../eagle/alert/engine/model/StreamEvent.java   |    165 -
 .../alert/engine/model/StreamEventBuilder.java  |     96 -
 .../eagle/alert/metric/IMetricSystem.java       |     61 -
 .../eagle/alert/metric/MetricConfigs.java       |     25 -
 .../apache/eagle/alert/metric/MetricSystem.java |    124 -
 .../eagle/alert/metric/entity/MetricEvent.java  |    112 -
 .../alert/metric/reporter/KafkaReporter.java    |    208 -
 .../eagle/alert/metric/sink/ConsoleSink.java    |     48 -
 .../alert/metric/sink/ElasticSearchSink.java    |     93 -
 .../apache/eagle/alert/metric/sink/JmxSink.java |     47 -
 .../eagle/alert/metric/sink/KafkaSink.java      |     66 -
 .../eagle/alert/metric/sink/MetricSink.java     |     31 -
 .../alert/metric/sink/MetricSinkRepository.java |     47 -
 .../eagle/alert/metric/sink/Slf4jSink.java      |     76 -
 .../alert/metric/source/JVMMetricSource.java    |     41 -
 .../eagle/alert/metric/source/MetricSource.java |     25 -
 .../metric/source/MetricSourceWrapper.java      |     39 -
 .../eagle/alert/resource/SimpleCORSFiler.java   |     58 -
 .../alert/service/IMetadataServiceClient.java   |    100 -
 .../service/MetadataServiceClientImpl.java      |    305 -
 .../siddhiext/StringEmptyFunctionExtension.java |     86 -
 .../StringListSizeFunctionExtension.java        |    100 -
 .../StringSubtractFunctionExtension.java        |    106 -
 .../eagle/alert/utils/AlertConstants.java       |     34 -
 .../org/apache/eagle/alert/utils/ByteUtils.java |    188 -
 .../apache/eagle/alert/utils/ConfigUtils.java   |     32 -
 .../org/apache/eagle/alert/utils/HostUtils.java |     87 -
 .../org/apache/eagle/alert/utils/JsonUtils.java |     56 -
 .../apache/eagle/alert/utils/KafkaEmbedded.java |     98 -
 .../eagle/alert/utils/StreamIdConversion.java   |     33 -
 .../alert/utils/StreamValidationException.java  |     39 -
 .../eagle/alert/utils/StreamValidator.java      |     57 -
 .../eagle/alert/utils/TimePeriodUtils.java      |     49 -
 .../eagle/alert/utils/ZookeeperEmbedded.java    |    113 -
 .../src/main/resources/log4j.properties         |     19 -
 .../src/main/resources/string.siddhiext         |     20 -
 .../eagle/alert/config/TestConfigBus.java       |     85 -
 .../eagle/alert/config/TestZKConfigBuilder.java |     37 -
 .../model/Kafka2TupleMetadataTest.java          |     49 -
 .../model/PolicyWorkerQueueTest.java            |     63 -
 .../model/StreamRepartitionStrategyTest.java    |     74 -
 .../model/StreamRouterSpecTest.java             |     59 -
 .../model/Tuple2StreamMetadataTest.java         |     50 -
 .../alert/coordination/model/WorkSlotTest.java  |     43 -
 .../model/internal/AlertDefinitionTest.java     |     50 -
 .../model/internal/MonitoredStreamTest.java     |     69 -
 .../model/internal/PolicyAssignmentTest.java    |     37 -
 .../model/internal/StreamGroupTest.java         |     68 -
 .../model/internal/StreamWorkSlotQueueTest.java |     61 -
 .../model/internal/TopologyTest.java            |     47 -
 .../OverrideDeduplicatorSpecTest.java           |     61 -
 .../coordinator/PolicyDefinitionTest.java       |    140 -
 .../engine/coordinator/PublishmentTest.java     |    100 -
 .../engine/coordinator/PublishmentTypeTest.java |     46 -
 .../engine/coordinator/StreamColumnTest.java    |    153 -
 .../coordinator/StreamDefinitionTest.java       |     52 -
 .../engine/coordinator/StreamPartitionTest.java |     43 -
 .../engine/coordinator/StreamSortSpecTest.java  |     45 -
 .../coordinator/StreamingClusterTest.java       |     47 -
 .../engine/model/AlertPublishEventTest.java     |    111 -
 .../engine/model/AlertStreamEventTest.java      |     55 -
 .../engine/model/PartitionedEventTest.java      |     54 -
 .../engine/model/StreamEventBuilderTest.java    |    166 -
 .../alert/engine/model/StreamEventTest.java     |    204 -
 .../eagle/alert/metric/MetricSystemTest.java    |    449 -
 .../service/TestMetadataServiceClientImpl.java  |     40 -
 .../eagle/alert/util/ConfigUtilsTest.java       |     76 -
 .../apache/eagle/alert/util/JsonUtilsTest.java  |     47 -
 .../alert/util/StreamIdConversionTest.java      |     46 -
 .../eagle/alert/util/TimePeriodUtilsTest.java   |    100 -
 .../apache/eagle/correlation/meta/JsonTest.java |     39 -
 .../correlation/meta/StreamPartitionTest.java   |     36 -
 .../StringListSizeFunctionExtensionTest.java    |    111 -
 .../StringSubtractFunctionExtensionTest.java    |     68 -
 .../src/test/resources/application.conf         |     39 -
 .../src/test/resources/log4j.properties         |     19 -
 .../src/test/resources/streamDef.json           |     45 -
 .../src/test/resources/string.siddhiext         |     20 -
 .../eagle-alert/alert-coordinator/.gitignore    |      1 -
 .../eagle-alert/alert-coordinator/pom.xml       |    113 -
 .../eagle/alert/coordinator/Coordinator.java    |    272 -
 .../alert/coordinator/CoordinatorConstants.java |     29 -
 .../alert/coordinator/CoordinatorListener.java  |     44 -
 .../alert/coordinator/ExclusiveExecutor.java    |    130 -
 .../alert/coordinator/IPolicyScheduler.java     |     33 -
 .../alert/coordinator/IScheduleContext.java     |     53 -
 .../LockWebApplicationException.java            |     34 -
 .../coordinator/PolicySchedulerFactory.java     |     29 -
 .../eagle/alert/coordinator/ScheduleOption.java |     72 -
 .../alert/coordinator/TopologyMgmtService.java  |     79 -
 .../eagle/alert/coordinator/ValidateState.java  |     90 -
 .../coordinator/impl/GreedyPolicyScheduler.java |    328 -
 .../coordinator/impl/MetadataValdiator.java     |    220 -
 .../impl/MonitorMetadataGenerator.java          |    292 -
 .../alert/coordinator/impl/ScheduleResult.java  |     39 -
 .../eagle/alert/coordinator/impl/WorkItem.java  |     33 -
 .../coordinator/impl/WorkQueueBuilder.java      |     92 -
 .../impl/strategies/IWorkSlotStrategy.java      |     30 -
 .../strategies/SameTopologySlotStrategy.java    |    177 -
 .../alert/coordinator/model/AlertBoltUsage.java |     91 -
 .../alert/coordinator/model/GroupBoltUsage.java |     65 -
 .../alert/coordinator/model/TopologyUsage.java  |    100 -
 .../provider/InMemScheduleConext.java           |    150 -
 .../provider/NodataMetadataGenerator.java       |    337 -
 .../provider/ScheduleContextBuilder.java        |    432 -
 .../resource/CoordinatorResource.java           |     94 -
 .../coordinator/trigger/CoordinatorTrigger.java |     82 -
 .../trigger/DynamicPolicyLoader.java            |    103 -
 .../trigger/PolicyChangeListener.java           |     25 -
 .../trigger/ScheduleStateCleaner.java           |     53 -
 .../alert/coordinator/CoordinatorTest.java      |    135 -
 .../coordinator/DynamicPolicyLoaderTest.java    |     27 -
 .../MetadataServiceClientImplTest.java          |     56 -
 .../NodataMetadataGeneratorTest.java            |    103 -
 .../coordinator/ScheduleContextBuilderTest.java |    419 -
 .../apache/alert/coordinator/SchedulerTest.java |    724 -
 .../coordinator/TestExclusiveExecutor.java      |    110 -
 .../TestGreedyScheduleCoordinator.java          |    134 -
 .../coordinator/TestMetadataValidator.java      |     41 -
 .../alert/coordinator/WorkSlotStrategyTest.java |    302 -
 .../mock/InMemMetadataServiceClient.java        |    206 -
 .../mock/TestTopologyMgmtService.java           |    100 -
 .../resources/application-multiplestreams.conf  |     53 -
 .../resources/application-multiplestreams2.conf |     52 -
 .../src/test/resources/application.conf         |     58 -
 .../src/test/resources/log4j.properties         |     19 -
 .../src/test/resources/multi/datasources.json   |     19 -
 .../src/test/resources/multi/policies.json      |     52 -
 .../src/test/resources/multi/publishments.json  |     32 -
 .../test/resources/multi/streamdefinitions.json |    152 -
 .../src/test/resources/multi/topologies.json    |     31 -
 .../src/test/resources/test-application.conf    |     51 -
 .../test/resources/validation/datasources.json  |     86 -
 .../src/test/resources/validation/policies.json |    572 -
 .../test/resources/validation/publishments.json |    113 -
 .../resources/validation/streamdefinitions.json |   2218 -
 .../test/resources/validation/topologies.json   |     42 -
 .../eagle-alert/alert-devtools/.gitignore       |      3 -
 .../bin/kafka-console-consumer.sh               |     18 -
 .../alert-devtools/bin/kafka-producer.sh        |     21 -
 .../alert-devtools/bin/kafka-server-start.sh    |     51 -
 .../alert-devtools/bin/kafka-server-status.sh   |     24 -
 .../alert-devtools/bin/kafka-server-stop.sh     |     23 -
 .../alert-devtools/bin/kafka-topics.sh          |     17 -
 .../eagle-alert/alert-devtools/bin/run-class.sh |    112 -
 .../alert-devtools/bin/start-coordinator.sh     |     20 -
 .../alert-devtools/bin/start-integration1.sh    |     30 -
 .../alert-devtools/bin/start-integration2.sh    |     34 -
 .../alert-devtools/bin/start-metadata.sh        |     20 -
 .../alert-devtools/bin/start-sampleclient1.sh   |     20 -
 .../alert-devtools/bin/start-sampleclient2.sh   |     21 -
 .../alert-devtools/bin/start-zk-kafka.sh        |     28 -
 .../alert-devtools/bin/stop-zk-kafka.sh         |     28 -
 .../bin/zookeeper-server-start.sh               |     50 -
 .../bin/zookeeper-server-status.sh              |     24 -
 .../alert-devtools/bin/zookeeper-server-stop.sh |     24 -
 .../alert-devtools/conf/cli-log4j.properties    |     19 -
 .../alert-devtools/conf/kafka-server.properties |     87 -
 .../alert-devtools/conf/log4j.properties        |     19 -
 .../conf/zookeeper-server.properties            |     20 -
 .../eagle-alert/alert-devtools/pom.xml          |    108 -
 .../eagle/alert/tools/KafkaConsumerOffset.java  |     27 -
 .../alert/tools/KafkaConsumerOffsetFetcher.java |     65 -
 .../alert/tools/KafkaLatestOffsetFetcher.java   |    107 -
 .../eagle/contrib/kafka/ProducerTool.scala      |    230 -
 .../eagle/alert/tools/TestKafkaOffset.java      |     69 -
 .../kafka-offset-test.application.conf          |     24 -
 .../src/test/resources/log4j.properties         |     19 -
 .../eagle-alert/alert-engine/.gitignore         |      1 -
 .../eagle-alert/alert-engine/pom.xml            |    180 -
 .../alert/engine/AlertStreamCollector.java      |     28 -
 .../apache/eagle/alert/engine/Collector.java    |     27 -
 .../alert/engine/PartitionedEventCollector.java |     29 -
 .../alert/engine/StormMultiCountMetric.java     |     42 -
 .../eagle/alert/engine/StreamContext.java       |     41 -
 .../eagle/alert/engine/StreamContextImpl.java   |     41 -
 .../eagle/alert/engine/StreamCounter.java       |     25 -
 .../eagle/alert/engine/UnitTopologyMain.java    |    118 -
 .../IMetadataChangeNotifyService.java           |     57 -
 .../alert/engine/coordinator/MetadataType.java  |     30 -
 .../coordinator/StreamNotDefinedException.java  |     38 -
 .../AbstractMetadataChangeNotifyService.java    |    113 -
 .../impl/ZKMetadataChangeNotifyService.java     |    196 -
 .../evaluator/CompositePolicyHandler.java       |     96 -
 .../engine/evaluator/PolicyChangeListener.java  |     30 -
 .../engine/evaluator/PolicyGroupEvaluator.java  |     45 -
 .../engine/evaluator/PolicyHandlerContext.java  |     70 -
 .../engine/evaluator/PolicyStreamHandler.java   |     29 -
 .../engine/evaluator/PolicyStreamHandlers.java  |     68 -
 .../evaluator/absence/AbsenceAlertDriver.java   |     75 -
 .../evaluator/absence/AbsenceDailyRule.java     |     26 -
 .../evaluator/absence/AbsencePolicyHandler.java |    144 -
 .../engine/evaluator/absence/AbsenceRule.java   |     23 -
 .../engine/evaluator/absence/AbsenceWindow.java |     38 -
 .../absence/AbsenceWindowGenerator.java         |     52 -
 .../absence/AbsenceWindowProcessor.java         |     98 -
 ...ertBoltOutputCollectorThreadSafeWrapper.java |    121 -
 .../impl/AlertBoltOutputCollectorWrapper.java   |     96 -
 .../evaluator/impl/AlertStreamCallback.java     |     97 -
 .../impl/PolicyGroupEvaluatorImpl.java          |    180 -
 .../evaluator/impl/SiddhiDefinitionAdapter.java |    175 -
 .../evaluator/impl/SiddhiPolicyHandler.java     |    123 -
 .../impl/SiddhiPolicyStateHandler.java          |     62 -
 .../nodata/DistinctValuesInTimeBatchWindow.java |    128 -
 .../nodata/DistinctValuesInTimeWindow.java      |    140 -
 .../evaluator/nodata/NoDataPolicyHandler.java   |    202 -
 .../nodata/NoDataPolicyTimeBatchHandler.java    |    173 -
 .../evaluator/nodata/NoDataWisbParser.java      |     34 -
 .../nodata/NoDataWisbProvidedParser.java        |     46 -
 .../engine/evaluator/nodata/NoDataWisbType.java |     25 -
 .../engine/interpreter/PolicyExecutionPlan.java |    100 -
 .../interpreter/PolicyExecutionPlanner.java     |     31 -
 .../interpreter/PolicyExecutionPlannerImpl.java |    376 -
 .../engine/interpreter/PolicyInterpreter.java   |    116 -
 .../engine/interpreter/PolicyParseResult.java   |     65 -
 .../interpreter/PolicyValidationResult.java     |     76 -
 .../engine/publisher/AlertDeduplicator.java     |     34 -
 .../engine/publisher/AlertPublishListener.java  |     28 -
 .../engine/publisher/AlertPublishPlugin.java    |     56 -
 .../publisher/AlertPublishPluginProvider.java   |     24 -
 .../publisher/AlertPublishSpecListener.java     |     29 -
 .../alert/engine/publisher/AlertPublisher.java  |     37 -
 .../eagle/alert/engine/publisher/AlertSink.java |     25 -
 .../engine/publisher/AlertStreamFilter.java     |     26 -
 .../engine/publisher/PipeStreamFilter.java      |     46 -
 .../engine/publisher/PublishConstants.java      |     69 -
 .../publisher/PublishementTypeLoader.java       |     58 -
 .../engine/publisher/dedup/DedupCache.java      |    223 -
 .../engine/publisher/dedup/DedupEntity.java     |     73 -
 .../engine/publisher/dedup/DedupValue.java      |     96 -
 .../publisher/dedup/ExtendedDeduplicator.java   |     81 -
 .../publisher/email/AlertEmailConstants.java    |     34 -
 .../publisher/email/AlertEmailContext.java      |     81 -
 .../publisher/email/AlertEmailGenerator.java    |    224 -
 .../email/AlertEmailGeneratorBuilder.java       |     77 -
 .../publisher/email/AlertEmailSender.java       |    127 -
 .../engine/publisher/email/EagleMailClient.java |    230 -
 .../publisher/impl/AbstractPublishPlugin.java   |    111 -
 .../publisher/impl/AlertEagleStorePlugin.java   |     85 -
 .../publisher/impl/AlertEmailPublisher.java     |    223 -
 .../publisher/impl/AlertFilePublisher.java      |    114 -
 .../publisher/impl/AlertKafkaPublisher.java     |    197 -
 .../impl/AlertPublishPluginsFactory.java        |     50 -
 .../publisher/impl/AlertPublisherImpl.java      |    207 -
 .../publisher/impl/AlertSlackPublisher.java     |    173 -
 .../publisher/impl/DefaultDeduplicator.java     |    165 -
 .../alert/engine/publisher/impl/EventUniq.java  |     83 -
 .../publisher/impl/JsonEventSerializer.java     |     70 -
 .../publisher/impl/KafkaProducerManager.java    |    145 -
 .../engine/publisher/impl/KafkaWriteMode.java   |     33 -
 .../engine/publisher/impl/PublishStatus.java    |     27 -
 .../publisher/impl/StringEventSerializer.java   |     38 -
 .../publisher/template/AlertContextFields.java  |     44 -
 .../publisher/template/AlertTemplateEngine.java |     48 -
 .../template/AlertTemplateProvider.java         |     23 -
 .../template/VelocityAlertTemplateEngine.java   |    171 -
 .../template/VelocityTemplateParser.java        |     95 -
 .../engine/router/AlertBoltSpecListener.java    |     32 -
 .../alert/engine/router/SpoutSpecListener.java  |     32 -
 .../engine/router/StreamOutputCollector.java    |     33 -
 .../eagle/alert/engine/router/StreamRoute.java  |     86 -
 .../router/StreamRoutePartitionFactory.java     |     37 -
 .../engine/router/StreamRoutePartitioner.java   |     25 -
 .../engine/router/StreamRouteSpecListener.java  |     30 -
 .../eagle/alert/engine/router/StreamRouter.java |     33 -
 .../router/StreamRouterBoltSpecListener.java    |     33 -
 .../alert/engine/router/StreamSortHandler.java  |     34 -
 .../engine/router/StreamSortSpecListener.java   |     28 -
 .../impl/BasicStreamRoutePartitioner.java       |     77 -
 .../router/impl/RoutePhysicalGrouping.java      |     71 -
 .../engine/router/impl/ShuffleGrouping.java     |     69 -
 .../router/impl/StormOutputCollector.java       |     65 -
 .../impl/StreamRouterBoltOutputCollector.java   |    221 -
 .../engine/router/impl/StreamRouterImpl.java    |    165 -
 .../alert/engine/runner/AbstractStreamBolt.java |    148 -
 .../eagle/alert/engine/runner/AlertBolt.java    |    245 -
 .../alert/engine/runner/AlertPublisherBolt.java |    218 -
 .../alert/engine/runner/MapComparator.java      |     69 -
 .../engine/runner/StormMetricConsumer.java      |    133 -
 .../runner/StormMetricTaggedConsumer.java       |    170 -
 .../alert/engine/runner/StreamRouterBolt.java   |    194 -
 .../alert/engine/runner/UnitTopologyRunner.java |    280 -
 .../eagle/alert/engine/scheme/JsonScheme.java   |     73 -
 .../scheme/JsonStringStreamNameSelector.java    |     73 -
 .../alert/engine/scheme/PlainStringScheme.java  |     67 -
 .../scheme/PlainStringStreamNameSelector.java   |     51 -
 .../PartitionedEventDigestSerializer.java       |     62 -
 .../PartitionedEventSerializer.java             |     28 -
 .../SerializationMetadataProvider.java          |     32 -
 .../alert/engine/serialization/Serializer.java  |     27 -
 .../alert/engine/serialization/Serializers.java |     57 -
 .../serialization/impl/BooleanSerializer.java   |     35 -
 .../serialization/impl/DoubleSerializer.java    |     38 -
 .../serialization/impl/FloatSerializer.java     |     38 -
 .../serialization/impl/IntegerSerializer.java   |     38 -
 .../impl/JavaObjectSerializer.java              |     42 -
 .../serialization/impl/LongSerializer.java      |     38 -
 .../impl/PartitionedEventSerializerImpl.java    |    102 -
 .../impl/StreamEventSerializer.java             |    118 -
 .../impl/StreamPartitionDigestSerializer.java   |    103 -
 .../impl/StreamPartitionSerializer.java         |     80 -
 .../serialization/impl/StringSerializer.java    |     35 -
 .../extension/AttributeCollectAggregator.java   |    120 -
 .../AttributeCollectWithDistinctAggregator.java |    123 -
 .../extension/ContainsIgnoreCaseExtension.java  |     88 -
 .../extension/EqualsIgnoreCaseExtension.java    |     88 -
 .../RegexpIgnoreCaseFunctionExtension.java      |     90 -
 .../alert/engine/sorter/BaseStreamWindow.java   |    184 -
 .../alert/engine/sorter/StreamTimeClock.java    |     42 -
 .../engine/sorter/StreamTimeClockListener.java  |     28 -
 .../engine/sorter/StreamTimeClockManager.java   |     40 -
 .../engine/sorter/StreamTimeClockTrigger.java   |     56 -
 .../eagle/alert/engine/sorter/StreamWindow.java |    103 -
 .../engine/sorter/StreamWindowManager.java      |     59 -
 .../engine/sorter/StreamWindowRepository.java   |    252 -
 .../sorter/impl/CachedEventGroupSerializer.java |    115 -
 .../impl/PartitionedEventGroupSerializer.java   |    113 -
 .../PartitionedEventTimeOrderingComparator.java |     50 -
 .../impl/StreamSortWindowHandlerImpl.java       |    114 -
 .../sorter/impl/StreamSortedWindowInMapDB.java  |    139 -
 .../sorter/impl/StreamSortedWindowOnHeap.java   |     82 -
 .../impl/StreamTimeClockInLocalMemory.java      |     64 -
 .../sorter/impl/StreamTimeClockManagerImpl.java |    169 -
 .../sorter/impl/StreamWindowManagerImpl.java    |    176 -
 .../alert/engine/spout/CorrelationSpout.java    |    411 -
 .../alert/engine/spout/CreateTopicUtils.java    |     43 -
 .../eagle/alert/engine/spout/ISpoutSpecLCM.java |     42 -
 .../engine/spout/KafkaMessageIdWrapper.java     |     50 -
 .../eagle/alert/engine/spout/SchemeBuilder.java |     37 -
 .../spout/SpoutOutputCollectorWrapper.java      |    229 -
 .../alert/engine/utils/AlertStreamUtils.java    |     58 -
 .../alert/engine/utils/CompressionUtils.java    |     65 -
 .../alert/engine/utils/MetadataSerDeser.java    |    103 -
 .../alert/engine/utils/SerializableUtils.java   |    122 -
 .../alert/engine/utils/SingletonExecutor.java   |     44 -
 .../main/java/storm/kafka/KafkaSpoutMetric.java |     89 -
 .../java/storm/kafka/KafkaSpoutWrapper.java     |    111 -
 .../main/resources/ALERT_DEFAULT_TEMPLATE.vm    |    301 -
 .../main/resources/ALERT_INLINED_TEMPLATE.vm    |    259 -
 .../src/main/resources/ALERT_LIGHT_TEMPLATE.vm  |    495 -
 .../src/main/resources/application.conf         |     64 -
 .../src/main/resources/eagle.siddhiext          |     19 -
 .../src/main/resources/log4j.properties         |     24 -
 .../src/main/resources/str.siddhiext            |     40 -
 .../alert/engine/absence/TestAbsenceDriver.java |     96 -
 .../absence/TestAbsencePolicyHandler.java       |    111 -
 .../absence/TestAbsenceWindowGenerator.java     |     80 -
 .../absence/TestAbsenceWindowProcessor.java     |     70 -
 .../alert/engine/e2e/CoordinatorClient.java     |     92 -
 .../eagle/alert/engine/e2e/Integration1.java    |    228 -
 .../eagle/alert/engine/e2e/Integration2.java    |    146 -
 .../eagle/alert/engine/e2e/Integration3.java    |    104 -
 .../engine/e2e/Integration4NoDataAlert.java     |     95 -
 .../engine/e2e/Integration5AbsenceAlert.java    |     95 -
 .../e2e/MetadataServiceClientImpTest.java       |     74 -
 .../eagle/alert/engine/e2e/SampleClient1.java   |    126 -
 .../eagle/alert/engine/e2e/SampleClient2.java   |    140 -
 .../eagle/alert/engine/e2e/SampleClient3.java   |     93 -
 .../engine/e2e/SampleClient4NoDataAlert.java    |    137 -
 .../engine/e2e/SampleClient5AbsenceAlert.java   |     93 -
 ...oltOutputCollectorThreadSafeWrapperTest.java |     92 -
 .../engine/evaluator/PoilcyExtendedTest.java    |     67 -
 .../SiddhiCEPPolicyEventHandlerTest.java        |    160 -
 .../AlertBoltOutputCollectorWrapperTest.java    |    120 -
 .../integration/MockMetadataServiceClient.java  |    175 -
 .../interpreter/PolicyInterpreterTest.java      |    558 -
 .../engine/metric/MemoryUsageGaugeSetTest.java  |     46 -
 .../engine/mock/MockPartitionedCollector.java   |     56 -
 .../engine/mock/MockSampleMetadataFactory.java  |    255 -
 .../alert/engine/mock/MockStreamCollector.java  |     52 -
 .../engine/mock/MockStreamMetadataService.java  |     39 -
 .../alert/engine/mock/MockStreamReceiver.java   |     80 -
 .../TestDistinctValuesInTimeBatchWindow.java    |     88 -
 .../nodata/TestDistinctValuesInTimeWindow.java  |     71 -
 .../alert/engine/nodata/TestEventTable.java     |     53 -
 .../alert/engine/nodata/TestNoDataAlert.java    |    114 -
 .../engine/nodata/TestNoDataPolicyHandler.java  |    135 -
 .../TestNoDataPolicyTimeBatchHandler.java       |    158 -
 .../alert/engine/perf/TestSerDeserPer.java      |    325 -
 .../publisher/AlertEmailPublisherTest.java      |     74 -
 .../publisher/AlertFilePublisherTest.java       |     62 -
 .../publisher/AlertKafkaPublisherTest.java      |    170 -
 .../publisher/AlertPublisherTestHelper.java     |    113 -
 .../publisher/PublishementTypeLoaderTest.java   |     27 -
 .../engine/publisher/dedup/DedupCacheTest.java  |    131 -
 .../dedup/DefaultDedupWithoutStateTest.java     |    115 -
 .../dedup/DefaultDeduplicatorTest.java          |    176 -
 .../dedup/ExtendedDeduplicatorTest.java         |     92 -
 .../publisher/dedup/SimpleEmbedMongo.java       |     76 -
 .../publisher/dedup/TestDeduplicator.java       |     82 -
 .../VelocityAlertTemplateEngineTest.java        |    135 -
 .../template/VelocityTemplateParserTest.java    |     65 -
 .../template/VelocityTemplateTest.java          |     95 -
 .../alert/engine/router/CustomizedHandler.java  |     58 -
 .../alert/engine/router/TestAlertBolt.java      |    701 -
 .../engine/router/TestAlertPublisherBolt.java   |    303 -
 .../TestStreamRouterBoltOutputCollector.java    |    176 -
 .../engine/runner/TestStreamRouterBolt.java     |    273 -
 .../serialization/JavaSerializationTest.java    |    112 -
 .../PartitionedEventSerializerTest.java         |    219 -
 .../alert/engine/siddhi/SiddhiPolicyTest.java   |    280 -
 .../AttributeCollectAggregatorTest.java         |    148 -
 .../alert/engine/sorter/MapDBTestSuite.java     |     45 -
 .../engine/sorter/StreamSortHandlerTest.java    |    268 -
 .../sorter/StreamWindowBenchmarkTest.java       |    152 -
 .../engine/sorter/StreamWindowTestSuite.java    |    164 -
 .../sorter/TreeMultisetComparatorTest.java      |    109 -
 .../engine/statecheck/TestStateCheckPolicy.java |    163 -
 .../engine/topology/AlertTopologyTest.java      |    138 -
 .../CoordinatorSpoutIntegrationTest.java        |    100 -
 .../engine/topology/CorrelationSpoutTest.java   |    231 -
 .../engine/topology/FastWordCountTopology.java  |    209 -
 .../MockMetadataChangeNotifyService.java        |    111 -
 .../engine/topology/SendData2KafkaTest.java     |    101 -
 .../eagle/alert/engine/topology/TestBolt.java   |     59 -
 .../alert/engine/topology/TestByteBuffer.java   |     53 -
 .../topology/TestMetadataSpecSerDeser.java      |    247 -
 .../TestStormCustomGroupingRouting.java         |    148 -
 .../engine/topology/TestStormParallelism.java   |    164 -
 .../topology/TestStormStreamIdRouting.java      |    143 -
 .../topology/TestTuple2StreamConverter.java     |     56 -
 .../engine/topology/TestUnitTopologyMain.java   |     56 -
 .../engine/utils/CompressionUtilsTest.java      |     43 -
 .../resources/absence/application-absence.conf  |     60 -
 .../src/test/resources/absence/datasources.json |     17 -
 .../src/test/resources/absence/policies.json    |     26 -
 .../test/resources/absence/publishments.json    |     20 -
 .../resources/absence/streamdefinitions.json    |     29 -
 .../src/test/resources/absence/topologies.json  |     31 -
 .../resources/application-mongo-statestore.conf |     17 -
 .../test/resources/application-test-backup.conf |     71 -
 .../src/test/resources/application-test.conf    |     78 -
 .../correlation/application-integration-2.conf  |     60 -
 .../test/resources/correlation/datasources.json |     36 -
 .../test/resources/correlation/policies.json    |     39 -
 .../resources/correlation/publishments.json     |     18 -
 .../correlation/streamdefinitions.json          |     92 -
 .../test/resources/correlation/topologies.json  |     31 -
 .../test/resources/correlation_spouttest.conf   |     53 -
 .../src/test/resources/e2e/application-e2e.conf |     60 -
 .../src/test/resources/e2e/datasources.json     |     19 -
 .../src/test/resources/e2e/policies.json        |     26 -
 .../src/test/resources/e2e/publishments.json    |     17 -
 .../src/test/resources/e2e/sherlock.json        |     53 -
 .../test/resources/e2e/streamdefinitions.json   |     83 -
 .../src/test/resources/e2e/topologies.json      |     31 -
 .../src/test/resources/e2e/ump_demo_schema.json |    181 -
 .../src/test/resources/eagle.siddhiext          |     18 -
 .../src/test/resources/extend_policy.json       |     22 -
 .../src/test/resources/interpreter/policy.json  |     36 -
 .../src/test/resources/interpreter/streams.json |    524 -
 .../src/test/resources/log4j.properties         |     20 -
 .../test/resources/loopback/datasources.json    |     36 -
 .../src/test/resources/loopback/policies.json   |     50 -
 .../test/resources/loopback/publishments.json   |     16 -
 .../resources/loopback/streamdefinitions.json   |    195 -
 .../resources/nodata/application-nodata.conf    |     60 -
 .../src/test/resources/nodata/datasources.json  |     17 -
 .../nodata/policies-provided-wisb.json          |     23 -
 .../src/test/resources/nodata/policies.json     |     26 -
 .../src/test/resources/nodata/publishments.json |     20 -
 .../resources/nodata/streamdefinitions.json     |     29 -
 .../src/test/resources/nodata/topologies.json   |     31 -
 .../src/test/resources/publishments1.json       |     25 -
 .../src/test/resources/publishments2.json       |     25 -
 .../router/publishments-empty-dedup-field.json  |     23 -
 .../publishments-extended-deduplicator.json     |     31 -
 .../resources/router/publishments-slack.json    |     19 -
 .../src/test/resources/router/publishments.json |     25 -
 .../src/test/resources/sample_perfmon_data.json |     10 -
 .../simple/application-integration.conf         |     66 -
 .../src/test/resources/simple/datasources.json  |     19 -
 .../src/test/resources/simple/policies.json     |     81 -
 .../src/test/resources/simple/publishments.json |     34 -
 .../resources/simple/streamdefinitions.json     |     47 -
 .../src/test/resources/simple/topologies.json   |     41 -
 .../statecheck/application-statecheck.conf      |     60 -
 .../test/resources/statecheck/datasources.json  |     19 -
 .../src/test/resources/statecheck/policies.json |     38 -
 .../test/resources/statecheck/publishments.json |     28 -
 .../resources/statecheck/streamdefinitions.json |     98 -
 .../test/resources/statecheck/topologies.json   |     31 -
 .../src/test/resources/testAlertBoltSpec.json   |     92 -
 .../src/test/resources/testPublishForAdd0.json  |     26 -
 .../src/test/resources/testPublishForAdd1.json  |     38 -
 .../test/resources/testPublishForMdyValue.json  |     27 -
 .../src/test/resources/testPublishSpec.json     |     44 -
 .../src/test/resources/testPublishSpec2.json    |     42 -
 .../src/test/resources/testPublishSpec3.json    |     39 -
 .../src/test/resources/testSpoutSpec.json       |    139 -
 .../resources/testStreamDefinitionsSpec.json    |     47 -
 .../resources/testStreamRouterBoltSpec.json     |    123 -
 .../alert-engine/src/test/resources/topic.json  |      1 -
 .../alert-metadata-service/.gitignore           |      2 -
 .../alert-metadata-service/pom.xml              |    125 -
 .../metadata/resource/MetadataResource.java     |    525 -
 .../resource/StreamDefinitionWrapper.java       |     72 -
 .../topology/resource/TopologyMgmtResource.java |     67 -
 .../impl/TopologyMgmtResourceHelper.java        |     48 -
 .../resource/impl/TopologyMgmtResourceImpl.java |    159 -
 .../topology/resource/impl/TopologyStatus.java  |     82 -
 .../impl/TopologyMgmtResourceImplTest.java      |    127 -
 .../src/test/resources/application.conf         |     24 -
 .../alert-metadata/.gitignore                   |      2 -
 .../alert-metadata/pom.xml                      |    102 -
 .../eagle/alert/metadata/IMetadataDao.java      |    201 -
 .../eagle/alert/metadata/MetadataUtils.java     |     92 -
 .../metadata/impl/InMemMetadataDaoImpl.java     |    362 -
 .../metadata/impl/JdbcMetadataDaoImpl.java      |    264 -
 .../metadata/impl/JdbcMetadataHandler.java      |    506 -
 .../alert/metadata/impl/JdbcSchemaManager.java  |    157 -
 .../alert/metadata/impl/MetadataDaoFactory.java |     71 -
 .../metadata/impl/MongoMetadataDaoImpl.java     |    753 -
 .../eagle/alert/metadata/resource/Models.java   |     47 -
 .../eagle/alert/metadata/resource/OpResult.java |     50 -
 .../eagle/alert/metadata/TestMetadataUtils.java |     59 -
 .../eagle/alert/metadata/impl/InMemoryTest.java |    115 -
 .../eagle/alert/metadata/impl/JdbcImplTest.java |    282 -
 .../alert/metadata/impl/MongoImplTest.java      |    344 -
 .../src/test/resources/application-jdbc.conf    |     25 -
 .../src/test/resources/application-mongo.conf   |     25 -
 .../src/test/resources/application.conf         |     26 -
 .../alert-metadata/src/test/resources/init.sql  |     88 -
 .../src/test/resources/policy-sample.json       |     32 -
 .../eagle-alert/alert-metadata-parent/pom.xml   |     30 -
 .../eagle-alert/alert-service/pom.xml           |    222 -
 .../app/AlertDropWizardConfiguration.java       |     39 -
 .../apache/eagle/service/app/ServiceApp.java    |     86 -
 .../src/main/resources/application.conf         |     61 -
 .../src/main/resources/log4j.properties         |     19 -
 .../src/main/webapp/WEB-INF/web.xml             |     96 -
 .../alert-service/src/main/webapp/index.html    |     19 -
 .../eagle/service/app/AlertServiceTestBase.java |    107 -
 .../service/app/TestServiceTestAppWithZk.java   |     67 -
 .../src/test/resources/configuration.yml        |     22 -
 .../eagle-alert-parent/eagle-alert/pom.xml      |    377 -
 eagle-core/eagle-alert-parent/pom.xml           |     49 -
 eagle-core/eagle-app/eagle-app-base/pom.xml     |    138 -
 .../java/org/apache/eagle/app/Application.java  |     57 -
 .../org/apache/eagle/app/ApplicationCLI.java    |     35 -
 .../apache/eagle/app/ApplicationLifecycle.java  |     50 -
 .../org/apache/eagle/app/ApplicationTool.java   |     44 -
 .../apache/eagle/app/ExecutableApplication.java |     33 -
 .../org/apache/eagle/app/StaticApplication.java |     56 -
 .../eagle/app/StaticApplicationProvider.java    |     34 -
 .../org/apache/eagle/app/StormApplication.java  |     27 -
 .../app/config/ApplicationProviderConfig.java   |     59 -
 .../config/ApplicationProviderDescConfig.java   |    165 -
 .../app/config/ApplicationProvidersConfig.java  |     39 -
 .../app/environment/AbstractEnvironment.java    |     74 -
 .../eagle/app/environment/Environment.java      |     37 -
 .../eagle/app/environment/ExecutionRuntime.java |     61 -
 .../environment/ExecutionRuntimeManager.java    |     93 -
 .../environment/ExecutionRuntimeProvider.java   |     21 -
 .../environment/builder/AggregateFunction.java  |     67 -
 .../environment/builder/ApplicationBuilder.java |    130 -
 .../app/environment/builder/CEPFunction.java    |    149 -
 .../app/environment/builder/Collector.java      |     23 -
 .../environment/builder/CountMetricFilter.java  |     26 -
 .../builder/CounterToRateFunction.java          |    220 -
 .../app/environment/builder/MaxFunction.java    |     48 -
 .../environment/builder/MetricDescriptor.java   |    301 -
 .../builder/StormOutputCollector.java           |     36 -
 .../environment/builder/TransformFunction.java  |     30 -
 .../builder/TransformFunctionBolt.java          |     66 -
 .../app/environment/impl/SparkEnvironment.java  |     29 -
 .../environment/impl/SparkExecutionRuntime.java |     57 -
 .../impl/StaticApplicationExecutor.java         |     34 -
 .../app/environment/impl/StaticEnvironment.java |     26 -
 .../impl/StaticExecutionRuntime.java            |     68 -
 .../app/environment/impl/StormEnvironment.java  |     69 -
 .../environment/impl/StormExecutionRuntime.java |    214 -
 .../app/environment/impl/StormSubmitter.java    |    320 -
 .../app/messaging/DefaultStreamSinkConfig.java  |     42 -
 .../app/messaging/EntityStreamPersist.java      |     98 -
 .../eagle/app/messaging/FlattenEventMapper.java |     60 -
 .../apache/eagle/app/messaging/JsonSchema.java  |     66 -
 .../app/messaging/KafkaStreamProvider.java      |    148 -
 .../eagle/app/messaging/KafkaStreamSink.java    |     97 -
 .../app/messaging/KafkaStreamSinkConfig.java    |    165 -
 .../eagle/app/messaging/KafkaStreamSource.java  |    163 -
 .../app/messaging/KafkaStreamSourceConfig.java  |    216 -
 .../app/messaging/MetricSchemaGenerator.java    |    117 -
 .../app/messaging/MetricStreamPersist.java      |    161 -
 .../eagle/app/messaging/StormStreamSink.java    |     71 -
 .../eagle/app/messaging/StormStreamSource.java  |     25 -
 .../eagle/app/messaging/StreamEventMapper.java  |     35 -
 .../eagle/app/messaging/StreamProvider.java     |     50 -
 .../eagle/app/messaging/StreamRecord.java       |     30 -
 .../apache/eagle/app/messaging/StreamSink.java  |     24 -
 .../eagle/app/messaging/StreamSource.java       |     23 -
 .../app/module/ApplicationExtensionLoader.java  |     39 -
 .../app/module/ApplicationGuiceModule.java      |     52 -
 .../java/org/apache/eagle/app/package-info.java |     29 -
 .../eagle/app/resource/ApplicationResource.java |    202 -
 .../eagle/app/service/ApplicationAction.java    |    205 -
 .../app/service/ApplicationEmailService.java    |    104 -
 .../ApplicationHealthCheckPublisher.java        |     26 -
 .../service/ApplicationHealthCheckService.java  |     30 -
 .../eagle/app/service/ApplicationListener.java  |     32 -
 .../service/ApplicationManagementService.java   |     64 -
 .../app/service/ApplicationOperations.java      |    302 -
 .../app/service/ApplicationProviderLoader.java  |     79 -
 .../app/service/ApplicationProviderService.java |     32 -
 .../impl/ApplicationHealthCheckBase.java        |     72 -
 .../ApplicationHealthCheckEmailPublisher.java   |    165 -
 .../impl/ApplicationHealthCheckServiceImpl.java |    217 -
 .../impl/ApplicationManagementServiceImpl.java  |    260 -
 .../impl/ApplicationProviderConfigLoader.java   |    139 -
 .../impl/ApplicationProviderSPILoader.java      |     97 -
 .../impl/ApplicationProviderServiceImpl.java    |    144 -
 .../ApplicationStatusUpdateServiceImpl.java     |    132 -
 .../app/spi/AbstractApplicationProvider.java    |    150 -
 .../eagle/app/spi/ApplicationDescLoader.java    |     27 -
 .../eagle/app/spi/ApplicationProvider.java      |     93 -
 .../app/spi/ApplicationXMLDescriptorLoader.java |     71 -
 .../eagle/app/test/ApplicationSimulator.java    |     52 -
 .../app/test/ApplicationSimulatorImpl.java      |    121 -
 .../eagle/app/test/ApplicationTestBase.java     |     76 -
 .../app/test/ApplicationTestGuiceModule.java    |     46 -
 .../apache/eagle/app/test/KafkaTestServer.java  |     34 -
 .../eagle/app/test/KafkaTestServerImpl.java     |     79 -
 .../org/apache/eagle/app/test/package-info.java |     46 -
 .../apache/eagle/app/utils/AppConfigUtils.java  |     30 -
 .../app/utils/ApplicationConfigHelper.java      |     48 -
 .../app/utils/ApplicationExecutionConfig.java   |     66 -
 .../java/org/apache/eagle/app/utils/Clock.java  |     24 -
 .../apache/eagle/app/utils/ClockWithOffset.java |     35 -
 .../eagle/app/utils/DynamicJarPathFinder.java   |    130 -
 .../org/apache/eagle/app/utils/ManualClock.java |     54 -
 .../eagle/app/utils/StreamConvertHelper.java    |     51 -
 .../src/main/resources/HealthCheckTemplate.vm   |     43 -
 .../src/main/resources/log4j.properties         |     21 -
 .../app/ApplicationProviderDescConfigTest.java  |     48 -
 .../app/ApplicationProviderServiceTest.java     |     54 -
 .../eagle/app/ConfigurationHelperTest.java      |     33 -
 .../org/apache/eagle/app/StreamDefinitions.java |     37 -
 .../eagle/app/TestApplicationSimulatorImpl.java |     41 -
 .../apache/eagle/app/TestStormApplication.java  |     93 -
 .../apache/eagle/app/TestWebApplication.java    |     27 -
 .../app/environment/StaticEnvironmentTest.java  |     39 -
 .../builder/CounterToRateFunctionTest.java      |    306 -
 .../app/messaging/MetricStreamPersistTest.java  |    144 -
 .../app/resource/ApplicationResourceTest.java   |     83 -
 .../app/service/ApplicationActionTest.java      |    107 -
 ...estApplicationHealthCheckEmailPublisher.java |     64 -
 .../TestApplicationHealthCheckServiceImpl.java  |    101 -
 .../TestApplicationManagementServiceImpl.java   |    181 -
 .../eagle/app/storm/MockStormApplication.java   |     60 -
 .../app/storm/MockStormApplicationTest.java     |     37 -
 .../eagle/app/stream/CEPFunctionTest.java       |     60 -
 .../test/resources/ExampleApplicationConf.xml   |     31 -
 ....eagle.app.TestStormApplication$Provider.xml |    109 -
 ...he.eagle.app.TestWebApplication$Provider.xml |     37 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     17 -
 .../src/test/resources/TestApplicationConf.xml  |     31 -
 .../test/resources/TestStreamDefinitionConf.xml |     37 -
 .../src/test/resources/application.conf         |     70 -
 .../src/test/resources/config_template.xml      |     35 -
 .../src/test/resources/log4j.properties         |     21 -
 .../src/test/resources/providers.xml            |     23 -
 .../eagle-app/eagle-app-streamproxy/pom.xml     |     39 -
 .../proxy/exception/StreamProxyException.java   |     39 -
 .../stream/StreamConfigUpdateListener.java      |     36 -
 .../stream/StreamMetadataUpdateService.java     |     27 -
 .../eagle/app/proxy/stream/StreamProxy.java     |     27 -
 .../app/proxy/stream/StreamProxyManager.java    |     31 -
 .../app/proxy/stream/StreamProxyProducer.java   |     28 -
 .../app/proxy/stream/StreamProxyResource.java   |     85 -
 .../impl/KafkaStreamProxyProducerImpl.java      |     88 -
 .../impl/StreamMetadataUpdateServiceImpl.java   |    116 -
 .../app/proxy/stream/impl/StreamProxyImpl.java  |     77 -
 .../stream/impl/StreamProxyManagerImpl.java     |    129 -
 .../eagle/app/proxy/stream/StreamProxyTest.java |     76 -
 .../src/test/resources/application.conf         |     35 -
 eagle-core/eagle-app/eagle-app-utils/pom.xml    |     44 -
 .../apache/eagle/app/utils/AppConstants.java    |     26 -
 .../eagle/app/utils/HadoopSecurityUtil.java     |     48 -
 .../eagle/app/utils/PathResolverHelper.java     |     37 -
 .../app/utils/connection/InputStreamUtils.java  |     68 -
 .../connection/ServiceNotResponseException.java |     61 -
 .../utils/connection/URLConnectionUtils.java    |    103 -
 .../utils/connection/URLResourceFetcher.java    |     62 -
 .../eagle/app/utils/ha/HAURLSelector.java       |     29 -
 eagle-core/eagle-app/pom.xml                    |     52 -
 eagle-core/eagle-common/pom.xml                 |    170 -
 .../org/apache/eagle/common/Version.java        |     59 -
 .../java/org/apache/eagle/common/Base64.java    |     40 -
 .../java/org/apache/eagle/common/ByteUtil.java  |    178 -
 .../apache/eagle/common/CircularArrayList.java  |    149 -
 .../common/CircularArrayListSortedSet.java      |    106 -
 .../org/apache/eagle/common/DateTimeUtil.java   |    221 -
 .../apache/eagle/common/EagleBase64Wrapper.java |     32 -
 .../eagle/common/EagleExceptionWrapper.java     |     48 -
 .../org/apache/eagle/common/Environment.java    |     23 -
 .../main/java/org/apache/eagle/common/OS.java   |     41 -
 .../apache/eagle/common/SerializableUtils.java  |    126 -
 .../java/org/apache/eagle/common/agg/Agg.java   |     26 -
 .../eagle/common/agg/AggregateHandler.java      |     29 -
 .../eagle/common/agg/AggregateResult.java       |     62 -
 .../org/apache/eagle/common/agg/Column.java     |     25 -
 .../org/apache/eagle/common/agg/Groupby.java    |     26 -
 .../eagle/common/agg/SiddhiAggregator.java      |    145 -
 .../eagle/common/agg/StreamAggregator.java      |    112 -
 .../eagle/common/agg/StreamDefinition.java      |     26 -
 .../eagle/common/agg/TimeBatchAggSpec.java      |     27 -
 .../eagle/common/agg/TimeBatchWindowSpec.java   |     31 -
 .../config/AbstractConfigOptionParser.java      |     71 -
 .../eagle/common/config/ConfigOptionParser.java |     67 -
 .../apache/eagle/common/config/EagleConfig.java |     62 -
 .../common/config/EagleConfigConstants.java     |     66 -
 .../eagle/common/config/EagleConfigFactory.java |    221 -
 .../eagle/common/config/EagleConfigHelper.java  |     43 -
 .../common/function/ThrowableConsumer.java      |     22 -
 .../common/function/ThrowableConsumer2.java     |     22 -
 .../common/function/ThrowableFunction.java      |     29 -
 .../common/function/ThrowableSupplier.java      |     29 -
 .../eagle/common/mail/AbstractEmailService.java |     82 -
 .../eagle/common/mail/AlertEmailConstants.java  |     58 -
 .../eagle/common/mail/AlertEmailContext.java    |     68 -
 .../eagle/common/mail/AlertEmailSender.java     |    112 -
 .../eagle/common/mail/EagleMailClient.java      |    229 -
 .../eagle/common/metric/AlertContext.java       |     93 -
 .../eagle/common/module/CommonGuiceModule.java  |     28 -
 .../common/module/ConfigServiceProvider.java    |     30 -
 .../apache/eagle/common/module/GlobalScope.java |     23 -
 .../eagle/common/module/GuiceJUnitRunner.java   |     83 -
 .../eagle/common/module/ModuleRegistry.java     |     58 -
 .../eagle/common/module/ModuleRegistryImpl.java |     52 -
 .../apache/eagle/common/module/ModuleScope.java |     40 -
 .../org/apache/eagle/common/module/Modules.java |     36 -
 .../apache/eagle/common/rest/RESTResponse.java  |    256 -
 .../apache/eagle/common/security/DenyAll.java   |     27 -
 .../apache/eagle/common/security/PermitAll.java |     29 -
 .../eagle/common/security/RolesAllowed.java     |     26 -
 .../org/apache/eagle/common/security/User.java  |    176 -
 .../common/service/HadoopAccountService.java    |     23 -
 .../apache/eagle/common/service/HadoopUser.java |     45 -
 .../eagle/common/service/LdapService.java       |    271 -
 .../common/service/POSTResultEntityBase.java    |     46 -
 .../service/TrustAllSSLSocketFactory.java       |    102 -
 .../eagle/common/utils/ReflectionsHelper.java   |     48 -
 .../org/apache/eagle/common/utils/Tuple2.java   |     42 -
 .../eagle-common/src/main/resources/footer.vm   |     25 -
 .../eagle-common/src/main/resources/header.vm   |    304 -
 .../src/main/resources/templates/tec_alert.vm   |    114 -
 .../org/apache/eagle/common/TestBase64.java     |     32 -
 .../org/apache/eagle/common/TestByteUtil.java   |    111 -
 .../eagle/common/TestCircularArrayList.java     |     74 -
 .../common/TestCircularArrayListSortedSet.java  |     58 -
 .../apache/eagle/common/TestDateTimeUtil.java   |    102 -
 .../eagle/common/TestEagleBase64Wrapper.java    |     38 -
 .../eagle/common/TestEagleExceptionWrapper.java |     32 -
 .../eagle/common/TestSerializableUtils.java     |     55 -
 .../eagle/common/TestSiddhiAggregator.java      |    112 -
 .../org/apache/eagle/common/TestVersion.java    |     27 -
 .../eagle/common/agg/TestSiddhiAggregator.java  |     93 -
 .../common/agg/TestSiddhiExternalTimeBatch.java |    116 -
 .../eagle/common/agg/TestStreamAggregator.java  |     65 -
 .../eagle/common/config/TestConfigParser.java   |     36 -
 .../eagle/common/config/TestEagleConfig.java    |     42 -
 .../eagle/common/metric/TestAlertContext.java   |     39 -
 .../eagle/common/module/ModuleRegistryTest.java |     55 -
 .../src/test/resources/application-test.conf    |     33 -
 .../eagle-common/src/test/resources/footer.vm   |     25 -
 .../eagle-common/src/test/resources/header.vm   |    300 -
 .../src/test/resources/log4j.properties         |     30 -
 .../src/test/resources/templates/tec_alert.vm   |    120 -
 .../resources/templates/test_anomaly_alert.vm   |    141 -
 eagle-core/eagle-data-process/pom.xml           |    166 -
 .../dataproc/impl/storm/StormSpoutProvider.java |     28 -
 .../eagle/dataproc/impl/storm/ValuesArray.java  |     38 -
 .../impl/storm/kafka/KafkaSpoutProvider.java    |    131 -
 .../kafka/SpoutKafkaMessageDeserializer.java    |     23 -
 .../partition/CustomPartitionGrouping.java      |     48 -
 .../storm/partition/DataDistributionDao.java    |     26 -
 .../storm/partition/PartitionAlgorithm.java     |     26 -
 .../impl/storm/partition/PartitionStrategy.java |     25 -
 .../storm/partition/PartitionStrategyImpl.java  |     82 -
 .../dataproc/impl/storm/partition/Weight.java   |     28 -
 .../impl/storm/zookeeper/ZKStateConfig.java     |     29 -
 .../src/main/resources/application.conf         |     72 -
 .../src/main/resources/log4j.properties         |     19 -
 .../eagle-embed/eagle-embed-hbase/pom.xml       |     73 -
 .../src/main/initdata/eagle-topology-init.sh    |     98 -
 .../src/main/initdata/prepare-dev-data.sh       |     21 -
 .../src/main/initdata/sample-policy-create.sh   |     31 -
 .../sample-sensitivity-resource-create.sh       |     30 -
 .../eagle/service/hbase/EmbeddedHbase.java      |    141 -
 .../org/apache/eagle/service/hbase/Tables.java  |     52 -
 .../src/main/resources/hbase-default.xml        |    940 -
 .../eagle/service/hbase/EmbeddedHbaseTest.java  |     28 -
 .../eagle/service/hbase/TestHBaseBase.java      |     64 -
 .../eagle-embed/eagle-embed-server/pom.xml      |     81 -
 .../eagle-embed-server/runEmbeddedServer.sh     |     19 -
 .../service/embedded/tomcat/EmbeddedServer.java |    108 -
 .../embedded/tomcat/TestEmbeddedServer.java     |     30 -
 eagle-core/eagle-embed/pom.xml                  |     48 -
 .../eagle-metadata/eagle-metadata-base/pom.xml  |     75 -
 .../ApplicationNotFoundException.java           |     31 -
 .../ApplicationWrongStatusException.java        |     31 -
 .../exceptions/EntityNotFoundException.java     |     31 -
 .../IllegalApplicationTypeException.java        |     20 -
 .../exceptions/SiteDeleteException.java         |     32 -
 .../eagle/metadata/model/AlertEntity.java       |     95 -
 .../metadata/model/ApplicationDependency.java   |     58 -
 .../eagle/metadata/model/ApplicationDesc.java   |    152 -
 .../eagle/metadata/model/ApplicationDocs.java   |     46 -
 .../eagle/metadata/model/ApplicationEntity.java |    208 -
 .../metadata/model/ApplicationRawEntity.java    |     72 -
 .../eagle/metadata/model/Configuration.java     |     75 -
 .../eagle/metadata/model/DashboardEntity.java   |    135 -
 .../model/MetadataEntityRepository.java         |     27 -
 .../metadata/model/MetricSchemaEntity.java      |     88 -
 .../apache/eagle/metadata/model/Property.java   |     65 -
 .../apache/eagle/metadata/model/SiteEntity.java |     76 -
 .../apache/eagle/metadata/model/StreamDesc.java |     92 -
 .../eagle/metadata/model/StreamSinkConfig.java  |     27 -
 .../metadata/model/StreamSourceConfig.java      |     27 -
 .../metadata/persistence/MetadataStore.java     |     24 -
 .../persistence/MetadataStoreModuleFactory.java |     51 -
 .../metadata/persistence/PersistenceEntity.java |     64 -
 .../persistence/PersistenceService.java         |     29 -
 .../metadata/persistence/package-info.java      |     17 -
 .../metadata/resource/DashboardResource.java    |     68 -
 .../eagle/metadata/resource/SiteResource.java   |    113 -
 .../eagle/metadata/resource/UUIDRequest.java    |     32 -
 .../service/ApplicationDescService.java         |     27 -
 .../service/ApplicationEntityService.java       |     35 -
 .../service/ApplicationStatusUpdateService.java |     26 -
 .../service/DashboardEntityService.java         |     42 -
 .../metadata/service/SiteEntityService.java     |     31 -
 .../ApplicationEntityServiceMemoryImpl.java     |    114 -
 .../DashboardEntityServiceMemoryImpl.java       |    119 -
 .../service/memory/MemoryMetadataStore.java     |     35 -
 .../SiteEntityEntityServiceMemoryImpl.java      |     90 -
 .../metadata/utils/ConfigTemplateHelper.java    |     68 -
 .../metadata/utils/InnerDomAsTextHandler.java   |     66 -
 .../metadata/utils/InstallDocDomHandler.java    |     23 -
 .../metadata/utils/StreamIdConversions.java     |     46 -
 .../eagle/metadata/utils/UUIDGenerator.java     |     25 -
 .../metadata/utils/UninstallDocDomHandler.java  |     23 -
 .../eagle/metadata/model/TestConfiguration.java |     67 -
 .../metadata/persistence/MetadataStoreTest.java |     28 -
 .../TestMetadataStoreModuleFactory.java         |     33 -
 .../TestApplicationEntityServiceMemoryImpl.java |    231 -
 .../TestDashboardEntityServiceMemoryImpl.java   |    109 -
 .../TestSiteEntityServiceMemoryImpl.java        |     98 -
 .../metadata/utils/StreamIdConversionsTest.java |     37 -
 .../src/test/resources/application-test.conf    |     31 -
 .../src/test/resources/application-test.xml     |     35 -
 .../eagle-metadata/eagle-metadata-jdbc/pom.xml  |     54 -
 .../store/jdbc/JDBCDataSourceConfig.java        |    104 -
 .../JDBCMetadataMetadataStoreServiceImpl.java   |    313 -
 .../store/jdbc/JDBCMetadataQueryService.java    |     52 -
 .../metadata/store/jdbc/JDBCMetadataStore.java  |     47 -
 .../jdbc/provider/JDBCDataSourceProvider.java   |     58 -
 .../JDBCMetadataStoreConfigProvider.java        |     45 -
 .../ApplicationEntityServiceJDBCImpl.java       |    257 -
 .../service/DashboardEntityServiceJDBCImpl.java |    224 -
 .../jdbc/service/SiteEntityServiceJDBCImpl.java |    163 -
 .../orm/ApplicationEntityToRelation.java        |     77 -
 .../orm/RelationToApplicationEntity.java        |     87 -
 .../jdbc/service/orm/RelationToSiteEntity.java  |     37 -
 .../jdbc/service/orm/SiteEntityToRelation.java  |     59 -
 .../ApplicationEntityServiceJDBCImplTest.java   |    229 -
 .../DashboardEntityServiceJDBCImplTest.java     |    112 -
 .../store/jdbc/JDBCDataSourceProviderTest.java  |     78 -
 .../jdbc/JDBCMetadataQueryServiceTest.java      |     36 -
 .../store/jdbc/JDBCMetadataTestBase.java        |     53 -
 .../jdbc/SiteEntityServiceJDBCImplTest.java     |    237 -
 .../store/jdbc/TestStaticApplication.java       |     31 -
 ...tore.jdbc.TestStaticApplication$Provider.xml |     30 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/test/resources/application.conf         |     31 -
 .../src/test/resources/init.sql                 |     56 -
 .../eagle-metadata/eagle-metadata-mongo/pom.xml |     36 -
 .../store/mongo/MongoMetadataStore.java         |     29 -
 eagle-core/eagle-metadata/pom.xml               |     47 -
 eagle-core/eagle-metric/pom.xml                 |     67 -
 .../apache/eagle/metric/MetricConstants.java    |     24 -
 .../metric/reportor/EagleCounterMetric.java     |     72 -
 .../eagle/metric/reportor/EagleGaugeMetric.java |     42 -
 .../eagle/metric/reportor/EagleMetric.java      |     64 -
 .../eagle/metric/reportor/EagleMetricKey.java   |     28 -
 .../metric/reportor/EagleMetricListener.java    |     32 -
 .../EagleServiceReporterMetricListener.java     |     62 -
 .../eagle/metric/reportor/IEagleMetric.java     |     41 -
 .../metric/reportor/MetricEntityAdaptor.java    |     49 -
 .../metric/reportor/MetricKeyCodeDecoder.java   |     82 -
 .../src/test/resources/log4j.properties         |     31 -
 eagle-core/eagle-query/eagle-antlr/pom.xml      |     42 -
 .../eagle-antlr/src/main/java/EagleFilter.g4    |    114 -
 .../query/antlr/generated/EagleFilter.tokens    |     36 -
 .../generated/EagleFilterBaseListener.java      |     91 -
 .../query/antlr/generated/EagleFilterLexer.java |    216 -
 .../antlr/generated/EagleFilterLexer.tokens     |     36 -
 .../antlr/generated/EagleFilterListener.java    |     57 -
 .../antlr/generated/EagleFilterParser.java      |    364 -
 .../eagle/query/parser/ANDExpression.java       |     33 -
 .../eagle/query/parser/AtomicExpression.java    |     67 -
 .../eagle/query/parser/ComparisonOperator.java  |     55 -
 .../query/parser/EagleANTLRErrorStrategy.java   |     48 -
 .../parser/EagleQueryFilterListenerImpl.java    |    176 -
 .../query/parser/EagleQueryParseException.java  |     29 -
 .../eagle/query/parser/EagleQueryParser.java    |     54 -
 .../eagle/query/parser/LogicalOperator.java     |     23 -
 .../apache/eagle/query/parser/ORExpression.java |     60 -
 .../eagle/query/parser/TokenConstant.java       |     52 -
 .../apache/eagle/query/parser/TokenType.java    |     44 -
 .../UnsupportedExpressionOperatorException.java |     25 -
 .../eagle-antlr/src/main/java/readme.txt        |     31 -
 .../query/parser/test/TestEagleQueryParser.java |    832 -
 .../eagle/query/parser/test/TestValueType.java  |     73 -
 eagle-core/eagle-query/eagle-audit-base/pom.xml |     50 -
 .../eagle/audit/common/AuditConstants.java      |     35 -
 .../apache/eagle/audit/common/AuditEvent.java   |     51 -
 .../eagle/audit/common/AuditListenerMap.java    |     43 -
 .../audit/common/BaseAuditListenerMap.java      |    149 -
 .../apache/eagle/audit/dao/ServiceAuditDAO.java |     90 -
 .../eagle/audit/dao/ServiceAuditDAOImpl.java    |    176 -
 .../eagle/audit/entity/GenericAuditEntity.java  |     80 -
 .../entity/repo/AuditEntityRepository.java      |     28 -
 .../eagle/audit/listener/AuditListener.java     |     25 -
 .../audit/listener/AuditListenerProxy.java      |     41 -
 .../eagle/audit/listener/AuditSupport.java      |    111 -
 .../audit/dao/TestSearchRequestBuilder.java     |     48 -
 .../audit/entity/TestGenericAuditEntity.java    |     81 -
 .../audit/listener/AuditListenerTestHelper.java |     32 -
 .../eagle/audit/listener/TestAuditSupport.java  |     98 -
 .../eagle-query/eagle-client-base/pom.xml       |     69 -
 .../service/client/EagleServiceAsyncClient.java |    117 -
 .../client/EagleServiceClientException.java     |     64 -
 .../service/client/EagleServiceConnector.java   |     70 -
 .../client/EagleServiceGroupByQueryRequest.java |    173 -
 .../client/EagleServiceQueryBuilder.java        |    107 -
 .../client/EagleServiceQueryRequest.java        |    151 -
 .../EagleServiceSingleEntityQueryRequest.java   |    211 -
 .../service/client/IEagleServiceClient.java     |    131 -
 .../client/IEagleServiceRequestBuilder.java     |     83 -
 .../ListGroupByQueryAPIResponseEntity.java      |     90 -
 .../ListQueryAPIResponseConvertHelper.java      |    117 -
 .../ListTimeSeriesQueryAPIResponseEntity.java   |     84 -
 .../RowkeyQueryAPIResponseConvertHelper.java    |    110 -
 .../eagle/service/client/ServiceConfig.java     |     40 -
 .../TimeSeriesGroupByAPIResponseEntity.java     |    101 -
 .../eagle/service/client/impl/BatchSender.java  |     93 -
 .../service/client/impl/ConcurrentSender.java   |    170 -
 .../client/impl/DeleteRequestBuilder.java       |    137 -
 .../impl/EagleServiceAsyncClientImpl.java       |    156 -
 .../client/impl/EagleServiceBaseClient.java     |    327 -
 .../client/impl/EagleServiceClientImpl.java     |    249 -
 .../eagle/service/client/impl/MetricSender.java |     75 -
 .../client/impl/SearchRequestBuilder.java       |     97 -
 .../client/security/SecurityConstants.java      |     22 -
 .../org/apache/eagle/service/client/Base.java   |     31 -
 .../org/apache/eagle/service/client/ClassA.java |     35 -
 .../org/apache/eagle/service/client/ClassB.java |     34 -
 .../eagle/service/client/ClientTestBase.java    |     32 -
 .../client/TestEagleServiceClientImpl.java      |    327 -
 .../service/client/TestIEagleServiceClient.java |     64 -
 .../eagle/service/client/TestJackson.java       |     62 -
 .../client/impl/TestDeleteRequestBuilder.java   |     67 -
 .../client/impl/TestEagleServiceClient.java     |     98 -
 .../TestEagleServiceGroupByQueryRequest.java    |     55 -
 .../impl/TestEagleServiceQueryBuilder.java      |     39 -
 .../TestListQueryAPIReponseConvertHelper.java   |     61 -
 .../eagle/service/client/impl/TestQuery.java    |     49 -
 ...TestRowkeyQueryAPIResponseConvertHelper.java |     57 -
 .../service/jackson/TestJacksonMarshalling.java |    149 -
 .../src/test/resources/log4j.properties         |     21 -
 .../eagle-query/eagle-entity-base/pom.xml       |    102 -
 .../eagle/log/base/taggedlog/EntityContext.java |     40 -
 .../log/base/taggedlog/EntityJsonModule.java    |     27 -
 .../log/base/taggedlog/MapEntrySerializer.java  |     38 -
 .../log/base/taggedlog/NoSuchRowException.java  |     29 -
 .../log/base/taggedlog/RowkeyAPIEntity.java     |     81 -
 .../log/base/taggedlog/TaggedLogAPIEntity.java  |    251 -
 .../base/taggedlog/TaggedLogObjectMapper.java   |     35 -
 .../log/entity/AbstractHBaseLogReader.java      |    240 -
 .../eagle/log/entity/BaseEntityRepository.java  |     26 -
 .../log/entity/EntityCreationListener.java      |     26 -
 .../eagle/log/entity/EntityQualifierUtils.java  |    281 -
 .../org/apache/eagle/log/entity/EntityUniq.java |     67 -
 .../entity/GenericCreateAPIResponseEntity.java  |     57 -
 .../log/entity/GenericEntityBatchReader.java    |     58 -
 .../entity/GenericEntityScanStreamReader.java   |    131 -
 .../log/entity/GenericEntityStreamReader.java   |    125 -
 .../log/entity/GenericEntityStreamReaderMT.java |    151 -
 .../eagle/log/entity/GenericEntityWriter.java   |     78 -
 .../eagle/log/entity/GenericMetricEntity.java   |     53 -
 .../entity/GenericMetricEntityBatchReader.java  |     54 -
 ...ricMetricEntityDecompactionStreamReader.java |     98 -
 .../log/entity/GenericMetricShadowEntity.java   |     34 -
 .../entity/GenericServiceAPIResponseEntity.java |    118 -
 ...ricServiceAPIResponseEntityDeserializer.java |     86 -
 .../log/entity/HBaseInternalLogHelper.java      |    245 -
 .../eagle/log/entity/HBaseLogReader2.java       |     86 -
 .../apache/eagle/log/entity/HBaseLogWriter.java |    152 -
 .../apache/eagle/log/entity/InternalLog.java    |    139 -
 .../log/entity/ListQueryAPIResponseEntity.java  |     78 -
 .../org/apache/eagle/log/entity/LogReader.java  |     28 -
 .../org/apache/eagle/log/entity/LogWriter.java  |     32 -
 .../eagle/log/entity/MetricMetadataEntity.java  |    117 -
 .../log/entity/QualifierCreationListener.java   |     28 -
 .../entity/QualifierNotDefinedException.java    |     28 -
 .../apache/eagle/log/entity/RowkeyBuilder.java  |    140 -
 .../entity/RowkeyQueryAPIResponseEntity.java    |     45 -
 .../eagle/log/entity/SearchCondition.java       |    148 -
 .../apache/eagle/log/entity/StreamReader.java   |     55 -
 .../filter/BooleanExpressionComparator.java     |    300 -
 .../log/entity/filter/HBaseFilterBuilder.java   |    585 -
 .../entity/filter/QualifierFilterEntity.java    |    105 -
 .../eagle/log/entity/filter/RowValueFilter.java |    144 -
 .../entity/filter/TypedByteArrayComparator.java |    213 -
 .../eagle/log/entity/index/IndexLogReader.java  |     45 -
 .../log/entity/index/IndexStreamReader.java     |     94 -
 .../index/NonClusteredIndexLogReader.java       |    197 -
 .../index/NonClusteredIndexStreamReader.java    |     51 -
 .../eagle/log/entity/index/RowKeyLogReader.java |    107 -
 .../log/entity/index/UniqueIndexLogReader.java  |    124 -
 .../entity/index/UniqueIndexStreamReader.java   |     52 -
 .../eagle/log/entity/meta/BooleanSerDeser.java  |     54 -
 .../apache/eagle/log/entity/meta/Column.java    |     28 -
 .../eagle/log/entity/meta/ColumnFamily.java     |     28 -
 .../entity/meta/DefaultJavaObjctSerDeser.java   |     41 -
 .../log/entity/meta/Double2DArraySerDeser.java  |     97 -
 .../log/entity/meta/DoubleArraySerDeser.java    |     68 -
 .../eagle/log/entity/meta/DoubleSerDeser.java   |     41 -
 .../eagle/log/entity/meta/EntityConstants.java  |     31 -
 .../eagle/log/entity/meta/EntityDefinition.java |    326 -
 .../entity/meta/EntityDefinitionManager.java    |    474 -
 .../eagle/log/entity/meta/EntitySerDeser.java   |     23 -
 .../log/entity/meta/EntitySerDeserializer.java  |     79 -
 .../org/apache/eagle/log/entity/meta/Index.java |     32 -
 .../eagle/log/entity/meta/IndexDefinition.java  |    335 -
 .../apache/eagle/log/entity/meta/Indexes.java   |     29 -
 .../eagle/log/entity/meta/IntArraySerDeser.java |     71 -
 .../eagle/log/entity/meta/IntSerDeser.java      |     42 -
 .../eagle/log/entity/meta/ListSerDeser.java     |    128 -
 .../eagle/log/entity/meta/LongSerDeser.java     |     43 -
 .../eagle/log/entity/meta/MapSerDeser.java      |    168 -
 .../apache/eagle/log/entity/meta/Metric.java    |     29 -
 .../eagle/log/entity/meta/MetricDefinition.java |     68 -
 .../eagle/log/entity/meta/NonUniqueIndex.java   |     28 -
 .../eagle/log/entity/meta/NonUniqueIndexes.java |     31 -
 .../eagle/log/entity/meta/NullObject.java       |     21 -
 .../eagle/log/entity/meta/NullSerDeser.java     |     37 -
 .../apache/eagle/log/entity/meta/Partition.java |     40 -
 .../apache/eagle/log/entity/meta/Prefix.java    |     28 -
 .../apache/eagle/log/entity/meta/Qualifier.java |    100 -
 .../apache/eagle/log/entity/meta/Service.java   |     28 -
 .../eagle/log/entity/meta/ServicePath.java      |     34 -
 .../log/entity/meta/StringArraySerDeser.java    |     94 -
 .../eagle/log/entity/meta/StringSerDeser.java   |     39 -
 .../org/apache/eagle/log/entity/meta/Table.java |     28 -
 .../org/apache/eagle/log/entity/meta/Tags.java  |     31 -
 .../eagle/log/entity/meta/TimeSeries.java       |     28 -
 .../log/entity/old/GenericByRowkeyReader.java   |     78 -
 .../eagle/log/entity/old/GenericDeleter.java    |    135 -
 .../eagle/log/entity/old/GenericReader.java     |    115 -
 .../eagle/log/entity/old/GenericWriter.java     |     93 -
 .../log/entity/old/HBaseLogByRowkeyReader.java  |    161 -
 .../eagle/log/entity/old/HBaseLogDeleter.java   |    131 -
 .../eagle/log/entity/old/HBaseLogReader.java    |    247 -
 .../apache/eagle/log/entity/old/LogDeleter.java |     34 -
 .../eagle/log/entity/old/RowkeyHelper.java      |     85 -
 .../org/apache/eagle/log/entity/old/Schema.java |     24 -
 .../entity/repo/DefaultEntityRepository.java    |     34 -
 .../eagle/log/entity/repo/EntityRepository.java |     56 -
 .../entity/repo/EntityRepositoryScanner.java    |     82 -
 .../eagle/log/entity/test/TestEntity.java       |    107 -
 .../eagle/log/entity/test/TestLogAPIEntity.java |     99 -
 .../entity/test/TestTimeSeriesAPIEntity.java    |     97 -
 .../eagle/log/expression/ExpressionParser.java  |    207 -
 .../log/expression/ParsiiInvalidException.java  |     57 -
 .../ParsiiUnknowVariableException.java          |     57 -
 .../TestGenericServiceAPIResponseEntity.java    |     92 -
 .../log/entity/TestDouble2DArraySerDeser.java   |     48 -
 .../eagle/log/entity/TestDoubleSerDeser.java    |     58 -
 .../TestGenericEntityIndexStreamReader.java     |    173 -
 .../log/entity/TestHBaseIntegerLogHelper.java   |     67 -
 .../TestHBaseWriteEntitiesPerformance.java      |    130 -
 .../log/entity/TestHbaseWritePerformance.java   |    100 -
 .../eagle/log/entity/TestTestLogAPIEntity.java  |    414 -
 .../base/taggedlog/TestTaggedLogAPIEntity.java  |    117 -
 .../filter/TestEntityQualifierHelper.java       |    182 -
 .../entity/filter/TestExpressionComparator.java |    195 -
 .../entity/filter/TestHBaseFilterBuilder.java   |    282 -
 .../filter/TestTypedByteArrayComparator.java    |     61 -
 .../log/entity/meta/TestArraySerDeser.java      |     64 -
 .../meta/TestEntityDefinitionManager.java       |     35 -
 .../eagle/log/entity/meta/TestListSerDeser.java |    101 -
 .../eagle/log/entity/meta/TestMapSerDeser.java  |    106 -
 .../repo/TestEntityRepositoryScanner.java       |     31 -
 .../log/expression/TestExpressionParser.java    |    256 -
 .../expression/TestExpressionPerformance.java   |    120 -
 .../src/test/resources/application.conf         |     31 -
 .../src/test/resources/log4j.properties         |     34 -
 eagle-core/eagle-query/eagle-query-base/pom.xml |     62 -
 .../apache/eagle/query/GenericEntityQuery.java  |     74 -
 .../org/apache/eagle/query/GenericQuery.java    |     46 -
 .../apache/eagle/query/ListQueryCompiler.java   |    380 -
 .../org/apache/eagle/query/QueryConstants.java  |     24 -
 .../query/aggregate/AggregateAPIEntity.java     |     69 -
 .../aggregate/AggregateAPIEntityFactory.java    |     21 -
 .../query/aggregate/AggregateCondition.java     |     73 -
 .../AggregateFunctionNotSupportedException.java |     28 -
 .../query/aggregate/AggregateFunctionType.java  |     85 -
 .../aggregate/AggregateFunctionTypeMatcher.java |     41 -
 .../eagle/query/aggregate/AggregateParams.java  |     77 -
 .../aggregate/AggregateParamsValidator.java     |     94 -
 .../aggregate/AggregateResultAPIEntity.java     |     52 -
 .../eagle/query/aggregate/Aggregator.java       |    168 -
 .../eagle/query/aggregate/BucketQuery.java      |     84 -
 .../IllegalAggregateFieldTypeException.java     |     28 -
 .../query/aggregate/PostAggregateSorting.java   |    101 -
 .../query/aggregate/SortFieldOrderType.java     |     59 -
 .../aggregate/SortFieldOrderTypeMatcher.java    |     38 -
 .../eagle/query/aggregate/raw/Function.java     |    106 -
 .../query/aggregate/raw/FunctionFactory.java    |     75 -
 .../eagle/query/aggregate/raw/GroupbyKey.java   |    149 -
 .../aggregate/raw/GroupbyKeyAggregatable.java   |     39 -
 .../aggregate/raw/GroupbyKeyComparator.java     |     43 -
 .../query/aggregate/raw/GroupbyKeyValue.java    |     91 -
 .../raw/GroupbyKeyValueCreationListener.java    |     24 -
 .../eagle/query/aggregate/raw/GroupbyValue.java |    139 -
 .../query/aggregate/raw/RawAggregator.java      |     71 -
 .../query/aggregate/raw/RawGroupbyBucket.java   |    196 -
 .../eagle/query/aggregate/raw/WritableList.java |    104 -
 .../timeseries/AbstractAggregator.java          |    192 -
 .../query/aggregate/timeseries/Aggregator.java  |     29 -
 .../EntityCreationListenerFactory.java          |     25 -
 .../aggregate/timeseries/FlatAggregator.java    |     61 -
 .../aggregate/timeseries/GroupbyBucket.java     |    241 -
 .../timeseries/GroupbyFieldsComparator.java     |     39 -
 .../timeseries/HierarchicalAggregateEntity.java |     67 -
 .../timeseries/HierarchicalAggregator.java      |     82 -
 .../timeseries/PostFlatAggregateSort.java       |     93 -
 .../PostHierarchicalAggregateSort.java          |     92 -
 .../query/aggregate/timeseries/SortOption.java  |     49 -
 .../aggregate/timeseries/SortOptionsParser.java |     69 -
 .../timeseries/SynchronizedAggregator.java      |     35 -
 .../SynchronizedEntityCreationListener.java     |     36 -
 .../timeseries/TimeSeriesAggregator.java        |    169 -
 .../aggregate/timeseries/TimeSeriesBucket.java  |     76 -
 .../TimeSeriesPostFlatAggregateSort.java        |    151 -
 .../apache/eagle/query/TestHBaseLogReader2.java |    154 -
 .../eagle/query/TestListQueryCompiler.java      |    243 -
 .../query/aggregate/raw/TestGroupbyKey.java     |     73 -
 .../query/aggregate/raw/TestRawAggregator.java  |    517 -
 .../raw/TestRawHBaseLogReaderAndAgg.java        |     26 -
 .../query/aggregate/test/TestAggregator.java    |    251 -
 .../aggregate/test/TestAlertAggService.java     |     56 -
 .../query/aggregate/test/TestBucketQuery.java   |    156 -
 .../query/aggregate/test/TestBucketQuery2.java  |    160 -
 .../aggregate/test/TestFlatAggregator.java      |    399 -
 .../test/TestGroupbyFieldComparator.java        |     35 -
 .../test/TestHierarchicalAggregator.java        |    331 -
 .../aggregate/test/TestListQueryCompiler.java   |     47 -
 .../test/TestPostFlatAggregateSort.java         |    143 -
 .../test/TestTimeSeriesAggregator.java          |    175 -
 .../eagle-query/eagle-service-base/pom.xml      |    169 -
 .../service/common/EagleExceptionWrapper.java   |     42 -
 .../common/SplitFullScanEntityReader.java       |    289 -
 .../generic/GenericEntityServiceResource.java   |    635 -
 .../generic/GenericObjectMapperProvider.java    |     46 -
 .../service/generic/ListQueryResource.java      |    504 -
 .../eagle/service/generic/MetadataResource.java |    205 -
 .../service/metric/EagleMetricResource.java     |     58 -
 .../service/rowkey/RowKeyQueryResource.java     |     88 -
 .../eagle/service/rowkey/RowkeyResource.java    |    133 -
 .../EagleServiceSelfCheckAPIEntity.java         |     47 -
 .../EagleServiceSelfCheckResource.java          |     38 -
 .../service/selfcheck/ServiceResource.java      |     65 -
 .../src/main/webapp/WEB-INF/web.xml             |     52 -
 .../service/generic/MetadataResourceApp.java    |     40 -
 .../TestGenericEntityServiceResource.java       |    236 -
 .../service/generic/TestListQueryResource.java  |    598 -
 .../service/generic/TestMetadataResource.java   |     88 -
 .../service/generic/TestResourceUnmarshal.java  |    106 -
 .../service/metric/EagleMetricResourceApp.java  |     41 -
 .../service/metric/TestEagleMetricResource.java |     90 -
 .../eagle-query/eagle-storage-base/pom.xml      |     36 -
 .../org/apache/eagle/storage/DataStorage.java   |    111 -
 .../apache/eagle/storage/DataStorageBase.java   |     31 -
 .../eagle/storage/DataStorageManager.java       |    124 -
 .../exception/IllegalDataStorageException.java  |     38 -
 .../IllegalDataStorageTypeException.java        |     38 -
 .../exception/QueryCompileException.java        |     38 -
 .../eagle/storage/operation/CompiledQuery.java  |    281 -
 .../storage/operation/CreateStatement.java      |     68 -
 .../storage/operation/DeleteStatement.java      |     98 -
 .../eagle/storage/operation/QueryStatement.java |     52 -
 .../eagle/storage/operation/RawQuery.java       |    232 -
 .../storage/operation/RowkeyQueryStatement.java |     61 -
 .../eagle/storage/operation/Statement.java      |     34 -
 .../storage/operation/UpdateStatement.java      |     56 -
 .../eagle/storage/result/ModifyResult.java      |     34 -
 .../eagle/storage/result/QueryResult.java       |     67 -
 .../org/apache/eagle/storage/result/Result.java |     41 -
 .../storage/spi/DataStorageServiceLoader.java   |     95 -
 .../storage/spi/DataStorageServiceProvider.java |     35 -
 ...eagle.storage.spi.DataStorageServiceProvider |     16 -
 .../eagle/storage/TestDataStorageLoader.java    |     51 -
 .../java/org/apache/eagle/storage/TestUri.java  |     42 -
 .../storage/operation/TestCompiledQuery.java    |     81 -
 .../storage/operation/TestCreateStatement.java  |     53 -
 .../storage/operation/TestDeleteStatement.java  |     68 -
 .../storage/operation/TestQueryStatement.java   |     41 -
 .../operation/TestRowkeyQueryStatement.java     |     52 -
 .../storage/operation/TestUpdateStatement.java  |     47 -
 .../eagle/storage/spi/TestDataStorage.java      |     84 -
 .../spi/TestDataStorageServiceProvider.java     |     42 -
 ...eagle.storage.spi.DataStorageServiceProvider |     16 -
 .../src/test/resources/application.conf         |     31 -
 .../src/test/resources/log4j.properties         |     21 -
 .../eagle-query/eagle-storage-hbase/pom.xml     |    102 -
 .../src/assembly/hbase-coprocessor.xml          |     57 -
 .../storage/hbase/HBaseEntitySchemaManager.java |    107 -
 .../eagle/storage/hbase/HBaseStorage.java       |    232 -
 .../eagle/storage/hbase/HBaseStorageAudit.java  |    166 -
 .../hbase/query/GenericQueryBuilder.java        |    164 -
 .../query/aggregate/GenericAggregateReader.java |    124 -
 .../GenericCoprocessorAggregateQuery.java       |    398 -
 .../GenericInMemoryAggregateQuery.java          |    213 -
 .../query/coprocessor/AggregateClient.java      |     80 -
 .../query/coprocessor/AggregateProtocol.java    |     65 -
 .../coprocessor/AggregateProtocolEndPoint.java  |    423 -
 .../query/coprocessor/AggregateResult.java      |    128 -
 .../coprocessor/AggregateResultCallback.java    |     40 -
 .../query/coprocessor/ProtoBufConverter.java    |    146 -
 .../coprocessor/generated/AggregateProtos.java  |   4236 -
 .../coprocessor/impl/AggregateClientImpl.java   |    142 -
 .../impl/AggregateResultCallbackImpl.java       |    145 -
 .../hbase/query/coprocessor/package-info.java   |    108 -
 .../hbase/spi/HBaseStorageServiceProvider.java  |     35 -
 .../storage/hbase/tools/CoprocessorTool.java    |    159 -
 .../src/main/protobuf/AggregateProtocol.proto   |     65 -
 ...eagle.storage.spi.DataStorageServiceProvider |     16 -
 .../eagle/storage/hbase/TestHBaseStatement.java |     91 -
 .../storage/hbase/TestWithHBaseCoprocessor.java |     92 -
 .../TestAggregateResultCallback.java            |    183 -
 .../coprocessor/TestGroupAggregateClient.java   |    238 -
 .../TestGroupAggregateTimeSeriesClient.java     |    223 -
 .../storage/hbase/it/CoprocessorITSuite.java    |    246 -
 .../storage/hbase/it/CoprocessorJarUtils.java   |     41 -
 .../hbase/it/CoprocessorToolITSuite.java        |     92 -
 .../storage/hbase/spi/TestHBaseStorage.java     |    241 -
 ...estHBaseStorageAggregateWithCoprocessor.java |    111 -
 .../hbase/spi/TestHBaseStorageLoader.java       |     42 -
 .../src/test/resources/application-co.conf      |     33 -
 .../src/test/resources/application-it.conf      |     27 -
 .../src/test/resources/application.conf         |     32 -
 .../src/test/resources/hbase-site-sandbox.xml   |     40 -
 .../src/test/resources/log4j.properties         |     19 -
 .../eagle-query/eagle-storage-jdbc/pom.xml      |     59 -
 .../eagle/storage/jdbc/JdbcConstants.java       |     49 -
 .../apache/eagle/storage/jdbc/JdbcStorage.java  |    217 -
 .../storage/jdbc/conn/ConnectionConfig.java     |    100 -
 .../jdbc/conn/ConnectionConfigFactory.java      |     57 -
 .../storage/jdbc/conn/ConnectionManager.java    |     69 -
 .../jdbc/conn/ConnectionManagerFactory.java     |     75 -
 .../storage/jdbc/conn/PrimaryKeyBuilder.java    |     32 -
 .../storage/jdbc/conn/StatementExecutor.java    |     43 -
 .../impl/EncodedRowkeyPrimaryKeyBuilder.java    |     45 -
 .../conn/impl/TorqueConnectionManagerImpl.java  |    142 -
 .../jdbc/conn/impl/TorqueStatementPeerImpl.java |     58 -
 .../jdbc/conn/impl/UUIDPrimaryKeyBuilder.java   |     31 -
 .../storage/jdbc/criteria/CriteriaBuilder.java  |     26 -
 .../storage/jdbc/criteria/CriterionBuilder.java |     26 -
 .../impl/ExpressionCriterionBuilder.java        |    161 -
 .../impl/PrimaryKeyCriteriaBuilder.java         |     48 -
 .../criteria/impl/QueryCriteriaBuilder.java     |    146 -
 .../storage/jdbc/entity/JdbcEntityDeleter.java  |     48 -
 .../storage/jdbc/entity/JdbcEntityReader.java   |     49 -
 .../jdbc/entity/JdbcEntitySerDeserHelper.java   |    268 -
 .../storage/jdbc/entity/JdbcEntityUpdater.java  |     34 -
 .../storage/jdbc/entity/JdbcEntityUtils.java    |     26 -
 .../storage/jdbc/entity/JdbcEntityWriter.java   |     37 -
 .../jdbc/entity/impl/AggreagteRecordMapper.java |     56 -
 .../jdbc/entity/impl/EntityRecordMapper.java    |     51 -
 .../jdbc/entity/impl/JdbcEntityDeleterImpl.java |     87 -
 .../jdbc/entity/impl/JdbcEntityReaderImpl.java  |    136 -
 .../jdbc/entity/impl/JdbcEntityUpdaterImpl.java |     90 -
 .../jdbc/entity/impl/JdbcEntityWriterImpl.java  |    133 -
 .../eagle/storage/jdbc/entity/package-info.java |     25 -
 .../apache/eagle/storage/jdbc/package-info.java |     84 -
 .../jdbc/schema/IJdbcEntityDDLManager.java      |     26 -
 .../jdbc/schema/JdbcEntityDefinition.java       |    157 -
 .../schema/JdbcEntityDefinitionManager.java     |    170 -
 .../jdbc/schema/JdbcEntitySchemaManager.java    |    224 -
 .../eagle/storage/jdbc/schema/package-info.java |     24 -
 .../schema/serializer/DefaultJdbcSerDeser.java  |     67 -
 .../jdbc/schema/serializer/JdbcSerDeser.java    |     47 -
 .../schema/serializer/JsonJdbcSerDeser.java     |     55 -
 .../schema/serializer/MetricJdbcSerDeser.java   |     57 -
 .../jdbc/spi/JdbcStorageServiceProvider.java    |     38 -
 ...eagle.storage.spi.DataStorageServiceProvider |     16 -
 .../eagle/storage/jdbc/JdbcStorageTestBase.java |     46 -
 .../storage/jdbc/TestGenericMetricStorage.java  |    129 -
 .../eagle/storage/jdbc/TestJdbcStorage.java     |    243 -
 .../jdbc/criteria/TestQueryCriteriaBuilder.java |     93 -
 .../eagle/storage/jdbc/criteria/TestTorque.java |    119 -
 .../eagle/storage/jdbc/schema/TestDllUtils.java |     40 -
 .../jdbc/schema/TestJdbcEntityDefinition.java   |     33 -
 .../schema/TestJdbcEntitySchemaManager.java     |     27 -
 .../src/test/resources/application-derby.conf   |     29 -
 .../src/test/resources/application-mysql.conf   |     28 -
 .../src/test/resources/application.conf         |     28 -
 .../src/test/resources/log4j.properties         |     21 -
 .../test/resources/unittest.application.conf    |     28 -
 .../src/test/resources/unittest_ddl.derby.sql   |     34 -
 .../src/test/resources/unittest_ddl.mysql.sql   |     44 -
 eagle-core/eagle-query/pom.xml                  |    135 -
 eagle-core/pom.xml                              |     47 -
 eagle-dev/build.sh                              |     18 -
 eagle-dev/checkout-eagle-pr.py                  |    152 -
 eagle-dev/checkstyle-suppressions.xml           |     23 -
 eagle-dev/checkstyle.xml                        |    257 -
 eagle-dev/ci-build.sh                           |     31 -
 eagle-dev/ci-log4j.properties                   |     22 -
 eagle-dev/clean-all-services.sh                 |     21 -
 eagle-dev/eclipse-java-templates.xml            |     25 -
 eagle-dev/eclipse-scala-templates.xml           |    142 -
 eagle-dev/merge-eagle-pr.py                     |    464 -
 eagle-dev/start-webservice.sh                   |     39 -
 eagle-dev/start-zk-kafka-webservice.sh          |     49 -
 eagle-dev/start-zk-kafka.sh                     |     37 -
 eagle-dev/stop-all-services.sh                  |     31 -
 eagle-examples/eagle-app-example/pom.xml        |     50 -
 .../app/example/ExampleApplicationProvider.java |     85 -
 .../app/example/ExampleStormApplication.java    |     63 -
 .../extensions/ExampleCommonService.java        |     23 -
 .../extensions/ExampleCommonServiceImpl.java    |     27 -
 .../app/example/extensions/ExampleEntity.java   |     29 -
 .../extensions/ExampleEntityService.java        |     23 -
 .../ExampleEntityServiceMemoryImpl.java         |     30 -
 .../app/example/extensions/ExampleResource.java |     58 -
 .../main/resources/ExampleApplicationConf.xml   |     31 -
 ...e.app.example.ExampleApplicationProvider.xml |    107 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/webapp/app/apps/example/index.html |      6 -
 .../src/main/webapp/app/apps/example/index.js   |      1 -
 .../src/main/webapp/package.json                |      0
 .../example/ExampleApplicationProviderTest.java |    123 -
 .../src/test/resources/application.conf         |     69 -
 .../eagle-cassandra-example/.gitignore          |      2 -
 .../eagle-cassandra-example/README.md           |     43 -
 .../eagle-cassandra-example/bin/env.sh          |     31 -
 .../eagle-cassandra-example/bin/init.sh         |    278 -
 .../eagle-cassandra-example/bin/quick-start.sh  |     55 -
 .../bin/send-sample-querylog.sh                 |     26 -
 .../conf/cassandra-security-local.conf          |     69 -
 eagle-examples/pom.xml                          |     32 -
 eagle-external/eagle-ambari/.gitignore          |      3 -
 eagle-external/eagle-ambari/README.md           |     47 -
 eagle-external/eagle-ambari/bin/eagle-ambari.sh |    218 -
 .../lib/EAGLE/configuration/application.conf    |     77 -
 .../lib/EAGLE/configuration/eagle-env.sh        |     15 -
 .../lib/EAGLE/configuration/eagle-service.conf  |     25 -
 .../lib/EAGLE/configuration/log4j.properties    |     30 -
 .../eagle-ambari/lib/EAGLE/metainfo.xml         |    180 -
 .../package/patches/add-eagle-quicklink.patch   |     27 -
 .../lib/EAGLE/package/patches/app.js            | 173812 ----------------
 .../lib/EAGLE/package/scripts/__init__.py       |     15 -
 .../lib/EAGLE/package/scripts/actions.py        |    147 -
 .../EAGLE/package/scripts/eagle_audit_kafka.py  |     61 -
 .../lib/EAGLE/package/scripts/eagle_client.py   |     27 -
 .../package/scripts/eagle_hdfs_topology.py      |     88 -
 .../package/scripts/eagle_hive_topology.py      |     87 -
 .../lib/EAGLE/package/scripts/eagle_service.py  |     85 -
 .../package/scripts/eagle_service_check.py      |     29 -
 .../lib/EAGLE/package/scripts/eagle_topology.py |     84 -
 .../package/scripts/eagle_topology_check.py     |     29 -
 .../scripts/eagle_userprofile_scheduler.py      |     84 -
 .../scripts/eagle_userprofile_topology.py       |     88 -
 .../lib/EAGLE/package/scripts/params.py         |     57 -
 .../lib/EAGLE/package/scripts/service_check.py  |     34 -
 eagle-external/eagle-ambari/lib/metainfo.xml    |     27 -
 eagle-external/eagle-docker/Dockerfile          |     47 -
 eagle-external/eagle-docker/LICENSE             |    209 -
 eagle-external/eagle-docker/README.md           |    125 -
 eagle-external/eagle-docker/bin/eagle-docker.sh |    299 -
 eagle-external/eagle-docker/bin/eagle-lib.sh    |    163 -
 .../eagle-docker/resource/deploy-eagle.sh       |     85 -
 .../eagle-docker/resource/eagle-multinode.json  |    163 -
 .../eagle-docker/resource/eagle-singlenode.json |    127 -
 .../eagle-docker/resource/install-cluster.sh    |     36 -
 .../eagle-docker/resource/serf/etc/ambari.json  |      9 -
 .../eagle-docker/resource/serf/handlers/eagle   |     22 -
 .../eagle-docker/resource/wait-for-eagle.sh     |     38 -
 eagle-external/eagle-kafka/pom.xml              |     93 -
 .../src/main/resources/log4j.properties         |     19 -
 .../eagle/contrib/kafka/ProducerTool.scala      |    213 -
 eagle-external/eagle-log4jkafka/pom.xml         |    129 -
 .../eagle-log4jkafka/src/assembly/build.xml     |     61 -
 .../resources/conf/log4j-template.properties    |     31 -
 .../eagle/log4j/kafka/JKafkaLog4jAppender.scala |    136 -
 .../eagle/log4j/kafka/KafkaLog4jAppender.scala  |    164 -
 .../org/apache/eagle/log4j/kafka/Keyer.scala    |     32 -
 .../apache/eagle/log4j/kafka/TopicPicker.scala  |     32 -
 .../log4j/kafka/hadoop/AuditLogKeyer.scala      |     33 -
 .../log4j/kafka/hadoop/AuditLogUtils.scala      |     29 -
 .../kafka/hadoop/AuditSecurityLogKeyer.scala    |     43 -
 .../hadoop/FailedAuthenticationFilter.scala     |     42 -
 .../log4j/kafka/hadoop/GenericLogKeyer.scala    |     45 -
 .../log4j/kafka/hadoop/SecurityLogKeyer.scala   |     50 -
 .../kafka/hadoop/SecurityLogTopicPicker.scala   |     53 -
 .../src/test/resources/log4j.properties         |     30 -
 .../log4j/kafka/KafkaLog4jAppenderIT.scala      |     80 -
 .../eagle/log4j/kafka/KafkaTestBase.scala       |     66 -
 .../eagle/log4j/kafka/TestGenericLogKeyer.scala |     56 -
 .../log4j/kafka/TestKafkaLog4jAppender.scala    |     34 -
 eagle-external/hadoop_jmx_collectd/README.md    |     82 -
 eagle-external/hadoop_jmx_collectd/hadoop.py    |    183 -
 .../hadoop_jmx_collectd/hadooproleconfig.json   |     57 -
 eagle-external/hadoop_jmx_collector/.gitignore  |      2 -
 eagle-external/hadoop_jmx_collector/README.md   |     92 -
 .../hadoop_jmx_collector/hadoop_ha_checker.py   |    156 -
 .../hadoop_jmx_config-sample.json               |     72 -
 .../hadoop_jmx_collector/hadoop_jmx_config.json |     62 -
 .../hadoop_jmx_collector/hadoop_jmx_kafka.py    |    119 -
 .../hbase_jmx_config-sample.json                |     96 -
 .../lib/kafka-python/.gitignore                 |     30 -
 .../lib/kafka-python/.gitmodules                |     18 -
 .../lib/kafka-python/.travis.yml                |     44 -
 .../lib/kafka-python/AUTHORS.md                 |     35 -
 .../lib/kafka-python/CHANGES.md                 |     92 -
 .../lib/kafka-python/LICENSE                    |    202 -
 .../lib/kafka-python/MANIFEST.in                |      2 -
 .../lib/kafka-python/POWERED-BY.md              |     25 -
 .../lib/kafka-python/README.rst                 |     53 -
 .../lib/kafka-python/VERSION                    |      1 -
 .../lib/kafka-python/build_integration.sh       |     86 -
 .../lib/kafka-python/docs/Makefile              |    177 -
 .../kafka-python/docs/apidoc/kafka.consumer.rst |     46 -
 .../docs/apidoc/kafka.partitioner.rst           |     38 -
 .../kafka-python/docs/apidoc/kafka.producer.rst |     38 -
 .../lib/kafka-python/docs/apidoc/kafka.rst      |     79 -
 .../lib/kafka-python/docs/apidoc/modules.rst    |      7 -
 .../lib/kafka-python/docs/conf.py               |    291 -
 .../lib/kafka-python/docs/index.rst             |     58 -
 .../lib/kafka-python/docs/install.rst           |     79 -
 .../lib/kafka-python/docs/make.bat              |    242 -
 .../lib/kafka-python/docs/requirements.txt      |      7 -
 .../lib/kafka-python/docs/tests.rst             |     59 -
 .../lib/kafka-python/docs/usage.rst             |    124 -
 .../lib/kafka-python/example.py                 |     69 -
 .../lib/kafka-python/kafka/NOTES.md             |     32 -
 .../lib/kafka-python/kafka/__init__.py          |     27 -
 .../lib/kafka-python/kafka/client.py            |    503 -
 .../lib/kafka-python/kafka/codec.py             |    143 -
 .../lib/kafka-python/kafka/common.py            |    215 -
 .../lib/kafka-python/kafka/conn.py              |    208 -
 .../lib/kafka-python/kafka/consumer/__init__.py |      7 -
 .../lib/kafka-python/kafka/consumer/base.py     |    173 -
 .../lib/kafka-python/kafka/consumer/kafka.py    |    758 -
 .../kafka-python/kafka/consumer/multiprocess.py |    251 -
 .../lib/kafka-python/kafka/consumer/simple.py   |    330 -
 .../lib/kafka-python/kafka/context.py           |    175 -
 .../kafka-python/kafka/partitioner/__init__.py  |      6 -
 .../lib/kafka-python/kafka/partitioner/base.py  |     24 -
 .../kafka-python/kafka/partitioner/hashed.py    |     14 -
 .../kafka/partitioner/roundrobin.py             |     23 -
 .../lib/kafka-python/kafka/producer/__init__.py |      6 -
 .../lib/kafka-python/kafka/producer/base.py     |    214 -
 .../lib/kafka-python/kafka/producer/keyed.py    |     68 -
 .../lib/kafka-python/kafka/producer/simple.py   |     81 -
 .../lib/kafka-python/kafka/protocol.py          |    604 -
 .../lib/kafka-python/kafka/util.py              |    153 -
 .../lib/kafka-python/load_example.py            |     60 -
 .../servers/0.8.0/resources/kafka.properties    |     59 -
 .../servers/0.8.0/resources/log4j.properties    |     24 -
 .../0.8.0/resources/zookeeper.properties        |     19 -
 .../servers/0.8.1.1/resources/kafka.properties  |    118 -
 .../servers/0.8.1.1/resources/log4j.properties  |     24 -
 .../0.8.1.1/resources/zookeeper.properties      |     21 -
 .../servers/0.8.1/resources/kafka.properties    |     59 -
 .../servers/0.8.1/resources/log4j.properties    |     24 -
 .../0.8.1/resources/zookeeper.properties        |     19 -
 .../servers/0.8.2.0/resources/kafka.properties  |    118 -
 .../servers/0.8.2.0/resources/log4j.properties  |     24 -
 .../0.8.2.0/resources/zookeeper.properties      |     21 -
 .../servers/trunk/resources/kafka.properties    |    118 -
 .../servers/trunk/resources/log4j.properties    |     24 -
 .../trunk/resources/zookeeper.properties        |     21 -
 .../lib/kafka-python/setup.py                   |     70 -
 .../lib/kafka-python/test/__init__.py           |      6 -
 .../lib/kafka-python/test/fixtures.py           |    236 -
 .../lib/kafka-python/test/service.py            |    111 -
 .../lib/kafka-python/test/test_client.py        |    403 -
 .../test/test_client_integration.py             |     67 -
 .../lib/kafka-python/test/test_codec.py         |     72 -
 .../lib/kafka-python/test/test_conn.py          |    164 -
 .../lib/kafka-python/test/test_consumer.py      |     15 -
 .../test/test_consumer_integration.py           |    401 -
 .../lib/kafka-python/test/test_context.py       |    117 -
 .../test/test_failover_integration.py           |    201 -
 .../lib/kafka-python/test/test_package.py       |     29 -
 .../lib/kafka-python/test/test_producer.py      |     42 -
 .../test/test_producer_integration.py           |    481 -
 .../lib/kafka-python/test/test_protocol.py      |    732 -
 .../lib/kafka-python/test/test_util.py          |    126 -
 .../lib/kafka-python/test/testutil.py           |    105 -
 .../lib/kafka-python/tox.ini                    |     50 -
 .../lib/kafka-python/travis_selector.sh         |     16 -
 .../hadoop_jmx_collector/lib/six/.gitignore     |     23 -
 .../hadoop_jmx_collector/lib/six/CHANGES        |    231 -
 .../hadoop_jmx_collector/lib/six/CONTRIBUTORS   |     21 -
 .../hadoop_jmx_collector/lib/six/LICENSE        |     18 -
 .../hadoop_jmx_collector/lib/six/MANIFEST.in    |      6 -
 .../hadoop_jmx_collector/lib/six/README         |     16 -
 .../lib/six/documentation/Makefile              |    130 -
 .../lib/six/documentation/conf.py               |    217 -
 .../lib/six/documentation/index.rst             |    757 -
 .../hadoop_jmx_collector/lib/six/setup.cfg      |      2 -
 .../hadoop_jmx_collector/lib/six/setup.py       |     32 -
 .../hadoop_jmx_collector/lib/six/six.py         |    762 -
 .../hadoop_jmx_collector/lib/six/test_six.py    |    736 -
 .../hadoop_jmx_collector/lib/six/tox.ini        |     12 -
 .../hadoop_jmx_collector/metric_collector.py    |    597 -
 .../system_metric_collector.py                  |    338 -
 .../system_metric_config-sample.json            |     21 -
 .../hadoop_jmx_collector/util_func.py           |     79 -
 eagle-external/pom.xml                          |     36 -
 eagle-gc/pom.xml                                |     56 -
 .../org/apache/eagle/gc/GCLogApplication.java   |     80 -
 .../eagle/gc/GCLogApplicationProvider.java      |     34 -
 .../org/apache/eagle/gc/common/GCConstants.java |     30 -
 .../eagle/gc/executor/GCLogAnalyzerBolt.java    |     80 -
 .../gc/executor/GCMetricGeneratorBolt.java      |    123 -
 .../apache/eagle/gc/model/GCPausedEvent.java    |    249 -
 .../apache/eagle/gc/parser/DateTimeParser.java  |     37 -
 .../apache/eagle/gc/parser/GCEventParser.java   |     31 -
 .../eagle/gc/parser/GCEventParserEnum.java      |     46 -
 .../java/org/apache/eagle/gc/parser/GCType.java |     26 -
 .../eagle/gc/parser/OtherLogFormatParser.java   |     39 -
 .../exception/IgnoredLogFormatException.java    |     39 -
 .../UnrecognizedLogFormatException.java         |     39 -
 .../full/ConcurrentModeFailureParser.java       |     62 -
 .../gc/parser/full/NormalFullGCParser.java      |     79 -
 .../full/ParaNewPromotionFailureParser.java     |    106 -
 .../gc/parser/tenured/CMSInitialMarkParser.java |     63 -
 .../gc/parser/tenured/CMSRemarkParser.java      |     72 -
 .../eagle/gc/parser/young/ParaNewParser.java    |     77 -
 .../apache/eagle/gc/stream/GCStreamBuilder.java |     46 -
 ...apache.eagle.gc.GCLogApplicationProvider.xml |    179 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     37 -
 .../src/main/resources/application-gclog.conf   |     44 -
 .../src/main/resources/gclog-NNFullGC-import.sh |     33 -
 .../resources/gclog-NNGCPauseTimeLong-import.sh |     33 -
 .../hadoop-namenode-gc-logstash-kafka.conf      |     30 -
 eagle-gc/src/main/resources/log4j.properties    |     19 -
 .../java/org/apache/eagle/TestGCLogParser.java  |    118 -
 eagle-jpm/eagle-hadoop-queue/pom.xml            |     80 -
 .../hadoop/queue/HadoopQueueRunningApp.java     |     68 -
 .../queue/HadoopQueueRunningAppConfig.java      |     83 -
 .../queue/HadoopQueueRunningAppProvider.java    |     34 -
 ...adoopQueueRunningApplicationHealthCheck.java |    105 -
 .../hadoop/queue/HadoopQueueRunningMain.java    |     25 -
 .../queue/common/HadoopClusterConstants.java    |     83 -
 .../queue/common/HadoopYarnResourceUtils.java   |     68 -
 .../common/YarnClusterResourceURLBuilder.java   |     58 -
 .../queue/crawler/ClusterMetricsCrawler.java    |     65 -
 .../crawler/ClusterMetricsParseListener.java    |    156 -
 .../queue/crawler/RunningAppParseListener.java  |    167 -
 .../queue/crawler/RunningAppsCrawler.java       |     68 -
 .../queue/crawler/SchedulerInfoCrawler.java     |     67 -
 .../crawler/SchedulerInfoParseListener.java     |    181 -
 .../exceptions/HadoopQueueFetcherException.java |     59 -
 .../model/HadoopQueueEntityRepository.java      |     30 -
 .../hadoop/queue/model/applications/App.java    |    242 -
 .../queue/model/applications/AppStreamInfo.java |     54 -
 .../hadoop/queue/model/applications/Apps.java   |     42 -
 .../queue/model/applications/AppsWrapper.java   |     37 -
 .../model/applications/YarnAppAPIEntity.java    |    113 -
 .../queue/model/cluster/ClusterMetrics.java     |    239 -
 .../model/cluster/ClusterMetricsWrapper.java    |     37 -
 .../hadoop/queue/model/scheduler/Queue.java     |    229 -
 .../queue/model/scheduler/QueueStreamInfo.java  |     79 -
 .../scheduler/QueueStructureAPIEntity.java      |     69 -
 .../hadoop/queue/model/scheduler/Queues.java    |     38 -
 .../queue/model/scheduler/ResourcesUsed.java    |     48 -
 .../model/scheduler/RunningQueueAPIEntity.java  |    169 -
 .../hadoop/queue/model/scheduler/Scheduler.java |     36 -
 .../queue/model/scheduler/SchedulerInfo.java    |     83 -
 .../queue/model/scheduler/SchedulerWrapper.java |     36 -
 .../hadoop/queue/model/scheduler/User.java      |     63 -
 .../queue/model/scheduler/UserWrapper.java      |     74 -
 .../queue/model/scheduler/UserWrappers.java     |     39 -
 .../hadoop/queue/model/scheduler/Users.java     |     38 -
 .../queue/storm/HadoopQueueMessageId.java       |     57 -
 .../storm/HadoopQueueMetricPersistBolt.java     |    126 -
 .../storm/HadoopQueueRunningExtractor.java      |     85 -
 .../queue/storm/HadoopQueueRunningSpout.java    |     73 -
 ...doop.queue.HadoopQueueRunningAppProvider.xml |    182 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/resources/application.conf         |     47 -
 .../src/main/resources/log4j.properties         |     34 -
 .../HadoopQueueRunningAppProviderTest.java      |     31 -
 .../hadoop/queue/HadoopQueueRunningAppTest.java |     27 -
 .../hadoop/queue/TestClusterMetricsCrawler.java |     39 -
 .../queue/TestHadoopYarnResourceUtils.java      |     54 -
 .../hadoop/queue/TestRunningAppsCrawler.java    |     39 -
 .../hadoop/queue/TestSchedulerInfoCrawler.java  |     39 -
 .../YarnClusterResourceURLBuilderTest.java      |     80 -
 .../src/test/resources/application-bak.conf     |     36 -
 .../src/test/resources/application.conf         |     47 -
 .../src/test/resources/log4j.properties         |     34 -
 eagle-jpm/eagle-jpm-aggregation/pom.xml         |     66 -
 .../jpm/aggregation/AggregationApplication.java |     72 -
 .../AggregationApplicationProvider.java         |     26 -
 .../jpm/aggregation/AggregationConfig.java      |    115 -
 .../eagle/jpm/aggregation/AggregationMain.java  |     24 -
 .../aggregation/common/AggregatorColumns.java   |     61 -
 .../aggregation/common/MetricAggregator.java    |     23 -
 .../common/MetricsAggregateContainer.java       |     25 -
 .../jpm/aggregation/mr/MRMetricAggregator.java  |    163 -
 .../mr/MRMetricsAggregateContainer.java         |     94 -
 .../state/AggregationTimeManager.java           |    103 -
 .../jpm/aggregation/storm/AggregationBolt.java  |     68 -
 .../jpm/aggregation/storm/AggregationSpout.java |    139 -
 ...gregation.AggregationApplicationProvider.xml |     75 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/resources/application.conf         |     53 -
 eagle-jpm/eagle-jpm-analyzer/pom.xml            |     64 -
 .../apache/eagle/jpm/analyzer/Evaluator.java    |     25 -
 .../apache/eagle/jpm/analyzer/JobAnalyzer.java  |     30 -
 .../apache/eagle/jpm/analyzer/Processor.java    |     25 -
 .../analyzer/meta/MetaManagementService.java    |     41 -
 .../impl/MetaManagementServiceJDBCImpl.java     |    231 -
 .../impl/MetaManagementServiceMemoryImpl.java   |    138 -
 .../meta/impl/orm/JobMetaEntityToRelation.java  |     62 -
 .../meta/impl/orm/RelationToJobMetaEntity.java  |     93 -
 .../impl/orm/RelationToUserEmailEntity.java     |     37 -
 .../impl/orm/UserEmailEntityToRelation.java     |     57 -
 .../jpm/analyzer/meta/model/AnalyzerEntity.java |    130 -
 .../jpm/analyzer/meta/model/JobMetaEntity.java  |     82 -
 .../meta/model/MapReduceAnalyzerEntity.java     |    174 -
 .../analyzer/meta/model/UserEmailEntity.java    |     91 -
 .../analyzer/mr/MRJobPerformanceAnalyzer.java   |     79 -
 .../jpm/analyzer/mr/sla/SLAJobEvaluator.java    |     68 -
 .../sla/processors/LongStuckJobProcessor.java   |     43 -
 .../UnExpectedLongDurationJobProcessor.java     |    125 -
 .../mr/suggestion/JobSuggestionEvaluator.java   |    116 -
 .../MapReduceCompressionSettingProcessor.java   |     82 -
 .../suggestion/MapReduceDataSkewProcessor.java  |     63 -
 .../mr/suggestion/MapReduceGCTimeProcessor.java |     78 -
 .../MapReduceJobSuggestionContext.java          |    209 -
 .../MapReduceQueueResourceProcessor.java        |     83 -
 .../mr/suggestion/MapReduceSpillProcessor.java  |    124 -
 .../MapReduceSplitSettingProcessor.java         |     44 -
 .../suggestion/MapReduceTaskNumProcessor.java   |    194 -
 .../analyzer/publisher/EagleStorePublisher.java |     72 -
 .../jpm/analyzer/publisher/EmailPublisher.java  |    141 -
 .../eagle/jpm/analyzer/publisher/Publisher.java |     24 -
 .../eagle/jpm/analyzer/publisher/Result.java    |    193 -
 .../publisher/dedup/AlertDeduplicator.java      |     25 -
 .../dedup/impl/SimpleDeduplicator.java          |     66 -
 .../jpm/analyzer/resource/AnalyzerResource.java |    160 -
 .../eagle/jpm/analyzer/util/Constants.java      |     68 -
 .../apache/eagle/jpm/analyzer/util/Utils.java   |    106 -
 .../main/resources/AnalyzerReportTemplate.vm    |    266 -
 .../src/main/resources/createTable.sql          |     38 -
 eagle-jpm/eagle-jpm-entity/pom.xml              |     51 -
 .../mr/historyentity/JPAEntityRepository.java   |     44 -
 .../jpm/mr/historyentity/JobBaseAPIEntity.java  |     24 -
 .../eagle/jpm/mr/historyentity/JobConfig.java   |     38 -
 .../jpm/mr/historyentity/JobConfigSerDeser.java |     67 -
 .../JobConfigurationAPIEntity.java              |     71 -
 .../jpm/mr/historyentity/JobCountEntity.java    |     56 -
 .../JobErrorCategoryMappingAPIEntity.java       |     62 -
 .../jpm/mr/historyentity/JobEventAPIEntity.java |     44 -
 .../mr/historyentity/JobExecutionAPIEntity.java |    357 -
 .../JobProcessTimeStampEntity.java              |     45 -
 .../historyentity/JobSuggestionAPIEntity.java   |     63 -
 .../TaskAttemptCounterAPIEntity.java            |     66 -
 .../TaskAttemptErrorCategoryEntity.java         |     61 -
 .../TaskAttemptExecutionAPIEntity.java          |    138 -
 .../historyentity/TaskExecutionAPIEntity.java   |    103 -
 .../TaskFailureCountAPIEntity.java              |     66 -
 .../jpm/mr/runningentity/AppStreamInfo.java     |     53 -
 .../mr/runningentity/JPMEntityRepository.java   |     34 -
 .../eagle/jpm/mr/runningentity/JobConfig.java   |     26 -
 .../jpm/mr/runningentity/JobConfigSerDeser.java |     46 -
 .../mr/runningentity/JobExecutionAPIEntity.java |    460 -
 .../TaskAttemptExecutionAPIEntity.java          |    137 -
 .../runningentity/TaskExecutionAPIEntity.java   |    127 -
 .../jpm/mr/runningentity/YarnAppAPIEntity.java  |    112 -
 .../jpm/spark/entity/JPMEntityRepository.java   |     32 -
 .../eagle/jpm/spark/entity/JobConfig.java       |     40 -
 .../jpm/spark/entity/JobConfigSerDeser.java     |     46 -
 .../apache/eagle/jpm/spark/entity/SparkApp.java |    432 -
 .../eagle/jpm/spark/entity/SparkExecutor.java   |    234 -
 .../apache/eagle/jpm/spark/entity/SparkJob.java |    179 -
 .../eagle/jpm/spark/entity/SparkStage.java      |    300 -
 .../eagle/jpm/spark/entity/SparkTask.java       |    291 -
 .../running/entities/JPMEntityRepository.java   |     32 -
 .../jpm/spark/running/entities/JobConfig.java   |     26 -
 .../running/entities/JobConfigSerDeser.java     |     49 -
 .../spark/running/entities/SparkAppEntity.java  |    476 -
 .../running/entities/SparkExecutorEntity.java   |    233 -
 .../spark/running/entities/SparkJobEntity.java  |    191 -
 .../running/entities/SparkStageEntity.java      |    299 -
 .../spark/running/entities/SparkTaskEntity.java |    290 -
 eagle-jpm/eagle-jpm-mr-history/pom.xml          |    105 -
 .../jpm/mr/history/MRHistoryJobApplication.java |     99 -
 .../MRHistoryJobApplicationHealthCheck.java     |    103 -
 .../MRHistoryJobApplicationListener.java        |     46 -
 .../MRHistoryJobApplicationProvider.java        |     64 -
 .../jpm/mr/history/MRHistoryJobConfig.java      |    140 -
 .../mr/history/MRHistoryJobDailyReporter.java   |    304 -
 .../eagle/jpm/mr/history/MRHistoryJobMain.java  |     25 -
 .../history/crawler/AbstractJobHistoryDAO.java  |    155 -
 .../crawler/DefaultJHFInputStreamCallback.java  |     64 -
 .../history/crawler/EagleOutputCollector.java   |     31 -
 .../mr/history/crawler/JHFCrawlerDriver.java    |     27 -
 .../history/crawler/JHFCrawlerDriverImpl.java   |    283 -
 .../history/crawler/JHFInputStreamCallback.java |     37 -
 .../crawler/JobHistoryContentFilter.java        |     37 -
 .../crawler/JobHistoryContentFilterBuilder.java |    100 -
 .../crawler/JobHistoryContentFilterImpl.java    |    105 -
 .../mr/history/crawler/JobHistoryDAOImpl.java   |    199 -
 .../jpm/mr/history/crawler/JobHistoryLCM.java   |     92 -
 .../JobHistorySpoutCollectorInterceptor.java    |     40 -
 .../metrics/JobCountMetricsGenerator.java       |    105 -
 .../metrics/JobCounterMetricsGenerator.java     |    138 -
 .../JobExecutionMetricsCreationListener.java    |     85 -
 .../jpm/mr/history/parser/EagleJobStatus.java   |     29 -
 .../jpm/mr/history/parser/EagleTaskStatus.java  |     25 -
 .../HistoryJobEntityCreationListener.java       |     39 -
 .../HistoryJobEntityLifecycleListener.java      |     33 -
 .../jpm/mr/history/parser/ImportException.java  |     31 -
 .../mr/history/parser/JHFEventReaderBase.java   |    628 -
 .../eagle/jpm/mr/history/parser/JHFFormat.java  |     25 -
 .../mr/history/parser/JHFMRVer2EventReader.java |    577 -
 .../jpm/mr/history/parser/JHFMRVer2Parser.java  |     88 -
 .../jpm/mr/history/parser/JHFParserBase.java    |     31 -
 .../jpm/mr/history/parser/JHFParserFactory.java |     52 -
 .../parser/JHFWriteNotCompletedException.java   |     32 -
 ...JobConfigurationCreationServiceListener.java |     92 -
 .../JobEntityCreationEagleServiceListener.java  |    188 -
 .../parser/JobEntityCreationPublisher.java      |     43 -
 .../parser/JobEntityLifecycleAggregator.java    |    176 -
 .../history/parser/JobSuggestionListener.java   |     95 -
 .../mr/history/parser/MRErrorClassifier.java    |    117 -
 .../jpm/mr/history/parser/RecordTypes.java      |     27 -
 .../parser/TaskAttemptCounterListener.java      |    153 -
 .../mr/history/parser/TaskFailureListener.java  |    144 -
 .../history/publisher/JobStreamPublisher.java   |     54 -
 .../mr/history/publisher/StreamPublisher.java   |     48 -
 .../publisher/StreamPublisherManager.java       |     54 -
 .../publisher/TaskAttemptStreamPublisher.java   |     54 -
 .../jpm/mr/history/storm/JobHistorySpout.java   |    290 -
 .../history/zkres/JobHistoryZKStateManager.java |    331 -
 .../src/main/resources/JobCounter.conf          |    188 -
 .../src/main/resources/JobReportTemplate.vm     |    419 -
 .../src/main/resources/JobReportTemplatePure.vm |    141 -
 ....history.MRHistoryJobApplicationProvider.xml |    286 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../services/org.apache.hadoop.fs.FileSystem    |     20 -
 .../src/main/resources/MRErrorCategory.config   |     44 -
 .../src/main/resources/application.conf         |     80 -
 .../src/main/resources/log4j.properties         |     34 -
 .../MRHistoryJobApplicationProviderTest.java    |     31 -
 .../mr/history/MRHistoryJobApplicationTest.java |     27 -
 .../history/MRHistoryJobDailyReporterTest.java  |    110 -
 .../mr/history/storm/JobHistorySpoutTest.java   |    216 -
 .../src/test/resources/application-test.conf    |     58 -
 ...41898_508949-1481299030929-testhistory.jhist |     37 -
 .../resources/job_1479206441898_508949_conf.xml |     18 -
 .../src/test/resources/log4j.properties         |     34 -
 eagle-jpm/eagle-jpm-mr-running/pom.xml          |    100 -
 .../jpm/mr/running/MRRunningJobApplication.java |     87 -
 .../MRRunningJobApplicationListener.java        |     49 -
 .../MRRunningJobApplicationProvider.java        |     45 -
 .../jpm/mr/running/MRRunningJobConfig.java      |    161 -
 .../eagle/jpm/mr/running/MRRunningJobMain.java  |     25 -
 .../parser/MRJobEntityCreationHandler.java      |    121 -
 .../jpm/mr/running/parser/MRJobParser.java      |    611 -
 .../JobExecutionMetricsCreationListener.java    |     61 -
 .../TaskExecutionMetricsCreationListener.java   |     46 -
 .../mr/running/recover/MRRunningJobManager.java |     82 -
 .../running/storm/MRRunningAppMetricBolt.java   |    235 -
 .../running/storm/MRRunningJobFetchSpout.java   |    187 -
 .../mr/running/storm/MRRunningJobParseBolt.java |    116 -
 .../src/main/resources/JobCounter.conf          |    187 -
 ....running.MRRunningJobApplicationProvider.xml |    241 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/resources/application.conf         |     57 -
 .../src/main/resources/log4j.properties         |     35 -
 .../MRRunningJobApplicationProviderTest.java    |     32 -
 .../mr/running/MRRunningJobApplicationTest.java |    260 -
 .../jpm/mr/running/MRRunningJobManagerTest.java |    207 -
 .../parser/MRJobEntityCreationHandlerTest.java  |    233 -
 .../jpm/mr/running/parser/MRJobParserTest.java  |    503 -
 .../application_1479206441898_35341.json        |     35 -
 .../src/test/resources/jobInfo_805.json         |      4 -
 .../src/test/resources/jobcounts_30784.json     |    390 -
 .../src/test/resources/mrconf_30784.xml         |     16 -
 .../src/test/resources/mrjob_30784.json         |     37 -
 .../src/test/resources/mrtasks_30784.json       |     61 -
 .../test/resources/previousmrrunningapp.json    |     64 -
 .../test/resources/thistimemrrunningapp.json    |     35 -
 eagle-jpm/eagle-jpm-service/pom.xml             |     52 -
 .../service/jpm/MRJobExecutionResource.java     |    360 -
 .../service/jpm/MRJobTaskCountResponse.java     |     70 -
 .../service/jpm/MRTaskExecutionResource.java    |    241 -
 .../service/jpm/MRTaskExecutionResponse.java    |     85 -
 .../apache/eagle/service/jpm/ResourceUtils.java |     87 -
 .../eagle/service/jpm/RunningQueueResource.java |    154 -
 .../eagle/service/jpm/RunningQueueResponse.java |     50 -
 .../eagle/service/jpm/count/MRJobCountImpl.java |    146 -
 .../service/jpm/count/MRTaskCountImpl.java      |    124 -
 .../service/jpm/suggestion/AbstractGCFunc.java  |    104 -
 .../jpm/suggestion/AbstractInputFunc.java       |     86 -
 .../eagle/service/jpm/suggestion/MapGCFunc.java |     38 -
 .../service/jpm/suggestion/MapInputFunc.java    |     40 -
 .../service/jpm/suggestion/MapSpillFunc.java    |     90 -
 .../service/jpm/suggestion/ReduceGCFunc.java    |     38 -
 .../service/jpm/suggestion/ReduceInputFunc.java |     39 -
 .../service/jpm/suggestion/SuggestionFunc.java  |     27 -
 .../service/jpm/count/TestMRJobCountImpl.java   |     92 -
 .../service/jpm/count/TestMRTaskCountImpl.java  |    129 -
 .../jpm/suggestion/TestDataSkewFunc.java        |     89 -
 .../jpm/suggestion/TestTaskCounterFunc.java     |     88 -
 eagle-jpm/eagle-jpm-spark-history/pom.xml       |     79 -
 .../jpm/spark/history/SparkHistoryJobApp.java   |     53 -
 .../spark/history/SparkHistoryJobAppConfig.java |    141 -
 .../history/SparkHistoryJobAppProvider.java     |     36 -
 .../SparkHistoryJobApplicationHealthCheck.java  |    102 -
 .../jpm/spark/history/SparkHistoryJobMain.java  |     25 -
 .../history/crawl/JHFInputStreamReader.java     |     24 -
 .../jpm/spark/history/crawl/JHFParserBase.java  |     29 -
 .../history/crawl/JHFSparkEventReader.java      |    721 -
 .../jpm/spark/history/crawl/JHFSparkParser.java |     68 -
 .../history/crawl/SparkApplicationInfo.java     |     69 -
 .../SparkFilesystemInputStreamReaderImpl.java   |     55 -
 .../status/JobHistoryZKStateManager.java        |    252 -
 .../spark/history/status/ZKStateConstant.java   |     27 -
 .../history/storm/SparkHistoryJobParseBolt.java |    200 -
 .../history/storm/SparkHistoryJobSpout.java     |    142 -
 ...spark.history.SparkHistoryJobAppProvider.xml |    166 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../services/org.apache.hadoop.fs.FileSystem    |     20 -
 .../src/main/resources/application.conf         |     75 -
 .../src/main/resources/log4j.properties         |     35 -
 .../java/SparkHistoryJobAppProviderTest.java    |     31 -
 eagle-jpm/eagle-jpm-spark-running/pom.xml       |     91 -
 .../jpm/spark/running/SparkRunningJobApp.java   |     68 -
 .../spark/running/SparkRunningJobAppConfig.java |    166 -
 .../running/SparkRunningJobAppProvider.java     |     26 -
 .../jpm/spark/running/SparkRunningJobMain.java  |     25 -
 .../eagle/jpm/spark/running/common/Util.java    |     35 -
 .../parser/SparkAppEntityCreationHandler.java   |     73 -
 .../running/parser/SparkApplicationParser.java  |    644 -
 .../running/recover/SparkRunningJobManager.java |     81 -
 .../storm/SparkRunningJobFetchSpout.java        |    180 -
 .../running/storm/SparkRunningJobParseBolt.java |    120 -
 ...spark.running.SparkRunningJobAppProvider.xml |    110 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../services/org.apache.hadoop.fs.FileSystem    |     20 -
 .../src/main/resources/application.conf         |     62 -
 .../src/main/resources/log4j.properties         |     35 -
 .../java/SparkRunningJobAppProviderTest.java    |     31 -
 eagle-jpm/eagle-jpm-util/pom.xml                |     82 -
 .../org/apache/eagle/jpm/util/Constants.java    |    208 -
 .../eagle/jpm/util/DefaultJobIdPartitioner.java |     28 -
 .../org/apache/eagle/jpm/util/HDFSUtil.java     |     47 -
 .../org/apache/eagle/jpm/util/JSONUtils.java    |    109 -
 .../org/apache/eagle/jpm/util/JobIdFilter.java  |     23 -
 .../eagle/jpm/util/JobIdFilterByPartition.java  |     40 -
 .../apache/eagle/jpm/util/JobIdPartitioner.java |     23 -
 .../eagle/jpm/util/JobNameNormalization.java    |    116 -
 .../org/apache/eagle/jpm/util/MRJobTagName.java |     49 -
 .../eagle/jpm/util/SparkEntityConstant.java     |     29 -
 .../apache/eagle/jpm/util/SparkEventType.java   |     25 -
 .../apache/eagle/jpm/util/SparkJobTagName.java  |     45 -
 .../java/org/apache/eagle/jpm/util/Utils.java   |    121 -
 .../util/jobcounter/CounterGroupDictionary.java |    249 -
 .../jpm/util/jobcounter/CounterGroupKey.java    |     37 -
 .../eagle/jpm/util/jobcounter/CounterKey.java   |     31 -
 .../util/jobcounter/JobCounterException.java    |     59 -
 .../eagle/jpm/util/jobcounter/JobCounters.java  |    130 -
 .../util/jobcounter/JobCountersSerDeser.java    |    165 -
 .../jpm/util/jobrecover/RunningJobManager.java  |    310 -
 .../AbstractMetricsCreationListener.java        |     42 -
 .../util/resourcefetch/RMResourceFetcher.java   |    247 -
 .../jpm/util/resourcefetch/ResourceFetcher.java |     27 -
 .../SparkHistoryServerResourceFetcher.java      |     87 -
 .../connection/InputStreamUtils.java            |     68 -
 .../util/resourcefetch/connection/JobUtils.java |     43 -
 .../connection/URLConnectionUtils.java          |    101 -
 .../util/resourcefetch/ha/HAURLSelector.java    |     28 -
 .../resourcefetch/ha/HAURLSelectorImpl.java     |    117 -
 .../jpm/util/resourcefetch/model/AppInfo.java   |    254 -
 .../util/resourcefetch/model/Applications.java  |     38 -
 .../util/resourcefetch/model/AppsWrapper.java   |     37 -
 .../util/resourcefetch/model/ClusterInfo.java   |    135 -
 .../resourcefetch/model/ClusterInfoWrapper.java |     35 -
 .../resourcefetch/model/JobCounterGroup.java    |     46 -
 .../resourcefetch/model/JobCounterItem.java     |     62 -
 .../util/resourcefetch/model/JobCounters.java   |     46 -
 .../resourcefetch/model/JobCountersWrapper.java |     35 -
 .../jpm/util/resourcefetch/model/MRJob.java     |    289 -
 .../util/resourcefetch/model/MRJobsWrapper.java |     37 -
 .../jpm/util/resourcefetch/model/MRTask.java    |    109 -
 .../util/resourcefetch/model/MRTaskAttempt.java |    136 -
 .../model/MRTaskAttemptWrapper.java             |     37 -
 .../resourcefetch/model/MRTaskAttempts.java     |     39 -
 .../jpm/util/resourcefetch/model/MRTasks.java   |     40 -
 .../resourcefetch/model/MRTasksWrapper.java     |     37 -
 .../jpm/util/resourcefetch/model/MrJobs.java    |     39 -
 .../resourcefetch/model/SparkApplication.java   |     57 -
 .../model/SparkApplicationAttempt.java          |     73 -
 .../model/SparkApplicationWrapper.java          |     38 -
 .../util/resourcefetch/model/SparkExecutor.java |    155 -
 .../jpm/util/resourcefetch/model/SparkJob.java  |    165 -
 .../util/resourcefetch/model/SparkStage.java    |    211 -
 .../jpm/util/resourcefetch/model/SparkTask.java |    111 -
 .../model/SparkTaskInputMetrics.java            |     46 -
 .../resourcefetch/model/SparkTaskMetrics.java   |    118 -
 .../model/SparkTaskShuffleReadMetrics.java      |     82 -
 .../model/SparkTaskShuffleWriteMetrics.java     |     55 -
 .../resourcefetch/model/TaskCounterGroup.java   |     46 -
 .../resourcefetch/model/TaskCounterItem.java    |     44 -
 .../util/resourcefetch/model/TaskCounters.java  |     46 -
 .../model/TaskCountersWrapper.java              |     35 -
 .../url/JobListServiceURLBuilderImpl.java       |     49 -
 .../url/RmActiveTestURLBuilderImpl.java         |     28 -
 .../resourcefetch/url/ServiceURLBuilder.java    |     21 -
 .../SparkCompleteJobServiceURLBuilderImpl.java  |     33 -
 .../url/SparkJobServiceURLBuilderImpl.java      |     31 -
 .../jpm/util/resourcefetch/url/URLUtil.java     |     33 -
 .../src/main/resources/JobCounter.conf          |    187 -
 .../src/main/resources/application.properties   |     23 -
 .../jpm/util/DefaultJobIdPartitionerTest.java   |     29 -
 .../apache/eagle/jpm/util/JSONUtilsTest.java    |     79 -
 .../jpm/util/JobNameNormalizationTest.java      |     45 -
 .../org/apache/eagle/jpm/util/UtilsTest.java    |     86 -
 .../jobcounter/JobCountersSerDeserTest.java     |     46 -
 .../resourcefetch/RMResourceFetcherTest.java    |    105 -
 .../resourcefetch/ha/HAURLSelectorImplTest.java |    102 -
 .../url/JobListServiceURLBuilderImplTest.java   |     38 -
 ...arkCompleteJobServiceURLBuilderImplTest.java |     30 -
 .../url/SparkJobServiceURLBuilderImplTest.java  |     30 -
 .../jpm/util/resourcefetch/url/URLUtilTest.java |     35 -
 .../src/test/resources/clusterinfo.json         |     15 -
 .../src/test/resources/mrcompleteapp.json       |     54 -
 .../src/test/resources/mrrunningapp.json        |     64 -
 .../src/test/resources/sparkcompleteapp.json    |     64 -
 .../src/test/resources/sparkrunningapp.json     |     64 -
 eagle-jpm/eagle-jpm-web/pom.xml                 |     58 -
 .../app/jpm/JPMWebApplicationProvider.java      |     23 -
 ....eagle.app.jpm.JPMWebApplicationProvider.xml |     54 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../webapp/app/apps/jpm/ctrl/compareCtrl.js     |    380 -
 .../main/webapp/app/apps/jpm/ctrl/detailCtrl.js |    258 -
 .../webapp/app/apps/jpm/ctrl/jobTaskCtrl.js     |    551 -
 .../main/webapp/app/apps/jpm/ctrl/listCtrl.js   |    240 -
 .../webapp/app/apps/jpm/ctrl/overviewCtrl.js    |    141 -
 .../main/webapp/app/apps/jpm/ctrl/queueCtrl.js  |    230 -
 .../webapp/app/apps/jpm/ctrl/statisticCtrl.js   |    386 -
 .../src/main/webapp/app/apps/jpm/index.html     |      6 -
 .../src/main/webapp/app/apps/jpm/index.js       |    514 -
 .../app/apps/jpm/partials/job/compare.html      |    274 -
 .../app/apps/jpm/partials/job/detail.html       |    350 -
 .../webapp/app/apps/jpm/partials/job/list.html  |    133 -
 .../app/apps/jpm/partials/job/overview.html     |    347 -
 .../app/apps/jpm/partials/job/statistic.html    |    120 -
 .../webapp/app/apps/jpm/partials/job/task.html  |    149 -
 .../app/apps/jpm/partials/queue/overview.html   |     57 -
 .../main/webapp/app/apps/jpm/style/index.css    |     84 -
 .../webapp/app/apps/jpm/widget/jobStatistic.js  |    108 -
 .../eagle-jpm-web/src/main/webapp/package.json  |      0
 .../eagle/app/jpm/JPMWebApplicationTest.java    |    107 -
 eagle-jpm/pom.xml                               |     83 -
 eagle-metric/eagle-hadoop-metric/pom.xml        |     34 -
 .../eagle/metric/HadoopMetricMonitorApp.java    |     65 -
 .../metric/HadoopMetricMonitorAppProdiver.java  |     29 -
 ...le.metric.HadoopMetricMonitorAppProdiver.xml |    230 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/resources/datasources.json         |     19 -
 .../src/main/resources/policies.json            |    169 -
 .../src/main/resources/publishments.json        |     33 -
 .../src/main/resources/streamdefinitions.json   |     47 -
 .../metric/HadoopMetricMonitorAppDebug.java     |     26 -
 .../HadoopMetricMonitorAppProviderTest.java     |     89 -
 .../eagle/metric/SendSampleDataToKafka.java     |     56 -
 .../src/test/resources/application.conf         |     45 -
 .../resources/hadoop_jmx_metric_sample.json     |      8 -
 .../test/resources/integrate_test_policy.json   |     37 -
 eagle-metric/eagle-hbase-web/pom.xml            |     57 -
 .../HBaseMetricWebApplicationProvider.java      |     23 -
 ...metric.HBaseMetricWebApplicationProvider.xml |     46 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/webapp/app/apps/hbase/config.json  |     68 -
 .../apps/hbase/ctrls/backupMasterListCtrl.js    |     35 -
 .../webapp/app/apps/hbase/ctrls/overview.js     |    328 -
 .../app/apps/hbase/ctrls/regionDetailCtrl.js    |    317 -
 .../app/apps/hbase/ctrls/regionListCtrl.js      |     38 -
 .../src/main/webapp/app/apps/hbase/index.html   |      6 -
 .../src/main/webapp/app/apps/hbase/index.js     |    342 -
 .../apps/hbase/partials/backupMasterList.html   |     52 -
 .../app/apps/hbase/partials/overview.html       |    120 -
 .../hbase/partials/region/regionDetail.html     |    117 -
 .../apps/hbase/partials/region/regionList.html  |     53 -
 .../main/webapp/app/apps/hbase/style/index.css  |     88 -
 .../app/apps/hbase/widgets/availabilityChart.js |    164 -
 .../src/main/webapp/package.json                |      0
 .../HBaseMetricWebApplicationProviderTest.java  |    100 -
 eagle-metric/eagle-hdfs-web/pom.xml             |     57 -
 .../HdfsMetricWebApplicationProvider.java       |     23 -
 ....metric.HdfsMetricWebApplicationProvider.xml |     46 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/webapp/app/apps/hdfs/config.json   |     34 -
 .../app/apps/hdfs/ctrl/datanodeDetailCtrl.js    |    232 -
 .../app/apps/hdfs/ctrl/datanodeListCtrl.js      |     40 -
 .../app/apps/hdfs/ctrl/namenodeListCtrl.js      |     37 -
 .../main/webapp/app/apps/hdfs/ctrl/overview.js  |    315 -
 .../src/main/webapp/app/apps/hdfs/index.html    |      6 -
 .../src/main/webapp/app/apps/hdfs/index.js      |    333 -
 .../app/apps/hdfs/partials/datanodeDetail.html  |    117 -
 .../app/apps/hdfs/partials/datanodeList.html    |     53 -
 .../app/apps/hdfs/partials/namenodeList.html    |     52 -
 .../webapp/app/apps/hdfs/partials/overview.html |    132 -
 .../main/webapp/app/apps/hdfs/style/index.css   |     88 -
 .../app/apps/hdfs/widget/availabilityChart.js   |    154 -
 .../eagle-hdfs-web/src/main/webapp/package.json |      0
 .../HdfsMetricWebApplicationProviderTest.java   |    101 -
 eagle-metric/eagle-system-web/pom.xml           |     61 -
 .../SystemMetricWebApplicationProvider.java     |     22 -
 ...etric.SystemMetricWebApplicationProvider.xml |     46 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/webapp/app/apps/system/config.json |     80 -
 .../webapp/app/apps/system/ctrl/overview.js     |    321 -
 .../app/apps/system/ctrl/serverDetailCtrl.js    |    229 -
 .../app/apps/system/ctrl/serverListCtrl.js      |     39 -
 .../src/main/webapp/app/apps/system/index.html  |      6 -
 .../src/main/webapp/app/apps/system/index.js    |    293 -
 .../app/apps/system/partials/overview.html      |    126 -
 .../app/apps/system/partials/serverDetail.html  |    111 -
 .../app/apps/system/partials/serverList.html    |     60 -
 .../main/webapp/app/apps/system/style/index.css |     88 -
 .../app/apps/system/widget/availabilityChart.js |    138 -
 .../src/main/webapp/package.json                |      0
 eagle-metric/pom.xml                            |     75 -
 eagle-security/eagle-metric-collection/pom.xml  |     90 -
 .../kafka/EagleMetricCollectorApplication.java  |     71 -
 .../eagle/metric/kafka/KafkaConsumerOffset.java |     27 -
 .../kafka/KafkaConsumerOffsetFetcher.java       |     70 -
 .../metric/kafka/KafkaLatestOffsetFetcher.java  |     96 -
 .../kafka/KafkaMessageDistributionBolt.java     |    110 -
 .../metric/kafka/KafkaOffsetCheckerConfig.java  |     44 -
 .../kafka/KafkaOffsetSourceSpoutProvider.java   |     51 -
 .../eagle/metric/kafka/KafkaOffsetSpout.java    |    135 -
 .../metric/kafka/KafkaSourcedSpoutProvider.java |     93 -
 .../metric/kafka/KafkaSourcedSpoutScheme.java   |     68 -
 .../eagle/metric/kafka/NameConstants.java       |     25 -
 .../src/main/resources/application.conf         |     55 -
 .../src/main/resources/log4j.properties         |     39 -
 .../kafka/TestDataDistributionDaoImpl.java      |     46 -
 .../eagle/metric/kafka/TestGreedyPartition.java |     49 -
 .../eagle/metric/kafka/TestKafkaOffset.java     |     71 -
 eagle-security/eagle-security-common/pom.xml    |     64 -
 .../security/enrich/AbstractDataEnrichBolt.java |     67 -
 .../security/enrich/AbstractDataEnrichLCM.java  |     51 -
 .../eagle/security/enrich/DataEnrichJob.java    |     55 -
 .../eagle/security/enrich/DataEnrichLCM.java    |     45 -
 .../security/enrich/ExternalDataCache.java      |     41 -
 .../security/enrich/ExternalDataJoiner.java     |    101 -
 .../eagle/security/entity/FileStatusEntity.java |    176 -
 .../security/entity/HbaseResourceEntity.java    |    105 -
 .../entity/HdfsUserCommandPatternEntity.java    |     82 -
 .../security/entity/HiveResourceEntity.java     |    104 -
 .../security/entity/OozieResourceEntity.java    |     82 -
 .../OozieResourceSensitivityAPIEntity.java      |     46 -
 .../entity/SecurityEntityRepository.java        |     28 -
 .../eagle/security/hdfs/HDFSAuditLogObject.java |     38 -
 .../eagle/security/hdfs/HDFSAuditLogParser.java |    104 -
 .../security/hdfs/MAPRFSAuditLogObject.java     |     31 -
 .../security/hdfs/MAPRFSAuditLogParser.java     |     71 -
 .../apache/eagle/security/partition/Bucket.java |     30 -
 .../security/partition/BucketComparator.java    |     36 -
 .../partition/DataDistributionDaoImpl.java      |    103 -
 .../partition/GreedyPartitionAlgorithm.java     |     65 -
 .../resolver/AbstractCommandResolver.java       |     72 -
 .../AbstractSensitivityTypeResolver.java        |     82 -
 .../resolver/MetadataAccessConfigRepo.java      |     45 -
 .../service/HBaseSensitivityEntity.java         |     50 -
 .../security/service/HdfsSensitivityEntity.java |     50 -
 .../security/service/HiveSensitivityEntity.java |     54 -
 .../eagle/security/service/IPZoneEntity.java    |     41 -
 .../ISecurityDataEnrichServiceClient.java       |     40 -
 .../security/service/ISecurityMetadataDAO.java  |     36 -
 .../security/service/InMemMetadataDaoImpl.java  |    119 -
 .../service/JDBCSecurityMetadataDAO.java        |    277 -
 .../security/service/MetadataDaoFactory.java    |     42 -
 .../service/OozieSensitivityEntity.java         |     50 -
 .../apache/eagle/security/service/OpResult.java |     28 -
 .../SecurityDataEnrichServiceClientImpl.java    |    177 -
 .../SecurityExternalMetadataResource.java       |    112 -
 .../eagle/security/topo/TopologySubmitter.java  |     85 -
 .../traffic/HadoopLogAccumulatorBolt.java       |    136 -
 .../traffic/HadoopLogTrafficPersist.java        |     77 -
 .../security/traffic/SimpleWindowCounter.java   |     83 -
 .../util/BadMetadataAccessConfigException.java  |     30 -
 .../eagle/security/util/HadoopSecurityUtil.java |     46 -
 .../security/util/JVMSingleQuartzScheduler.java |     51 -
 .../eagle/security/util/LogParseUtil.java       |     42 -
 .../audit/JDBCSecurityMetadataDAOTest.java      |     69 -
 .../crawler/audit/TestHDFSAuditLogParser.java   |     40 -
 .../crawler/audit/TestMAPRFSAuditLogParser.java |     63 -
 .../audit/TestMetaDataAccessConfigRepo.java     |     73 -
 .../src/test/resources/application.conf         |     77 -
 .../eagle-security-hbase-auditlog/README.md     |     85 -
 .../eagle-security-hbase-auditlog/pom.xml       |     44 -
 .../hbase/HBaseAuditLogAppProvider.java         |     34 -
 .../hbase/HBaseAuditLogApplication.java         |     73 -
 .../security/hbase/HBaseAuditLogParserBolt.java |     69 -
 .../hbase/HBaseSensitivityDataEnrichLCM.java    |     43 -
 .../security/hbase/HbaseAuditLogObject.java     |     28 -
 .../security/hbase/HbaseAuditLogParser.java     |    148 -
 .../HbaseResourceSensitivityDataJoinBolt.java   |     80 -
 ....security.hbase.HBaseAuditLogAppProvider.xml |    211 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/resources/application.conf         |     45 -
 .../src/main/resources/log4j.properties         |     21 -
 .../src/main/resources/scripts                  |     22 -
 .../security/hbase/TestHbaseAuditLogParser.java |     44 -
 .../src/test/resources/application.conf         |     71 -
 .../src/test/resources/log4j.properties         |     35 -
 .../src/test/resources/securityAuditLog         |     25 -
 eagle-security/eagle-security-hbase-web/pom.xml |     40 -
 .../src/main/ddl.script                         |     21 -
 .../hbase/HbaseMetadataBrowseWebResource.java   |    190 -
 .../hbase/HbaseMetadataBrowseWebResponse.java   |     45 -
 .../hbase/dao/HbaseMetadataDAOImpl.java         |     95 -
 .../hbase/resolver/HbaseActionResolver.java     |     41 -
 .../hbase/resolver/HbaseMetadataResolver.java   |    130 -
 .../hbase/resolver/HbaseRequestResolver.java    |     67 -
 .../resolver/HbaseSensitivityTypeResolver.java  |     58 -
 .../hbase/TestHbaseMetadataResolver.java        |     41 -
 .../eagle-security-hdfs-auditlog/README.md      |    191 -
 .../eagle-security-hdfs-auditlog/pom.xml        |     68 -
 .../AbstractHdfsAuditLogApplication.java        |    135 -
 .../eagle/security/auditlog/AttributeType.java  |     30 -
 .../auditlog/HdfsAuditLogAppProvider.java       |     32 -
 .../auditlog/HdfsAuditLogApplication.java       |    109 -
 .../auditlog/HdfsAuditLogParserBolt.java        |     91 -
 .../auditlog/HdfsSensitivityDataEnrichBolt.java |     82 -
 .../auditlog/HdfsSensitivityDataEnrichLCM.java  |     43 -
 .../HdfsUserCommandPatternByDBImpl.java         |     61 -
 .../HdfsUserCommandPatternByFileImpl.java       |     49 -
 .../auditlog/HdfsUserCommandPatternDAO.java     |     31 -
 .../auditlog/HdfsUserCommandReassembler.java    |    191 -
 .../security/auditlog/IPZoneDataEnrichBolt.java |     64 -
 .../security/auditlog/IPZoneDataEnrichLCM.java  |     43 -
 .../security/auditlog/TopWindowResult.java      |    126 -
 .../security/auditlog/TrafficParserBolt.java    |    157 -
 .../auditlog/kafka/MessageJsonScheme.java       |     68 -
 .../auditlog/kafka/UserPartitioner.java         |     33 -
 .../security/auditlog/util/SimplifyPath.java    |     53 -
 ...ecurity.auditlog.HdfsAuditLogAppProvider.xml |    312 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     37 -
 .../src/main/resources/application.conf         |     49 -
 .../main/resources/hdfsUserCommandPattern.json  |     54 -
 .../src/main/resources/log4j.properties         |     35 -
 .../src/main/resources/scripts.txt              |     22 -
 .../src/test/java/META-INF/MANIFEST.MF          |     19 -
 .../auditlog/TestHdfsAuditLogApplication.java   |     83 -
 .../TestHdfsUserCommandPatternByDB.java         |     46 -
 .../TestHdfsUserCommandPatternByFile.java       |     42 -
 .../security/auditlog/TestSiddhiPattern.java    |    117 -
 .../auditlog/TestUserCommandReassembler.java    |    200 -
 .../auditlogtraining/util/TestSimplifyPath.java |     31 -
 .../security/dataproc/TestIPZonePollingJob.java |     45 -
 .../security/dataproc/TestOuterDataJoiner.java  |     59 -
 .../security/traffic/TopWindowResultTest.java   |     61 -
 .../src/test/resources/securityAuditLog         |     17 -
 .../eagle-security-hdfs-authlog/README.md       |     83 -
 .../eagle-security-hdfs-authlog/pom.xml         |     40 -
 .../securitylog/HDFSSecurityLogObject.java      |     27 -
 .../securitylog/HDFSSecurityLogParser.java      |     82 -
 .../securitylog/HdfsAuthLogMonitoringMain.java  |     63 -
 .../securitylog/SecurityLogParserBolt.java      |     78 -
 .../src/main/resources/application.conf         |     36 -
 .../src/main/resources/log4j.properties         |     23 -
 .../src/main/resources/security_log.sample      |     30 -
 .../security/TestHDFSSecuritylogParser.java     |     69 -
 eagle-security/eagle-security-hdfs-web/pom.xml  |     64 -
 .../service/security/hdfs/HDFSFileSystem.java   |     81 -
 .../security/hdfs/HDFSResourceConstants.java    |     25 -
 .../hdfs/HDFSResourceSensitivityDataJoiner.java |    102 -
 .../hdfs/HDFSResourceSensitivityService.java    |     92 -
 .../hdfs/resolver/HDFSCommandResolver.java      |     80 -
 .../hdfs/resolver/HDFSResourceResolver.java     |    149 -
 .../resolver/HDFSSensitivityTypeResolver.java   |     96 -
 .../rest/HDFSResourceWebRequestValidator.java   |     45 -
 .../hdfs/rest/HDFSResourceWebResource.java      |    102 -
 .../hdfs/rest/HDFSResourceWebResponse.java      |     53 -
 .../create-hdfs-resource-access-config.sh       |     20 -
 .../src/main/resources/sample_site.conf         |     23 -
 .../hdfs/test/HDFSChildSensitivityTypeTest.java |     49 -
 .../hdfs/test/HDFSResourceAccessConfigTest.java |     45 -
 eagle-security/eagle-security-hive-web/pom.xml  |     70 -
 .../BadHiveMetadataAccessConfigException.java   |     27 -
 .../hive/dao/HiveMetadataAccessConfig.java      |    102 -
 .../hive/dao/HiveMetadataAccessType.java        |     22 -
 .../dao/HiveMetadataByHiveServer2DAOImpl.java   |    127 -
 .../dao/HiveMetadataByMetastoreDBDAOImpl.java   |    151 -
 .../security/hive/dao/HiveMetadataDAO.java      |     25 -
 .../hive/dao/HiveMetadataDAOFactory.java        |     30 -
 .../hive/dao/HiveSensitivityMetadataDAO.java    |     29 -
 .../hive/res/HiveMetadataBrowseWebResource.java |    184 -
 .../hive/res/HiveMetadataBrowseWebResponse.java |     46 -
 .../hive/resolver/HiveCommandResolver.java      |     77 -
 .../hive/resolver/HiveMetadataResolver.java     |    133 -
 .../resolver/HiveSensitivityTypeResolver.java   |     92 -
 .../security/hive/TestHiveMetadataDAO.java      |     55 -
 eagle-security/eagle-security-hive/pom.xml      |    104 -
 .../run_hiveauditlog_topology.sh                |     17 -
 .../eagle-dam-hiveQueryLog-assembly.xml         |     62 -
 .../hive/HiveQueryMonitoringAppProvider.java    |     31 -
 .../hive/HiveQueryMonitoringApplication.java    |     82 -
 .../hive/config/RunningJobCrawlConfig.java      |     53 -
 .../hive/jobrunning/HiveJobFetchSpout.java      |    288 -
 ...HiveJobRunningSourcedStormSpoutProvider.java |     81 -
 .../hive/jobrunning/HiveQueryParserBolt.java    |    156 -
 .../security/hive/jobrunning/JobFilterBolt.java |     81 -
 .../jobrunning/JobRunningContentFilter.java     |     27 -
 .../jobrunning/JobRunningContentFilterImpl.java |     36 -
 .../security/hive/ql/HiveQLParserContent.java   |     55 -
 .../apache/eagle/security/hive/ql/Parser.java   |    365 -
 .../HiveSensitivityDataEnrichBolt.java          |     82 -
 .../HiveSensitivityDataEnrichLCM.java           |     43 -
 ....auditlog.HiveQueryMonitoringAppProvider.xml |    194 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../alert-metadata-create-jobhistory.sh         |     24 -
 .../main/resources/application-hive-ranger.conf |     52 -
 .../src/main/resources/application.conf         |     49 -
 .../create-hiveResourceSensitivity-metadata.sh  |     18 -
 .../src/main/resources/hive.storm.yaml          |     16 -
 .../src/main/resources/log4j.properties         |     37 -
 .../main/resources/sample-data-create.script    |     53 -
 .../src/main/resources/sample-hive-policy.sh    |     18 -
 .../src/test/java/META-INF/MANIFEST.MF          |     19 -
 .../hive/jobrunning/TestHiveJobFetchSpout.java  |     93 -
 .../eagle/security/hive/ql/TestParser.java      |    268 -
 .../src/test/resources/onelinehiveauditlog.txt  |      1 -
 .../resources/ranger-policy-update-request.txt  |      1 -
 .../eagle-security-maprfs-auditlog/pom.xml      |     68 -
 .../auditlog/MapRFSAuditLogAppProvider.java     |     29 -
 .../auditlog/MapRFSAuditLogApplication.java     |     44 -
 .../MapRFSAuditLogKafkaDeserializer.java        |     69 -
 .../auditlog/MapRFSAuditLogParserBolt.java      |     76 -
 ...urity.auditlog.MapRFSAuditLogAppProvider.xml |    250 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     37 -
 .../src/main/resources/application.conf         |     46 -
 .../src/main/resources/log4j.properties         |     21 -
 .../src/main/resources/maprFSAuditLog-init.sh   |    213 -
 .../main/resources/security-auditlog-storm.yaml |     18 -
 .../auditlog/MapRFSAuditLogAppProviderTest.java |     33 -
 .../eagle-security-maprfs-web/pom.xml           |     77 -
 .../security/hdfs/MAPRFSResourceConstants.java  |     33 -
 .../hdfs/resolver/MAPRFSCommandResolver.java    |     78 -
 .../hdfs/resolver/MAPRFSResourceResolver.java   |    162 -
 .../hdfs/resolver/MAPRFSVolumeResolver.java     |    122 -
 .../hdfs/resolver/MAPRStatusCodeResolver.java   |    104 -
 .../service/security/hdfs/rest/HttpRequest.java |     75 -
 .../hdfs/rest/MAPRFSResourceWebResource.java    |    100 -
 .../security/hdfs/rest/MapRNameResolver.java    |    196 -
 .../security/hdfs/rest/HttpRequestTest.java     |     30 -
 .../hdfs/rest/MapRNameResolverTest.java         |     30 -
 .../eagle-security-oozie-auditlog/pom.xml       |     44 -
 .../oozie/parse/OozieAuditLogAppProvider.java   |     31 -
 .../oozie/parse/OozieAuditLogApplication.java   |     76 -
 .../parse/OozieAuditLogKafkaDeserializer.java   |     70 -
 .../oozie/parse/OozieAuditLogObject.java        |     35 -
 .../oozie/parse/OozieAuditLogParser.java        |    111 -
 .../oozie/parse/OozieAuditLogParserBolt.java    |     88 -
 .../OozieResourceSensitivityDataJoinBolt.java   |     82 -
 .../OozieSensitivityDataEnrichLCM.java          |     45 -
 ...ity.oozie.parse.OozieAuditLogAppProvider.xml |    242 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     16 -
 .../src/main/resources/application.conf         |     66 -
 .../src/main/resources/oozieAuditlogConf.conf   |     56 -
 .../oozie/parse/TestOozieAuditLogParser.java    |     56 -
 eagle-security/eagle-security-oozie-web/pom.xml |     85 -
 .../OozieResourceSensitivityDataJoiner.java     |     47 -
 .../BadOozieMetadataAccessConfigException.java  |     27 -
 .../oozie/dao/OozieMetadataAccessConfig.java    |     87 -
 .../oozie/dao/OozieMetadataAccessConfigDAO.java |     23 -
 .../dao/OozieMetadataAccessConfigDAOImpl.java   |     30 -
 .../security/oozie/dao/OozieMetadataDAO.java    |     25 -
 .../oozie/dao/OozieMetadataDAOImpl.java         |     55 -
 .../oozie/dao/OozieSensitivityMetadataDAO.java  |     30 -
 .../dao/OozieSensitivityMetadataDAOImpl.java    |     82 -
 .../res/OozieMetadataBrowseWebResource.java     |     58 -
 .../res/OozieMetadataBrowseWebResponse.java     |     44 -
 .../TestOozieResourceSensitivityDataJoiner.java |     86 -
 .../dao/TestOozieMetadataAccessConfig.java      |     43 -
 .../TestOozieSensitivityMetadataDAOImpl.java    |    120 -
 .../src/test/resources/coordinatorJob.json      |     94 -
 eagle-security/pom.xml                          |     49 -
 eagle-server/.gitignore                         |      7 -
 eagle-server/pom.xml                            |    400 -
 .../eagle/server/RESTExceptionMapper.java       |     37 -
 .../apache/eagle/server/ServerApplication.java  |    167 -
 .../org/apache/eagle/server/ServerConfig.java   |     85 -
 .../org/apache/eagle/server/ServerMain.java     |     64 -
 .../eagle/server/module/GuiceBundleLoader.java  |     84 -
 .../eagle/server/module/ServerModule.java       |     38 -
 .../server/resource/AuthenticationResource.java |     65 -
 .../eagle/server/resource/ServerResource.java   |     48 -
 .../eagle/server/security/BasicAuthBuilder.java |     99 -
 .../server/security/BasicAuthRequestFilter.java |    200 -
 .../BasicAuthResourceFilterFactory.java         |     53 -
 .../authenticator/LdapBasicAuthenticator.java   |    106 -
 .../authenticator/SimpleBasicAuthenticator.java |     59 -
 .../security/config/AuthenticationConfig.java   |     95 -
 .../server/security/config/LdapConfig.java      |     96 -
 .../server/security/config/SimpleConfig.java    |     34 -
 .../server/security/config/UserAccount.java     |     55 -
 .../security/encrypt/EncryptorFactory.java      |     23 -
 .../security/encrypt/PasswordEncryptor.java     |     23 -
 .../security/encrypt/PasswordEncryptorImpl.java |     37 -
 .../eagle/server/task/ManagedService.java       |     43 -
 .../apache/eagle/server/tool/EncryptTool.java   |     42 -
 .../java/org/apache/eagle/server/tool/Tool.java |     21 -
 .../src/main/resources/application.conf         |    164 -
 .../src/main/resources/configuration.yml        |     96 -
 .../src/main/resources/log4j.properties         |     19 -
 eagle-server/src/main/webapp/WEB-INF/web.xml    |     93 -
 eagle-server/src/main/webapp/app/.editorconfig  |     27 -
 eagle-server/src/main/webapp/app/Gruntfile.js   |    196 -
 eagle-server/src/main/webapp/app/README.md      |      4 -
 eagle-server/src/main/webapp/app/build/index.js |    155 -
 eagle-server/src/main/webapp/app/dev/index.html |    357 -
 .../webapp/app/dev/partials/alert/detail.html   |     73 -
 .../webapp/app/dev/partials/alert/list.html     |     70 -
 .../app/dev/partials/alert/policyDetail.html    |    225 -
 .../app/dev/partials/alert/policyEdit.html      |    238 -
 .../partials/alert/policyEdit/advancedMode.html |    357 -
 .../app/dev/partials/alert/policyEdit/main.html |     19 -
 .../app/dev/partials/alert/policyList.html      |     80 -
 .../app/dev/partials/alert/streamList.html      |     58 -
 .../src/main/webapp/app/dev/partials/home.html  |     42 -
 .../partials/integration/applicationList.html   |     80 -
 .../app/dev/partials/integration/main.html      |     28 -
 .../app/dev/partials/integration/site.html      |    335 -
 .../app/dev/partials/integration/siteList.html  |     60 -
 .../src/main/webapp/app/dev/partials/login.html |     45 -
 .../webapp/app/dev/partials/metric/preview.html |     68 -
 .../src/main/webapp/app/dev/partials/setup.html |     46 -
 .../main/webapp/app/dev/partials/site/home.html |     36 -
 .../webapp/app/dev/public/css/animation.css     |     47 -
 .../src/main/webapp/app/dev/public/css/main.css |    506 -
 .../webapp/app/dev/public/css/sortTable.css     |     61 -
 .../webapp/app/dev/public/images/favicon.png    |    Bin 4209 -> 0 bytes
 .../app/dev/public/images/favicon_white.png     |    Bin 1621 -> 0 bytes
 .../src/main/webapp/app/dev/public/js/app.js    |    425 -
 .../src/main/webapp/app/dev/public/js/common.js |    412 -
 .../app/dev/public/js/components/chart.js       |    220 -
 .../app/dev/public/js/components/editor.js      |     79 -
 .../webapp/app/dev/public/js/components/main.js |     24 -
 .../app/dev/public/js/components/naBlock.js     |     41 -
 .../app/dev/public/js/components/sortTable.js   |    239 -
 .../dev/public/js/components/staticInclude.js   |     33 -
 .../app/dev/public/js/components/widget.js      |     58 -
 .../webapp/app/dev/public/js/ctrls/alertCtrl.js |    291 -
 .../app/dev/public/js/ctrls/alertEditCtrl.js    |    429 -
 .../webapp/app/dev/public/js/ctrls/authCtrl.js  |     49 -
 .../app/dev/public/js/ctrls/integrationCtrl.js  |    446 -
 .../main/webapp/app/dev/public/js/ctrls/main.js |     27 -
 .../webapp/app/dev/public/js/ctrls/mainCtrl.js  |     69 -
 .../app/dev/public/js/ctrls/metricCtrl.js       |     77 -
 .../webapp/app/dev/public/js/ctrls/siteCtrl.js  |     33 -
 .../src/main/webapp/app/dev/public/js/index.js  |    354 -
 .../app/dev/public/js/services/alertSrv.js      |     65 -
 .../dev/public/js/services/applicationSrv.js    |     81 -
 .../app/dev/public/js/services/authSrv.js       |    120 -
 .../public/js/services/compatibleEntitySrv.js   |    225 -
 .../app/dev/public/js/services/entitySrv.js     |    159 -
 .../webapp/app/dev/public/js/services/main.js   |     23 -
 .../dev/public/js/services/notificationSrv.js   |    144 -
 .../app/dev/public/js/services/pageSrv.js       |    186 -
 .../app/dev/public/js/services/policySrv.js     |     97 -
 .../app/dev/public/js/services/serverSrv.js     |     40 -
 .../app/dev/public/js/services/siteSrv.js       |    137 -
 .../app/dev/public/js/services/timeSrv.js       |    327 -
 .../webapp/app/dev/public/js/services/uiSrv.js  |    349 -
 .../app/dev/public/js/services/widgetSrv.js     |     79 -
 .../app/dev/public/js/services/wrapStateSrv.js  |    122 -
 .../app/dev/public/js/worker/sortTableFunc.js   |     93 -
 .../app/dev/public/js/worker/sortTableWorker.js |     32 -
 eagle-server/src/main/webapp/app/index.html     |     28 -
 eagle-server/src/main/webapp/app/package.json   |     48 -
 .../eagle/server/EmbeddedMailService.java       |    141 -
 .../eagle/server/GuiceBundleLoaderTest.java     |     28 -
 .../org/apache/eagle/server/ServerDebug.java    |     56 -
 .../LdapBasicAuthenticatorTest.java             |    168 -
 .../SimpleBasicAuthenticatorTest.java           |     81 -
 .../resource/BasicAuthenticationTestCase.java   |    176 -
 .../TestBasicAuthenticationResource.java        |    107 -
 .../src/test/resources/configuration.yml        |     87 -
 eagle-server/ui-build.sh                        |     48 -
 eagle-topology-assembly/pom.xml                 |    164 -
 .../src/assembly/eagle-topology-assembly.xml    |     65 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     36 -
 .../services/org.apache.hadoop.fs.FileSystem    |     20 -
 .../eagle-topology-app/README.md                |    166 -
 eagle-topology-check/eagle-topology-app/pom.xml |    100 -
 .../assembly/eagle-topology-check-assembly.xml  |     66 -
 .../apache/eagle/topology/TopologyCheckApp.java |     93 -
 .../eagle/topology/TopologyCheckAppConfig.java  |    172 -
 .../eagle/topology/TopologyCheckAppMain.java    |     26 -
 .../topology/TopologyCheckAppProvider.java      |     37 -
 .../TopologyCheckApplicationHealthCheck.java    |    108 -
 .../eagle/topology/TopologyCheckMessageId.java  |     56 -
 .../topology/extractor/TopologyCrawler.java     |     29 -
 .../extractor/TopologyEntityParser.java         |     43 -
 .../extractor/TopologyEntityParserResult.java   |     69 -
 .../extractor/TopologyExtractorFactory.java     |     76 -
 .../extractor/hbase/HbaseTopologyCrawler.java   |     61 -
 .../hbase/HbaseTopologyEntityParser.java        |    176 -
 .../extractor/hdfs/HdfsTopologyCrawler.java     |     59 -
 .../hdfs/HdfsTopologyEntityParser.java          |    291 -
 .../extractor/mr/MRTopologyCrawler.java         |     56 -
 .../extractor/mr/MRTopologyEntityParser.java    |    223 -
 .../topology/extractor/mr/YarnNodeInfo.java     |    120 -
 .../extractor/mr/YarnNodeInfoWrapper.java       |     38 -
 .../topology/extractor/mr/YarnNodeInfos.java    |     41 -
 .../system/SystemCheckPersistBolt.java          |    139 -
 .../topology/resolver/TopologyRackResolver.java |     32 -
 .../ClusterNodeAPITopologyRackResolver.java     |     75 -
 .../impl/DefaultTopologyRackResolver.java       |     45 -
 .../impl/IPMaskTopologyRackResolver.java        |     58 -
 .../eagle/topology/resolver/model/Node.java     |     36 -
 .../eagle/topology/resolver/model/NodeInfo.java |     57 -
 .../topology/storm/HealthCheckParseBolt.java    |     73 -
 .../topology/storm/TopologyCheckAppSpout.java   |     83 -
 .../topology/storm/TopologyDataExtractor.java   |    106 -
 .../topology/storm/TopologyDataPersistBolt.java |    199 -
 .../topology/utils/EntityBuilderHelper.java     |     75 -
 .../apache/eagle/topology/utils/JMXBean.java    |     36 -
 .../eagle/topology/utils/JMXQueryHelper.java    |     79 -
 ....eagle.topology.TopologyCheckAppProvider.xml |    228 -
 ...org.apache.eagle.app.spi.ApplicationProvider |     19 -
 .../src/main/resources/application.conf         |     69 -
 .../src/main/resources/log4j.properties         |     35 -
 .../TestClusterNodeAPITopologyRackResolver.java |     77 -
 .../topology/TestHbaseTopologyCrawler.java      |     40 -
 .../eagle/topology/TestHdfsTopologyCrawler.java |     40 -
 .../apache/eagle/topology/TestJsonParser.java   |     80 -
 .../eagle/topology/TestMRTopologyCrawler.java   |     40 -
 .../TestNetMaskTopologyRackResolver.java        |     67 -
 .../src/test/resources/application.conf         |     65 -
 .../src/test/resources/log4j.properties         |     35 -
 .../src/test/resources/nodeinfo.json            |     17 -
 .../eagle-topology-entity/pom.xml               |     36 -
 .../eagle/topology/TopologyConstants.java       |    102 -
 .../entity/HBaseServiceTopologyAPIEntity.java   |     99 -
 .../entity/HdfsServiceTopologyAPIEntity.java    |    124 -
 .../entity/HealthCheckParseAPIEntity.java       |     67 -
 .../entity/JournalNodeServiceAPIEntity.java     |     66 -
 .../entity/MRServiceTopologyAPIEntity.java      |     99 -
 .../entity/SystemServiceTopologyAPIEntity.java  |    122 -
 .../topology/entity/TopologyBaseAPIEntity.java  |     25 -
 .../entity/TopologyEntityRepository.java        |     32 -
 eagle-topology-check/pom.xml                    |     64 -
 pom.xml                                         |   1379 -
 2639 files changed, 427102 deletions(-)
----------------------------------------------------------------------



Mime
View raw message