Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 45E80200C3C for ; Mon, 3 Apr 2017 13:54:21 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 4168B160B76; Mon, 3 Apr 2017 11:54:21 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id CA322160BA8 for ; Mon, 3 Apr 2017 13:54:13 +0200 (CEST) Received: (qmail 79139 invoked by uid 500); 3 Apr 2017 11:54:13 -0000 Mailing-List: contact commits-help@eagle.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@eagle.apache.org Delivered-To: mailing list commits@eagle.apache.org Received: (qmail 77795 invoked by uid 99); 3 Apr 2017 11:54:11 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 03 Apr 2017 11:54:11 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 58A86DFF5A; Mon, 3 Apr 2017 11:54:11 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: hao@apache.org To: commits@eagle.apache.org Date: Mon, 03 Apr 2017 11:54:59 -0000 Message-Id: In-Reply-To: <04280246f21e4dcd9fbfe899c4344da2@git.apache.org> References: <04280246f21e4dcd9fbfe899c4344da2@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [51/84] [partial] eagle git commit: Clean repo for eagle site archived-at: Mon, 03 Apr 2017 11:54:21 -0000 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 Authored: Mon Apr 3 19:51:47 2017 +0800 Committer: Hao Chen 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(-) ----------------------------------------------------------------------