You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eagle.apache.org by ha...@apache.org on 2015/11/19 11:47:58 UTC
[51/55] [abbrv] [partial] incubator-eagle git commit: [EAGLE-46]
Rename package name as "org.apache.eagle"
[EAGLE-46] Rename package name as "org.apache.eagle"
Project: http://git-wip-us.apache.org/repos/asf/incubator-eagle/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-eagle/commit/afe86834
Tree: http://git-wip-us.apache.org/repos/asf/incubator-eagle/tree/afe86834
Diff: http://git-wip-us.apache.org/repos/asf/incubator-eagle/diff/afe86834
Branch: refs/heads/master
Commit: afe86834a09e734d4c4235a8c762d2011bea2daf
Parents: df39691
Author: Hao Chen <ha...@apache.org>
Authored: Thu Nov 19 16:50:07 2015 +0800
Committer: Hao Chen <ha...@apache.org>
Committed: Thu Nov 19 16:50:07 2015 +0800
----------------------------------------------------------------------
.../src/main/bin/eagle-topology-init.sh | 6 +-
eagle-assembly/src/main/bin/eagle-topology.sh | 4 +-
.../src/main/bin/eagle-userprofile-scheduler.sh | 2 +-
.../src/main/bin/eagle-userprofile-training.sh | 4 +-
.../main/bin/hbase-securitylog-schema-create.sh | 2 +-
.../sandbox-hbaseSecurityLog-application.conf | 4 +-
.../conf/sandbox-hdfsAuditLog-application.conf | 4 +-
.../conf/sandbox-hiveQueryLog-application.conf | 4 +-
.../main/conf/sandbox-userprofile-topology.conf | 4 +-
.../src/main/examples/eagle-sandbox-starter.sh | 6 +-
.../java/eagle/alert/common/AlertConstants.java | 64 -
.../eagle/alert/common/AlertEmailSender.java | 158 -
.../eagle/alert/dao/AlertDataSourceDAO.java | 25 -
.../eagle/alert/dao/AlertDataSourceDAOImpl.java | 83 -
.../eagle/alert/dao/AlertDefinitionDAO.java | 39 -
.../eagle/alert/dao/AlertDefinitionDAOImpl.java | 104 -
.../java/eagle/alert/dao/AlertExecutorDAO.java | 26 -
.../eagle/alert/dao/AlertExecutorDAOImpl.java | 108 -
.../java/eagle/alert/dao/AlertStreamDAO.java | 25 -
.../eagle/alert/dao/AlertStreamDAOImpl.java | 82 -
.../eagle/alert/dao/AlertStreamSchemaDAO.java | 25 -
.../alert/dao/AlertStreamSchemaDAOImpl.java | 83 -
.../eagle/alert/email/AlertEmailComponent.java | 32 -
.../eagle/alert/email/AlertEmailContext.java | 69 -
.../java/eagle/alert/entity/AlertAPIEntity.java | 84 -
.../alert/entity/AlertContextSerDeser.java | 98 -
.../alert/entity/AlertDataSourceEntity.java | 67 -
.../alert/entity/AlertDefinitionAPIEntity.java | 181 -
.../alert/entity/AlertEntityRepository.java | 32 -
.../eagle/alert/entity/AlertExecutorEntity.java | 45 -
.../eagle/alert/entity/AlertStreamEntity.java | 51 -
.../alert/entity/AlertStreamSchemaEntity.java | 111 -
.../eagle/alert/common/AlertConstants.java | 64 +
.../eagle/alert/common/AlertEmailSender.java | 158 +
.../eagle/alert/dao/AlertDataSourceDAO.java | 25 +
.../eagle/alert/dao/AlertDataSourceDAOImpl.java | 83 +
.../eagle/alert/dao/AlertDefinitionDAO.java | 39 +
.../eagle/alert/dao/AlertDefinitionDAOImpl.java | 104 +
.../eagle/alert/dao/AlertExecutorDAO.java | 26 +
.../eagle/alert/dao/AlertExecutorDAOImpl.java | 108 +
.../apache/eagle/alert/dao/AlertStreamDAO.java | 25 +
.../eagle/alert/dao/AlertStreamDAOImpl.java | 82 +
.../eagle/alert/dao/AlertStreamSchemaDAO.java | 25 +
.../alert/dao/AlertStreamSchemaDAOImpl.java | 83 +
.../eagle/alert/email/AlertEmailComponent.java | 32 +
.../eagle/alert/email/AlertEmailContext.java | 69 +
.../eagle/alert/entity/AlertAPIEntity.java | 84 +
.../alert/entity/AlertContextSerDeser.java | 98 +
.../alert/entity/AlertDataSourceEntity.java | 67 +
.../alert/entity/AlertDefinitionAPIEntity.java | 181 +
.../alert/entity/AlertEntityRepository.java | 32 +
.../eagle/alert/entity/AlertExecutorEntity.java | 45 +
.../eagle/alert/entity/AlertStreamEntity.java | 51 +
.../alert/entity/AlertStreamSchemaEntity.java | 111 +
.../alert/config/AbstractPolicyDefinition.java | 42 -
.../eagle/alert/config/DeduplicatorConfig.java | 37 -
.../alert/config/EmailNotificationConfig.java | 49 -
.../eagle/alert/config/NotificationConfig.java | 44 -
.../java/eagle/alert/config/Remediation.java | 32 -
.../dedup/AlertDeduplicationExecutorBase.java | 191 -
.../dedup/AlertEmailDeduplicationExecutor.java | 30 -
.../dedup/AlertEntityDeduplicationExecutor.java | 30 -
.../eagle/alert/dedup/DefaultDeduplicator.java | 116 -
.../eagle/alert/dedup/EntityDeduplicator.java | 36 -
.../java/eagle/alert/dedup/EntityTagsUniq.java | 81 -
.../alert/notification/AlertEmailGenerator.java | 134 -
.../AlertEmailGeneratorBuilder.java | 59 -
.../notification/AlertNotificationExecutor.java | 207 -
.../eagle/alert/notification/UrlBuilder.java | 47 -
.../alert/persist/AlertPersistExecutor.java | 56 -
.../java/eagle/alert/persist/EaglePersist.java | 71 -
.../alert/policy/DefaultPolicyPartitioner.java | 32 -
.../eagle/alert/policy/DynamicPolicyLoader.java | 246 -
.../java/eagle/alert/policy/PartitionUtils.java | 30 -
.../eagle/alert/policy/PolicyEvaluator.java | 48 -
.../policy/PolicyEvaluatorServiceProvider.java | 47 -
.../alert/policy/PolicyLifecycleMethods.java | 27 -
.../java/eagle/alert/policy/PolicyManager.java | 61 -
.../eagle/alert/policy/PolicyPartitioner.java | 26 -
.../java/eagle/alert/siddhi/AttributeType.java | 30 -
.../eagle/alert/siddhi/EagleAlertContext.java | 32 -
.../siddhi/SiddhiAlertAPIEntityRendner.java | 100 -
.../eagle/alert/siddhi/SiddhiAlertHandler.java | 26 -
.../alert/siddhi/SiddhiPolicyDefinition.java | 42 -
.../alert/siddhi/SiddhiPolicyEvaluator.java | 264 --
...iddhiPolicyEvaluatorServiceProviderImpl.java | 46 -
.../alert/siddhi/SiddhiQueryCallbackImpl.java | 85 -
.../alert/siddhi/SiddhiStreamMetadataUtils.java | 103 -
.../alert/siddhi/StreamMetadataManager.java | 128 -
.../extension/ContainsIgnoreCaseExtension.java | 87 -
.../extension/EqualsIgnoreCaseExtension.java | 91 -
.../RegexpIgnoreCaseFunctionExtension.java | 89 -
.../main/java/eagle/executor/AlertExecutor.java | 413 --
.../executor/AlertExecutorCreationUtils.java | 131 -
.../alert/config/AbstractPolicyDefinition.java | 42 +
.../eagle/alert/config/DeduplicatorConfig.java | 37 +
.../alert/config/EmailNotificationConfig.java | 49 +
.../eagle/alert/config/NotificationConfig.java | 44 +
.../apache/eagle/alert/config/Remediation.java | 32 +
.../dedup/AlertDeduplicationExecutorBase.java | 191 +
.../dedup/AlertEmailDeduplicationExecutor.java | 30 +
.../dedup/AlertEntityDeduplicationExecutor.java | 30 +
.../eagle/alert/dedup/DefaultDeduplicator.java | 116 +
.../eagle/alert/dedup/EntityDeduplicator.java | 36 +
.../eagle/alert/dedup/EntityTagsUniq.java | 81 +
.../alert/notification/AlertEmailGenerator.java | 134 +
.../AlertEmailGeneratorBuilder.java | 59 +
.../notification/AlertNotificationExecutor.java | 207 +
.../eagle/alert/notification/UrlBuilder.java | 47 +
.../alert/persist/AlertPersistExecutor.java | 56 +
.../eagle/alert/persist/EaglePersist.java | 71 +
.../alert/policy/DefaultPolicyPartitioner.java | 32 +
.../eagle/alert/policy/DynamicPolicyLoader.java | 246 +
.../eagle/alert/policy/PartitionUtils.java | 30 +
.../eagle/alert/policy/PolicyEvaluator.java | 47 +
.../policy/PolicyEvaluatorServiceProvider.java | 47 +
.../alert/policy/PolicyLifecycleMethods.java | 27 +
.../eagle/alert/policy/PolicyManager.java | 61 +
.../eagle/alert/policy/PolicyPartitioner.java | 26 +
.../eagle/alert/siddhi/AttributeType.java | 30 +
.../eagle/alert/siddhi/EagleAlertContext.java | 32 +
.../siddhi/SiddhiAlertAPIEntityRendner.java | 100 +
.../eagle/alert/siddhi/SiddhiAlertHandler.java | 26 +
.../alert/siddhi/SiddhiPolicyDefinition.java | 42 +
.../alert/siddhi/SiddhiPolicyEvaluator.java | 264 ++
...iddhiPolicyEvaluatorServiceProviderImpl.java | 45 +
.../alert/siddhi/SiddhiQueryCallbackImpl.java | 85 +
.../alert/siddhi/SiddhiStreamMetadataUtils.java | 103 +
.../alert/siddhi/StreamMetadataManager.java | 128 +
.../extension/ContainsIgnoreCaseExtension.java | 87 +
.../extension/EqualsIgnoreCaseExtension.java | 91 +
.../RegexpIgnoreCaseFunctionExtension.java | 89 +
.../apache/eagle/executor/AlertExecutor.java | 412 ++
.../executor/AlertExecutorCreationUtils.java | 133 +
....alert.policy.PolicyEvaluatorServiceProvider | 1 -
....alert.policy.PolicyEvaluatorServiceProvider | 1 +
.../src/main/resources/str.siddhiext | 6 +-
.../eagle/alert/cep/TestSiddhiEvaluator.java | 128 -
.../java/eagle/alert/config/TestAlertDedup.java | 38 -
.../alert/dao/TestAlertDefinitionDAOImpl.java | 72 -
.../dao/TestSiddhiStreamMetadataUtils.java | 60 -
.../alert/dao/TestStreamDefinitionDAOImpl.java | 66 -
.../alert/policy/TestDynamicPolicyLoader.java | 105 -
.../alert/policy/TestPolicyDistribution.java | 29 -
.../eagle/alert/siddhi/TestSiddhiEngine.java | 248 --
.../alert/siddhi/TestSiddhiSlideWindow.java | 129 -
.../eagle/alert/siddhi/TestSiddhiStream.java | 33 -
.../eagle/alert/cep/TestSiddhiEvaluator.java | 128 +
.../eagle/alert/config/TestAlertDedup.java | 38 +
.../alert/dao/TestAlertDefinitionDAOImpl.java | 72 +
.../dao/TestSiddhiStreamMetadataUtils.java | 60 +
.../alert/dao/TestStreamDefinitionDAOImpl.java | 66 +
.../alert/policy/TestDynamicPolicyLoader.java | 105 +
.../alert/policy/TestPolicyDistribution.java | 29 +
.../eagle/alert/siddhi/TestSiddhiEngine.java | 243 +
.../alert/siddhi/TestSiddhiSlideWindow.java | 129 +
.../eagle/alert/siddhi/TestSiddhiStream.java | 33 +
.../src/test/resources/str.siddhiext | 6 +-
.../src/test/resources/unittest.conf | 4 +-
.../alert/AlertPolicyValidateProvider.java | 36 -
.../service/alert/PolicyValidateResource.java | 64 -
.../SiddhiAlertPolicyValidateProvider.java | 133 -
.../alert/resolver/AttributeResolvable.java | 44 -
.../resolver/AttributeResolveException.java | 26 -
.../resolver/AttributeResolveResource.java | 81 -
.../resolver/AttributeResolveResponse.java | 40 -
.../resolver/AttributeResolverFactory.java | 50 -
.../BadAttributeResolveRequestException.java | 31 -
.../GenericAttributeResolveRequest.java | 54 -
.../resolver/impl/BooleanAttributeResolver.java | 43 -
.../resolver/impl/EntityAttributeResolver.java | 142 -
.../alert/AlertPolicyValidateProvider.java | 36 +
.../service/alert/PolicyValidateResource.java | 64 +
.../SiddhiAlertPolicyValidateProvider.java | 133 +
.../alert/resolver/AttributeResolvable.java | 44 +
.../resolver/AttributeResolveException.java | 26 +
.../resolver/AttributeResolveResource.java | 81 +
.../resolver/AttributeResolveResponse.java | 40 +
.../resolver/AttributeResolverFactory.java | 50 +
.../BadAttributeResolveRequestException.java | 31 +
.../GenericAttributeResolveRequest.java | 54 +
.../resolver/impl/BooleanAttributeResolver.java | 43 +
.../resolver/impl/EntityAttributeResolver.java | 142 +
...le.service.alert.AlertPolicyValidateProvider | 1 -
...le.service.alert.AlertPolicyValidateProvider | 1 +
...le.service.alert.AlertPolicyValidateProvider | 1 -
...le.service.alert.AlertPolicyValidateProvider | 1 +
.../eagle/job/DefaultJobPartitionerImpl.java | 26 -
.../src/main/java/eagle/job/JobFilter.java | 21 -
.../java/eagle/job/JobFilterByPartition.java | 37 -
.../src/main/java/eagle/job/JobPartitioner.java | 21 -
.../eagle/job/DefaultJobPartitionerImpl.java | 26 +
.../java/org/apache/eagle/job/JobFilter.java | 21 +
.../apache/eagle/job/JobFilterByPartition.java | 37 +
.../org/apache/eagle/job/JobPartitioner.java | 21 +
.../DefaultRunningJobInputStreamCallback.java | 58 -
.../jobrunning/callback/RunningJobCallback.java | 37 -
.../callback/RunningJobMessageId.java | 56 -
.../eagle/jobrunning/common/JobConstants.java | 53 -
.../config/RunningJobCrawlConfig.java | 61 -
.../jobrunning/counter/CounterGroupKey.java | 30 -
.../eagle/jobrunning/counter/CounterKey.java | 28 -
.../eagle/jobrunning/counter/JobCounters.java | 38 -
.../counter/parser/JobCountersParser.java | 26 -
.../counter/parser/JobCountersParserImpl.java | 44 -
.../jobrunning/crawler/ConfigWorkTask.java | 66 -
.../eagle/jobrunning/crawler/JobContext.java | 55 -
.../jobrunning/crawler/RMResourceFetcher.java | 275 --
.../jobrunning/crawler/ResourceFetcher.java | 27 -
.../jobrunning/crawler/RunningJobCrawler.java | 28 -
.../crawler/RunningJobCrawlerImpl.java | 354 --
.../eagle/jobrunning/crawler/XmlHelper.java | 55 -
.../java/eagle/jobrunning/ha/HAURLSelector.java | 31 -
.../eagle/jobrunning/ha/HAURLSelectorImpl.java | 103 -
.../jobrunning/job/conf/JobConfParser.java | 26 -
.../jobrunning/job/conf/JobConfParserImpl.java | 42 -
.../storm/JobRunningContentFilter.java | 27 -
.../storm/JobRunningContentFilterImpl.java | 36 -
.../eagle/jobrunning/storm/JobRunningSpout.java | 200 -
.../JobRunningSpoutCollectorInterceptor.java | 47 -
...JobCompleteCounterServiceURLBuilderImpl.java | 29 -
.../JobCompleteDetailServiceURLBuilderImpl.java | 31 -
...JobCompletedConfigServiceURLBuilderImpl.java | 27 -
.../url/JobCountersServiceURLBuilderImpl.java | 33 -
.../url/JobDetailServiceURLBuilderImpl.java | 28 -
.../url/JobListServiceURLBuilderImpl.java | 38 -
.../JobRunningConfigServiceURLBuilderImpl.java | 33 -
.../url/JobStatusServiceURLBuilderImpl.java | 29 -
.../eagle/jobrunning/url/ServiceURLBuilder.java | 21 -
.../eagle/jobrunning/util/InputStreamUtils.java | 61 -
.../java/eagle/jobrunning/util/JobUtils.java | 43 -
.../jobrunning/util/URLConnectionUtils.java | 108 -
.../java/eagle/jobrunning/yarn/model/App.java | 145 -
.../eagle/jobrunning/yarn/model/AppInfo.java | 146 -
.../eagle/jobrunning/yarn/model/AppWrapper.java | 35 -
.../jobrunning/yarn/model/Applications.java | 38 -
.../jobrunning/yarn/model/AppsWrapper.java | 36 -
.../eagle/jobrunning/yarn/model/Counter.java | 51 -
.../jobrunning/yarn/model/CounterGroup.java | 39 -
.../yarn/model/JobCompleteWrapper.java | 34 -
.../jobrunning/yarn/model/JobCounters.java | 39 -
.../yarn/model/JobCountersWrapper.java | 32 -
.../jobrunning/yarn/model/JobDetailInfo.java | 241 -
.../java/eagle/jobrunning/yarn/model/Jobs.java | 38 -
.../jobrunning/yarn/model/JobsWrapper.java | 37 -
.../jobrunning/zkres/JobRunningZKStateLCM.java | 35 -
.../zkres/JobRunningZKStateManager.java | 210 -
.../DefaultRunningJobInputStreamCallback.java | 58 +
.../jobrunning/callback/RunningJobCallback.java | 37 +
.../callback/RunningJobMessageId.java | 56 +
.../eagle/jobrunning/common/JobConstants.java | 53 +
.../config/RunningJobCrawlConfig.java | 61 +
.../jobrunning/counter/CounterGroupKey.java | 30 +
.../eagle/jobrunning/counter/CounterKey.java | 28 +
.../eagle/jobrunning/counter/JobCounters.java | 38 +
.../counter/parser/JobCountersParser.java | 26 +
.../counter/parser/JobCountersParserImpl.java | 44 +
.../jobrunning/crawler/ConfigWorkTask.java | 66 +
.../eagle/jobrunning/crawler/JobContext.java | 55 +
.../jobrunning/crawler/RMResourceFetcher.java | 272 ++
.../jobrunning/crawler/ResourceFetcher.java | 27 +
.../jobrunning/crawler/RunningJobCrawler.java | 28 +
.../crawler/RunningJobCrawlerImpl.java | 352 ++
.../eagle/jobrunning/crawler/XmlHelper.java | 55 +
.../eagle/jobrunning/ha/HAURLSelector.java | 31 +
.../eagle/jobrunning/ha/HAURLSelectorImpl.java | 101 +
.../jobrunning/job/conf/JobConfParser.java | 26 +
.../jobrunning/job/conf/JobConfParserImpl.java | 42 +
.../storm/JobRunningContentFilter.java | 27 +
.../storm/JobRunningContentFilterImpl.java | 36 +
.../eagle/jobrunning/storm/JobRunningSpout.java | 200 +
.../JobRunningSpoutCollectorInterceptor.java | 47 +
...JobCompleteCounterServiceURLBuilderImpl.java | 29 +
.../JobCompleteDetailServiceURLBuilderImpl.java | 31 +
...JobCompletedConfigServiceURLBuilderImpl.java | 27 +
.../url/JobCountersServiceURLBuilderImpl.java | 33 +
.../url/JobDetailServiceURLBuilderImpl.java | 28 +
.../url/JobListServiceURLBuilderImpl.java | 37 +
.../JobRunningConfigServiceURLBuilderImpl.java | 33 +
.../url/JobStatusServiceURLBuilderImpl.java | 29 +
.../eagle/jobrunning/url/ServiceURLBuilder.java | 21 +
.../eagle/jobrunning/util/InputStreamUtils.java | 61 +
.../apache/eagle/jobrunning/util/JobUtils.java | 43 +
.../jobrunning/util/URLConnectionUtils.java | 108 +
.../apache/eagle/jobrunning/yarn/model/App.java | 145 +
.../eagle/jobrunning/yarn/model/AppInfo.java | 146 +
.../eagle/jobrunning/yarn/model/AppWrapper.java | 35 +
.../jobrunning/yarn/model/Applications.java | 38 +
.../jobrunning/yarn/model/AppsWrapper.java | 36 +
.../eagle/jobrunning/yarn/model/Counter.java | 51 +
.../jobrunning/yarn/model/CounterGroup.java | 39 +
.../yarn/model/JobCompleteWrapper.java | 34 +
.../jobrunning/yarn/model/JobCounters.java | 39 +
.../yarn/model/JobCountersWrapper.java | 32 +
.../jobrunning/yarn/model/JobDetailInfo.java | 243 +
.../eagle/jobrunning/yarn/model/Jobs.java | 38 +
.../jobrunning/yarn/model/JobsWrapper.java | 37 +
.../jobrunning/zkres/JobRunningZKStateLCM.java | 35 +
.../zkres/JobRunningZKStateManager.java | 210 +
.../src/test/resources/hive-jobrunning.conf | 2 +-
.../impl/storm/AbstractStormSpoutProvider.java | 29 -
.../storm/hdfs/DataCollectionHDFSSpout.java | 230 -
.../hdfs/HDFSSourcedStormSpoutProvider.java | 60 -
.../hdfs/UserProfileGenerationHDFSSpout.java | 300 --
.../storm/kafka/KafkaSourcedSpoutProvider.java | 88 -
.../storm/kafka/KafkaSourcedSpoutScheme.java | 66 -
.../kafka/SpoutKafkaMessageDeserializer.java | 23 -
.../main/java/eagle/datastream/JavaMapper.java | 26 -
.../datastream/JavaMapperStormExecutor.java | 82 -
.../JavaStormExecutorForAlertWrapper.java | 55 -
.../impl/storm/AbstractStormSpoutProvider.java | 29 +
.../storm/hdfs/DataCollectionHDFSSpout.java | 230 +
.../hdfs/HDFSSourcedStormSpoutProvider.java | 60 +
.../hdfs/UserProfileGenerationHDFSSpout.java | 299 ++
.../storm/kafka/KafkaSourcedSpoutProvider.java | 88 +
.../storm/kafka/KafkaSourcedSpoutScheme.java | 66 +
.../kafka/SpoutKafkaMessageDeserializer.java | 23 +
.../org/apache/eagle/datastream/JavaMapper.java | 26 +
.../datastream/JavaMapperStormExecutor.java | 82 +
.../JavaStormExecutorForAlertWrapper.java | 55 +
.../AbstractStreamProducerGraph.scala | 29 -
.../datastream/AbstractTopologyCompiler.scala | 21 -
.../datastream/AbstractTopologyExecutor.scala | 21 -
.../datastream/AlertExecutorConsumerUtils.scala | 75 -
.../eagle/datastream/ExecutionEnvironment.scala | 73 -
.../eagle/datastream/FilterBoltWrapper.scala | 48 -
.../scala/eagle/datastream/GraphPrinter.scala | 37 -
.../eagle/datastream/JavaStormBoltWrapper.scala | 52 -
.../scala/eagle/datastream/MapBoltWrapper.scala | 68 -
.../eagle/datastream/NodeNameSelector.scala | 26 -
.../eagle/datastream/OutputFieldNameConst.scala | 21 -
.../scala/eagle/datastream/SpoutProxy.scala | 59 -
.../eagle/datastream/StormBoltFactory.scala | 47 -
.../eagle/datastream/StormBoltWrapper.scala | 60 -
.../StormExecutorForAlertWrapper.scala | 43 -
.../eagle/datastream/StormSpoutFactory.scala | 46 -
.../scala/eagle/datastream/StormStreamDAG.scala | 68 -
.../datastream/StormStreamDAGTransformer.scala | 46 -
.../datastream/StormTopologyCompiler.scala | 98 -
.../datastream/StormTopologyExecutorImpl.scala | 47 -
.../eagle/datastream/StreamAlertExpansion.scala | 192 -
.../scala/eagle/datastream/StreamAppDSL.scala | 120 -
.../eagle/datastream/StreamConnector.scala | 28 -
.../eagle/datastream/StreamDAGExpansion.scala | 27 -
.../datastream/StreamGroupbyExpansion.scala | 59 -
.../eagle/datastream/StreamNameExpansion.scala | 41 -
.../StreamParallelismConfigExpansion.scala | 55 -
.../scala/eagle/datastream/StreamProducer.scala | 193 -
.../eagle/datastream/StreamUnionExpansion.scala | 62 -
.../scala/eagle/datastream/UnionUtils.scala | 41 -
.../kafka/JsonMessageDeserializer.scala | 45 -
.../datastream/kafka/KafkaStreamMonitor.scala | 35 -
.../AbstractStreamProducerGraph.scala | 29 +
.../datastream/AbstractTopologyCompiler.scala | 21 +
.../datastream/AbstractTopologyExecutor.scala | 21 +
.../datastream/AlertExecutorConsumerUtils.scala | 75 +
.../eagle/datastream/ExecutionEnvironment.scala | 73 +
.../eagle/datastream/FilterBoltWrapper.scala | 48 +
.../apache/eagle/datastream/GraphPrinter.scala | 37 +
.../eagle/datastream/JavaStormBoltWrapper.scala | 52 +
.../eagle/datastream/MapBoltWrapper.scala | 68 +
.../eagle/datastream/NodeNameSelector.scala | 26 +
.../eagle/datastream/OutputFieldNameConst.scala | 21 +
.../apache/eagle/datastream/SpoutProxy.scala | 59 +
.../eagle/datastream/StormBoltFactory.scala | 47 +
.../eagle/datastream/StormBoltWrapper.scala | 60 +
.../StormExecutorForAlertWrapper.scala | 43 +
.../eagle/datastream/StormSpoutFactory.scala | 46 +
.../eagle/datastream/StormStreamDAG.scala | 68 +
.../datastream/StormStreamDAGTransformer.scala | 46 +
.../datastream/StormTopologyCompiler.scala | 98 +
.../datastream/StormTopologyExecutorImpl.scala | 47 +
.../eagle/datastream/StreamAlertExpansion.scala | 192 +
.../apache/eagle/datastream/StreamAppDSL.scala | 120 +
.../eagle/datastream/StreamConnector.scala | 28 +
.../eagle/datastream/StreamDAGExpansion.scala | 27 +
.../datastream/StreamGroupbyExpansion.scala | 59 +
.../eagle/datastream/StreamNameExpansion.scala | 41 +
.../StreamParallelismConfigExpansion.scala | 55 +
.../eagle/datastream/StreamProducer.scala | 193 +
.../eagle/datastream/StreamUnionExpansion.scala | 62 +
.../apache/eagle/datastream/UnionUtils.scala | 41 +
.../kafka/JsonMessageDeserializer.scala | 45 +
.../datastream/kafka/KafkaStreamMonitor.scala | 35 +
.../dataproc/util/TestConfigOptionParser.java | 105 -
.../java/eagle/datastream/JavaEchoExecutor.java | 44 -
.../java/eagle/datastream/TestJavaMain.java | 57 -
.../datastream/TestKafkaStreamMonitor.java | 28 -
.../dataproc/util/TestConfigOptionParser.java | 105 +
.../eagle/datastream/JavaEchoExecutor.java | 44 +
.../apache/eagle/datastream/TestJavaMain.java | 57 +
.../datastream/TestKafkaStreamMonitor.java | 29 +
.../src/test/resources/application.conf | 2 +-
.../eagle/datastream/TestDAGExpansion.scala | 80 -
.../test/scala/eagle/datastream/TestScala.scala | 20 -
.../scala/eagle/datastream/TestStormNodes.scala | 160 -
.../eagle/datastream/TestStormRunner.scala | 122 -
.../eagle/datastream/TestStreamDAGBuilder.scala | 236 -
.../eagle/datastream/TestDAGExpansion.scala | 80 +
.../org/apache/eagle/datastream/TestScala.scala | 20 +
.../eagle/datastream/TestStormNodes.scala | 160 +
.../eagle/datastream/TestStormRunner.scala | 122 +
.../eagle/datastream/TestStreamDAGBuilder.scala | 236 +
.../dataproc/core/EagleOutputCollector.java | 27 -
.../eagle/dataproc/core/JsonSerDeserUtils.java | 53 -
.../core/StreamingProcessConstants.java | 23 -
.../java/eagle/dataproc/core/ValuesArray.java | 38 -
.../util/AbstractConfigOptionParser.java | 68 -
.../eagle/dataproc/util/ConfigOptionParser.java | 64 -
.../dataproc/core/EagleOutputCollector.java | 27 +
.../eagle/dataproc/core/JsonSerDeserUtils.java | 53 +
.../core/StreamingProcessConstants.java | 23 +
.../apache/eagle/dataproc/core/ValuesArray.java | 38 +
.../util/AbstractConfigOptionParser.java | 68 +
.../eagle/dataproc/util/ConfigOptionParser.java | 64 +
.../main/scala/eagle/datastream/Collector.scala | 21 -
.../scala/eagle/datastream/EagleTuple.scala | 46 -
.../scala/eagle/datastream/FlatMapper.scala | 21 -
.../eagle/datastream/StormStreamExecutor.scala | 64 -
.../org/apache/eagle/datastream/Collector.scala | 21 +
.../apache/eagle/datastream/EagleTuple.scala | 46 +
.../apache/eagle/datastream/FlatMapper.scala | 21 +
.../eagle/datastream/StormStreamExecutor.scala | 64 +
.../java/eagle/service/hbase/EmbeddedHbase.java | 132 -
.../main/java/eagle/service/hbase/Tables.java | 50 -
.../eagle/service/hbase/EmbeddedHbase.java | 132 +
.../org/apache/eagle/service/hbase/Tables.java | 50 +
.../java/eagle/service/hbase/TestHBaseBase.java | 35 -
.../eagle/service/hbase/TestHBaseBase.java | 35 +
.../eagle-embed-server/runEmbeddedServer.sh | 2 +-
.../service/embedded/tomcat/EmbeddedServer.java | 109 -
.../service/embedded/tomcat/EmbeddedServer.java | 109 +
.../embedded/tomcat/TestEmbeddedServer.java | 26 -
.../embedded/tomcat/TestEmbeddedServer.java | 26 +
.../java/eagle/ml/MLAlgorithmEvaluator.java | 49 -
.../main/java/eagle/ml/MLAnomalyCallback.java | 28 -
.../src/main/java/eagle/ml/MLConstants.java | 24 -
.../src/main/java/eagle/ml/MLModelDAO.java | 30 -
.../main/java/eagle/ml/MLPolicyEvaluator.java | 163 -
.../eagle/ml/impl/MLAnomalyCallbackImpl.java | 106 -
.../main/java/eagle/ml/impl/MLModelDAOImpl.java | 83 -
.../MLPolicyEvaluatorServiceProviderImpl.java | 52 -
.../main/java/eagle/ml/model/MLAlgorithm.java | 61 -
.../java/eagle/ml/model/MLCallbackResult.java | 137 -
.../java/eagle/ml/model/MLEntityRepository.java | 25 -
.../java/eagle/ml/model/MLModelAPIEntity.java | 67 -
.../java/eagle/ml/model/MLPolicyDefinition.java | 82 -
.../java/eagle/ml/utils/MLReflectionUtils.java | 38 -
.../apache/eagle/ml/MLAlgorithmEvaluator.java | 49 +
.../org/apache/eagle/ml/MLAnomalyCallback.java | 28 +
.../java/org/apache/eagle/ml/MLConstants.java | 24 +
.../java/org/apache/eagle/ml/MLModelDAO.java | 30 +
.../org/apache/eagle/ml/MLPolicyEvaluator.java | 163 +
.../eagle/ml/impl/MLAnomalyCallbackImpl.java | 106 +
.../apache/eagle/ml/impl/MLModelDAOImpl.java | 83 +
.../MLPolicyEvaluatorServiceProviderImpl.java | 52 +
.../org/apache/eagle/ml/model/MLAlgorithm.java | 61 +
.../apache/eagle/ml/model/MLCallbackResult.java | 137 +
.../eagle/ml/model/MLEntityRepository.java | 25 +
.../apache/eagle/ml/model/MLModelAPIEntity.java | 67 +
.../eagle/ml/model/MLPolicyDefinition.java | 82 +
.../eagle/ml/utils/MLReflectionUtils.java | 38 +
....alert.policy.PolicyEvaluatorServiceProvider | 1 -
....alert.policy.PolicyEvaluatorServiceProvider | 1 +
....alert.policy.PolicyEvaluatorServiceProvider | 1 -
....alert.policy.PolicyEvaluatorServiceProvider | 1 +
.../src/test/resources/application.conf | 2 +-
.../test/resources/ml-policyDef-UserProfile.txt | 4 +-
.../main/java/eagle/metric/CountingMetric.java | 44 -
.../src/main/java/eagle/metric/Metric.java | 87 -
.../main/java/eagle/metric/MetricOperator.java | 22 -
.../metric/report/EagleSerivceMetricReport.java | 62 -
.../metric/report/MetricEntityConvert.java | 32 -
.../java/eagle/metric/report/MetricReport.java | 26 -
.../org/apache/eagle/metric/CountingMetric.java | 44 +
.../java/org/apache/eagle/metric/Metric.java | 87 +
.../org/apache/eagle/metric/MetricOperator.java | 22 +
.../metric/report/EagleSerivceMetricReport.java | 61 +
.../metric/report/MetricEntityConvert.java | 32 +
.../eagle/metric/report/MetricReport.java | 26 +
.../eagle-antlr/src/main/java/EagleFilter.g4 | 2 +-
.../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 --
.../java/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 -
.../java/eagle/query/parser/ORExpression.java | 60 -
.../java/eagle/query/parser/TokenConstant.java | 52 -
.../main/java/eagle/query/parser/TokenType.java | 44 -
.../UnsupportedExpressionOperatorException.java | 25 -
.../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 +
.../query/parser/test/TestEagleQueryParser.java | 832 ----
.../eagle/query/parser/test/TestValueType.java | 73 -
.../query/parser/test/TestEagleQueryParser.java | 832 ++++
.../eagle/query/parser/test/TestValueType.java | 73 +
.../service/client/EagleServiceAsyncClient.java | 117 -
.../client/EagleServiceClientException.java | 64 -
.../client/EagleServiceGroupByQueryRequest.java | 173 -
.../client/EagleServiceQueryBuilder.java | 109 -
.../client/EagleServiceQueryRequest.java | 151 -
.../EagleServiceSingleEntityQueryRequest.java | 211 -
.../service/client/IEagleServiceClient.java | 129 -
.../client/IEagleServiceRequestBuilder.java | 83 -
.../ListGroupByQueryAPIResponseEntity.java | 90 -
.../ListQueryAPIResponseConvertHelper.java | 117 -
.../ListTimeSeriesQueryAPIResponseEntity.java | 84 -
.../RowkeyQueryAPIResponseConvertHelper.java | 110 -
.../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 | 341 --
.../client/impl/EagleServiceClientImpl.java | 196 -
.../eagle/service/client/impl/MetricSender.java | 75 -
.../client/impl/SearchRequestBuilder.java | 97 -
.../client/security/SecurityConstants.java | 6 -
.../service/client/EagleServiceAsyncClient.java | 117 +
.../client/EagleServiceClientException.java | 64 +
.../client/EagleServiceGroupByQueryRequest.java | 173 +
.../client/EagleServiceQueryBuilder.java | 107 +
.../client/EagleServiceQueryRequest.java | 151 +
.../EagleServiceSingleEntityQueryRequest.java | 211 +
.../service/client/IEagleServiceClient.java | 129 +
.../client/IEagleServiceRequestBuilder.java | 83 +
.../ListGroupByQueryAPIResponseEntity.java | 90 +
.../ListQueryAPIResponseConvertHelper.java | 117 +
.../ListTimeSeriesQueryAPIResponseEntity.java | 84 +
.../RowkeyQueryAPIResponseConvertHelper.java | 110 +
.../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 | 339 ++
.../client/impl/EagleServiceClientImpl.java | 196 +
.../eagle/service/client/impl/MetricSender.java | 75 +
.../client/impl/SearchRequestBuilder.java | 97 +
.../client/security/SecurityConstants.java | 6 +
.../test/java/eagle/service/client/Base.java | 31 -
.../test/java/eagle/service/client/ClassA.java | 35 -
.../test/java/eagle/service/client/ClassB.java | 34 -
.../eagle/service/client/ClientTestBase.java | 37 -
.../client/TestEagleServiceClientImpl.java | 339 --
.../service/client/TestIEagleServiceClient.java | 64 -
.../java/eagle/service/client/TestJackson.java | 63 -
.../service/jackson/TestJacksonMarshalling.java | 149 -
.../jackson/TestJacksonUnmashalling.java | 149 -
.../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 | 339 ++
.../service/client/TestIEagleServiceClient.java | 64 +
.../eagle/service/client/TestJackson.java | 63 +
.../service/jackson/TestJacksonMarshalling.java | 149 +
.../jackson/TestJacksonUnmashalling.java | 149 +
.../src/main/java/eagle/common/Base64.java | 44 -
.../src/main/java/eagle/common/ByteUtil.java | 178 -
.../java/eagle/common/CircularArrayList.java | 149 -
.../common/CircularArrayListSortedSet.java | 106 -
.../main/java/eagle/common/DateTimeUtil.java | 138 -
.../java/eagle/common/EagleBase64Wrapper.java | 32 -
.../eagle/common/EagleExceptionWrapper.java | 42 -
.../src/main/java/eagle/common/Environment.java | 23 -
.../src/main/java/eagle/common/OS.java | 41 -
.../java/eagle/common/config/EagleConfig.java | 55 -
.../common/config/EagleConfigConstants.java | 55 -
.../eagle/common/config/EagleConfigFactory.java | 183 -
.../eagle/common/email/EagleMailClient.java | 248 --
.../java/eagle/common/metric/AlertContext.java | 66 -
.../common/service/HadoopAccountService.java | 23 -
.../java/eagle/common/service/HadoopUser.java | 44 -
.../java/eagle/common/service/LdapService.java | 259 --
.../common/service/POSTResultEntityBase.java | 42 -
.../service/TrustAllSSLSocketFactory.java | 94 -
.../java/org/apache/eagle/common/Base64.java | 44 +
.../java/org/apache/eagle/common/ByteUtil.java | 178 +
.../apache/eagle/common/CircularArrayList.java | 149 +
.../common/CircularArrayListSortedSet.java | 106 +
.../org/apache/eagle/common/DateTimeUtil.java | 138 +
.../apache/eagle/common/EagleBase64Wrapper.java | 32 +
.../eagle/common/EagleExceptionWrapper.java | 42 +
.../org/apache/eagle/common/Environment.java | 23 +
.../main/java/org/apache/eagle/common/OS.java | 41 +
.../apache/eagle/common/config/EagleConfig.java | 55 +
.../common/config/EagleConfigConstants.java | 55 +
.../eagle/common/config/EagleConfigFactory.java | 182 +
.../eagle/common/email/EagleMailClient.java | 248 ++
.../eagle/common/metric/AlertContext.java | 66 +
.../common/service/HadoopAccountService.java | 23 +
.../apache/eagle/common/service/HadoopUser.java | 44 +
.../eagle/common/service/LdapService.java | 259 ++
.../common/service/POSTResultEntityBase.java | 42 +
.../service/TrustAllSSLSocketFactory.java | 94 +
.../eagle-common/src/main/resources/footer.vm | 4 +-
.../eagle-common/src/main/resources/header.vm | 3 +-
.../src/main/resources/templates/tec_alert.vm | 3 +-
.../test/java/eagle/common/TestByteUtil.java | 112 -
.../eagle/common/TestCircularArrayList.java | 75 -
.../common/TestCircularArrayListSortedSet.java | 59 -
.../java/eagle/common/TestDateTimeUtil.java | 88 -
.../eagle/common/TestEagleBase64Wrapper.java | 38 -
.../eagle/common/config/TestEagleConfig.java | 43 -
.../org/apache/eagle/common/TestByteUtil.java | 112 +
.../eagle/common/TestCircularArrayList.java | 75 +
.../common/TestCircularArrayListSortedSet.java | 59 +
.../apache/eagle/common/TestDateTimeUtil.java | 88 +
.../eagle/common/TestEagleBase64Wrapper.java | 38 +
.../eagle/common/config/TestEagleConfig.java | 43 +
.../eagle-common/src/test/resources/footer.vm | 2 -
.../eagle-common/src/test/resources/header.vm | 1 -
.../src/test/resources/templates/tec_alert.vm | 1 -
.../resources/templates/test_anomaly_alert.vm | 1 -
.../src/test/resources/test-service-config.conf | 18 +-
.../src/test/resources/test_embed.png | Bin 9980 -> 0 bytes
.../eagle/log/base/taggedlog/EntityContext.java | 40 -
.../log/base/taggedlog/NoSuchRowException.java | 29 -
.../log/base/taggedlog/RowkeyAPIEntity.java | 81 -
.../log/base/taggedlog/TaggedLogAPIEntity.java | 238 -
.../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 | 279 --
.../main/java/eagle/log/entity/EntityUniq.java | 67 -
.../entity/GenericCreateAPIResponseEntity.java | 57 -
.../log/entity/GenericEntityBatchReader.java | 58 -
.../entity/GenericEntityScanStreamReader.java | 129 -
.../log/entity/GenericEntityStreamReader.java | 126 -
.../log/entity/GenericEntityStreamReaderMT.java | 151 -
.../eagle/log/entity/GenericEntityWriter.java | 78 -
.../eagle/log/entity/GenericMetricEntity.java | 60 -
.../entity/GenericMetricEntityBatchReader.java | 54 -
...ricMetricEntityDecompactionStreamReader.java | 98 -
.../log/entity/GenericMetricShadowEntity.java | 34 -
.../entity/GenericServiceAPIResponseEntity.java | 121 -
...ricServiceAPIResponseEntityDeserializer.java | 84 -
.../log/entity/HBaseInternalLogHelper.java | 245 -
.../java/eagle/log/entity/HBaseLogReader2.java | 86 -
.../java/eagle/log/entity/HBaseLogWriter.java | 152 -
.../main/java/eagle/log/entity/InternalLog.java | 139 -
.../log/entity/ListQueryAPIResponseEntity.java | 78 -
.../main/java/eagle/log/entity/LogReader.java | 28 -
.../main/java/eagle/log/entity/LogWriter.java | 32 -
.../eagle/log/entity/MetricMetadataEntity.java | 117 -
.../log/entity/QualifierCreationListener.java | 28 -
.../entity/QualifierNotDefinedException.java | 28 -
.../java/eagle/log/entity/RowkeyBuilder.java | 140 -
.../entity/RowkeyQueryAPIResponseEntity.java | 45 -
.../java/eagle/log/entity/SearchCondition.java | 148 -
.../java/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 | 46 -
.../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 | 125 -
.../entity/index/UniqueIndexStreamReader.java | 52 -
.../eagle/log/entity/meta/BooleanSerDeser.java | 54 -
.../main/java/eagle/log/entity/meta/Column.java | 28 -
.../eagle/log/entity/meta/ColumnFamily.java | 28 -
.../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 | 30 -
.../eagle/log/entity/meta/EntityDefinition.java | 318 --
.../entity/meta/EntityDefinitionManager.java | 463 --
.../eagle/log/entity/meta/EntitySerDeser.java | 23 -
.../log/entity/meta/EntitySerDeserializer.java | 79 -
.../main/java/eagle/log/entity/meta/Index.java | 32 -
.../eagle/log/entity/meta/IndexDefinition.java | 335 --
.../java/eagle/log/entity/meta/Indexes.java | 29 -
.../eagle/log/entity/meta/IntArraySerDeser.java | 71 -
.../java/eagle/log/entity/meta/IntSerDeser.java | 42 -
.../eagle/log/entity/meta/ListSerDeser.java | 128 -
.../eagle/log/entity/meta/LongSerDeser.java | 43 -
.../java/eagle/log/entity/meta/MapSerDeser.java | 168 -
.../main/java/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 -
.../java/eagle/log/entity/meta/NullObject.java | 21 -
.../eagle/log/entity/meta/NullSerDeser.java | 37 -
.../java/eagle/log/entity/meta/Partition.java | 40 -
.../main/java/eagle/log/entity/meta/Prefix.java | 28 -
.../java/eagle/log/entity/meta/Qualifier.java | 100 -
.../java/eagle/log/entity/meta/Service.java | 28 -
.../java/eagle/log/entity/meta/ServicePath.java | 34 -
.../log/entity/meta/StringArraySerDeser.java | 94 -
.../eagle/log/entity/meta/StringSerDeser.java | 39 -
.../main/java/eagle/log/entity/meta/Table.java | 28 -
.../main/java/eagle/log/entity/meta/Tags.java | 31 -
.../java/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 -
.../java/eagle/log/entity/old/LogDeleter.java | 34 -
.../java/eagle/log/entity/old/RowkeyHelper.java | 85 -
.../main/java/eagle/log/entity/old/Schema.java | 24 -
.../entity/repo/DefaultEntityRepository.java | 34 -
.../eagle/log/entity/repo/EntityRepository.java | 56 -
.../entity/repo/EntityRepositoryScanner.java | 73 -
.../java/eagle/log/entity/test/TestEntity.java | 107 -
.../eagle/log/entity/test/TestLogAPIEntity.java | 99 -
.../entity/test/TestTimeSeriesAPIEntity.java | 101 -
.../eagle/log/expression/ExpressionParser.java | 207 -
.../log/expression/ParsiiInvalidException.java | 57 -
.../ParsiiUnknowVariableException.java | 57 -
.../eagle/log/base/taggedlog/EntityContext.java | 40 +
.../log/base/taggedlog/NoSuchRowException.java | 29 +
.../log/base/taggedlog/RowkeyAPIEntity.java | 81 +
.../log/base/taggedlog/TaggedLogAPIEntity.java | 238 +
.../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 | 279 ++
.../org/apache/eagle/log/entity/EntityUniq.java | 67 +
.../entity/GenericCreateAPIResponseEntity.java | 57 +
.../log/entity/GenericEntityBatchReader.java | 58 +
.../entity/GenericEntityScanStreamReader.java | 129 +
.../log/entity/GenericEntityStreamReader.java | 125 +
.../log/entity/GenericEntityStreamReaderMT.java | 151 +
.../eagle/log/entity/GenericEntityWriter.java | 78 +
.../eagle/log/entity/GenericMetricEntity.java | 59 +
.../entity/GenericMetricEntityBatchReader.java | 54 +
...ricMetricEntityDecompactionStreamReader.java | 98 +
.../log/entity/GenericMetricShadowEntity.java | 34 +
.../entity/GenericServiceAPIResponseEntity.java | 121 +
...ricServiceAPIResponseEntityDeserializer.java | 84 +
.../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 +
.../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 | 30 +
.../eagle/log/entity/meta/EntityDefinition.java | 318 ++
.../entity/meta/EntityDefinitionManager.java | 463 ++
.../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 | 72 +
.../eagle/log/entity/test/TestEntity.java | 107 +
.../eagle/log/entity/test/TestLogAPIEntity.java | 99 +
.../entity/test/TestTimeSeriesAPIEntity.java | 101 +
.../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 | 169 -
.../log/entity/TestHBaseIntegerLogHelper.java | 67 -
.../TestHBaseWriteEntitiesPerformance.java | 132 -
.../log/entity/TestHbaseWritePerformance.java | 100 -
.../eagle/log/entity/TestTestLogAPIEntity.java | 405 --
.../base/taggedlog/TestTaggedLogAPIEntity.java | 91 -
.../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 | 30 -
.../log/expression/TestExpressionParser.java | 256 --
.../expression/TestExpressionPerformance.java | 120 -
.../TestGenericServiceAPIResponseEntity.java | 92 +
.../log/entity/TestDouble2DArraySerDeser.java | 48 +
.../eagle/log/entity/TestDoubleSerDeser.java | 58 +
.../TestGenericEntityIndexStreamReader.java | 169 +
.../log/entity/TestHBaseIntegerLogHelper.java | 67 +
.../TestHBaseWriteEntitiesPerformance.java | 132 +
.../log/entity/TestHbaseWritePerformance.java | 100 +
.../eagle/log/entity/TestTestLogAPIEntity.java | 405 ++
.../base/taggedlog/TestTaggedLogAPIEntity.java | 91 +
.../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 | 30 +
.../log/expression/TestExpressionParser.java | 256 ++
.../expression/TestExpressionPerformance.java | 120 +
.../java/eagle/query/GenericEntityQuery.java | 74 -
.../src/main/java/eagle/query/GenericQuery.java | 46 -
.../java/eagle/query/ListQueryCompiler.java | 380 --
.../main/java/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 -
.../java/eagle/query/aggregate/Aggregator.java | 168 -
.../java/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 | 138 -
.../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 | 184 -
.../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/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 | 138 +
.../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 | 184 +
.../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 +
.../query/aggregate/raw/TestGroupbyKey.java | 74 -
.../query/aggregate/raw/TestRawAggregator.java | 517 ---
.../raw/TestRawHBaseLogReaderAndAgg.java | 26 -
.../query/aggregate/test/TestAggregator.java | 254 --
.../aggregate/test/TestAlertAggService.java | 56 -
.../query/aggregate/test/TestBucketQuery.java | 156 -
.../query/aggregate/test/TestBucketQuery2.java | 160 -
.../aggregate/test/TestFlatAggregator.java | 400 --
.../test/TestGroupbyFieldComparator.java | 35 -
.../test/TestHierarchicalAggregator.java | 332 --
.../test/TestPostFlatAggregateSort.java | 143 -
.../test/TestTimeSeriesAggregator.java | 176 -
.../query/aggregate/raw/TestGroupbyKey.java | 74 +
.../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 | 400 ++
.../test/TestGroupbyFieldComparator.java | 35 +
.../test/TestHierarchicalAggregator.java | 332 ++
.../test/TestPostFlatAggregateSort.java | 143 +
.../test/TestTimeSeriesAggregator.java | 176 +
.../service/common/EagleExceptionWrapper.java | 42 -
.../common/SplitFullScanEntityReader.java | 289 --
.../generic/GenericEntityServiceResource.java | 589 ---
.../generic/GenericObjectMapperProvider.java | 44 -
.../service/generic/ListQueryResource.java | 504 ---
.../eagle/service/generic/MetadataResource.java | 198 -
.../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 | 64 -
.../service/common/EagleExceptionWrapper.java | 42 +
.../common/SplitFullScanEntityReader.java | 289 ++
.../generic/GenericEntityServiceResource.java | 589 +++
.../generic/GenericObjectMapperProvider.java | 44 +
.../service/generic/ListQueryResource.java | 504 +++
.../eagle/service/generic/MetadataResource.java | 198 +
.../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 | 64 +
.../src/main/webapp/WEB-INF/web.xml | 2 +-
.../service/generic/TestHBaseLogReader2.java | 162 -
.../service/generic/TestListQueryCompiler.java | 243 -
.../service/generic/TestListQueryResource.java | 601 ---
.../service/generic/TestHBaseLogReader2.java | 162 +
.../service/generic/TestListQueryCompiler.java | 243 +
.../service/generic/TestListQueryResource.java | 601 +++
.../main/java/eagle/storage/DataStorage.java | 111 -
.../java/eagle/storage/DataStorageBase.java | 31 -
.../java/eagle/storage/DataStorageManager.java | 124 -
.../exception/IllegalDataStorageException.java | 38 -
.../IllegalDataStorageTypeException.java | 38 -
.../exception/QueryCompileException.java | 38 -
.../eagle/storage/operation/CompiledQuery.java | 253 --
.../storage/operation/CreateStatement.java | 68 -
.../storage/operation/DeleteStatement.java | 98 -
.../eagle/storage/operation/QueryStatement.java | 52 -
.../java/eagle/storage/operation/RawQuery.java | 232 -
.../storage/operation/RowkeyQueryStatement.java | 61 -
.../java/eagle/storage/operation/Statement.java | 34 -
.../storage/operation/UpdateStatement.java | 56 -
.../java/eagle/storage/result/ModifyResult.java | 34 -
.../java/eagle/storage/result/QueryResult.java | 67 -
.../main/java/eagle/storage/result/Result.java | 41 -
.../storage/spi/DataStorageServiceLoader.java | 94 -
.../storage/spi/DataStorageServiceProvider.java | 35 -
.../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 | 253 ++
.../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 | 94 +
.../storage/spi/DataStorageServiceProvider.java | 35 +
.../eagle/storage/TestDataStorageLoader.java | 51 -
.../src/test/java/eagle/storage/TestUri.java | 42 -
.../java/eagle/storage/spi/TestDataStorage.java | 84 -
.../spi/TestDataStorageServiceProvider.java | 42 -
.../eagle/storage/TestDataStorageLoader.java | 51 +
.../java/org/apache/eagle/storage/TestUri.java | 42 +
.../eagle/storage/spi/TestDataStorage.java | 84 +
.../spi/TestDataStorageServiceProvider.java | 42 +
...eagle.storage.spi.DataStorageServiceProvider | 1 -
...eagle.storage.spi.DataStorageServiceProvider | 1 +
.../java/eagle/storage/hbase/HBaseStorage.java | 245 -
.../hbase/query/GenericQueryBuilder.java | 158 -
.../query/aggregate/GenericAggregateQuery.java | 423 --
.../query/aggregate/GenericAggregateReader.java | 131 -
.../query/coprocessor/AggregateClient.java | 89 -
.../query/coprocessor/AggregateProtocol.java | 68 -
.../coprocessor/AggregateProtocolEndPoint.java | 447 --
.../query/coprocessor/AggregateResult.java | 129 -
.../coprocessor/AggregateResultCallback.java | 48 -
.../query/coprocessor/ProtoBufConverter.java | 124 -
.../coprocessor/_AggregateProtocolEndPoint.java | 139 -
.../coprocessor/generated/AggregateProtos.java | 4214 ------------------
.../coprocessor/impl/AggregateClientImpl.java | 146 -
.../impl/AggregateResultCallbackImpl.java | 143 -
.../hbase/query/coprocessor/package-info.java | 111 -
.../hbase/spi/HBaseStorageServiceProvider.java | 38 -
.../eagle/storage/hbase/HBaseStorage.java | 245 +
.../hbase/query/GenericQueryBuilder.java | 158 +
.../query/aggregate/GenericAggregateQuery.java | 423 ++
.../query/aggregate/GenericAggregateReader.java | 131 +
.../query/coprocessor/AggregateClient.java | 89 +
.../query/coprocessor/AggregateProtocol.java | 68 +
.../coprocessor/AggregateProtocolEndPoint.java | 447 ++
.../query/coprocessor/AggregateResult.java | 129 +
.../coprocessor/AggregateResultCallback.java | 48 +
.../query/coprocessor/ProtoBufConverter.java | 124 +
.../coprocessor/_AggregateProtocolEndPoint.java | 139 +
.../coprocessor/generated/AggregateProtos.java | 4214 ++++++++++++++++++
.../coprocessor/impl/AggregateClientImpl.java | 146 +
.../impl/AggregateResultCallbackImpl.java | 143 +
.../hbase/query/coprocessor/package-info.java | 111 +
.../hbase/spi/HBaseStorageServiceProvider.java | 38 +
.../src/main/protobuf/AggregateProtocol.proto | 2 +-
...eagle.storage.spi.DataStorageServiceProvider | 1 -
...eagle.storage.spi.DataStorageServiceProvider | 1 +
.../eagle/storage/hbase/TestHBaseStatement.java | 103 -
.../eagle/storage/hbase/TestHBaseStorage.java | 34 -
.../TestAggregateResultCallback.java | 184 -
.../coprocessor/TestGroupAggregateClient.java | 254 --
.../TestGroupAggregateTimeSeriesClient.java | 218 -
.../storage/hbase/spi/TestHBaseStorage.java | 29 -
.../hbase/spi/TestHBaseStorageLoader.java | 43 -
.../eagle/storage/hbase/TestHBaseStatement.java | 103 +
.../eagle/storage/hbase/TestHBaseStorage.java | 34 +
.../TestAggregateResultCallback.java | 184 +
.../coprocessor/TestGroupAggregateClient.java | 253 ++
.../TestGroupAggregateTimeSeriesClient.java | 218 +
.../storage/hbase/spi/TestHBaseStorage.java | 29 +
.../hbase/spi/TestHBaseStorageLoader.java | 43 +
.../java/eagle/storage/jdbc/JdbcConstants.java | 37 -
.../java/eagle/storage/jdbc/JdbcStorage.java | 211 -
.../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 -
.../conn/impl/TorqueConnectionManagerImpl.java | 142 -
.../jdbc/conn/impl/TorqueStatementPeerImpl.java | 57 -
.../jdbc/conn/impl/UUIDPrimaryKeyBuilder.java | 31 -
.../storage/jdbc/criteria/CriteriaBuilder.java | 26 -
.../storage/jdbc/criteria/CriterionBuilder.java | 26 -
.../impl/ExpressionCriterionBuilder.java | 119 -
.../impl/PrimaryKeyCriteriaBuilder.java | 48 -
.../criteria/impl/QueryCriteriaBuilder.java | 115 -
.../storage/jdbc/entity/JdbcEntityDeleter.java | 48 -
.../storage/jdbc/entity/JdbcEntityReader.java | 49 -
.../jdbc/entity/JdbcEntitySerDeserHelper.java | 220 -
.../storage/jdbc/entity/JdbcEntityUpdater.java | 34 -
.../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 | 109 -
.../jdbc/entity/impl/JdbcEntityUpdaterImpl.java | 82 -
.../jdbc/entity/impl/JdbcEntityWriterImpl.java | 103 -
.../eagle/storage/jdbc/entity/package-info.java | 25 -
.../java/eagle/storage/jdbc/package-info.java | 84 -
.../jdbc/schema/JdbcEntityDefinition.java | 101 -
.../schema/JdbcEntityDefinitionManager.java | 125 -
.../jdbc/schema/ddl/JdbcEntityDdlManager.java | 24 -
.../storage/jdbc/schema/ddl/package-info.java | 24 -
.../schema/serializer/DefaultJdbcSerDeser.java | 52 -
.../jdbc/schema/serializer/JdbcSerDeser.java | 31 -
.../schema/serializer/JsonJdbcSerDeser.java | 57 -
.../jdbc/spi/JdbcStorageServiceProvider.java | 38 -
.../eagle/storage/jdbc/JdbcConstants.java | 37 +
.../apache/eagle/storage/jdbc/JdbcStorage.java | 211 +
.../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 +
.../conn/impl/TorqueConnectionManagerImpl.java | 142 +
.../jdbc/conn/impl/TorqueStatementPeerImpl.java | 57 +
.../jdbc/conn/impl/UUIDPrimaryKeyBuilder.java | 31 +
.../storage/jdbc/criteria/CriteriaBuilder.java | 26 +
.../storage/jdbc/criteria/CriterionBuilder.java | 26 +
.../impl/ExpressionCriterionBuilder.java | 119 +
.../impl/PrimaryKeyCriteriaBuilder.java | 48 +
.../criteria/impl/QueryCriteriaBuilder.java | 115 +
.../storage/jdbc/entity/JdbcEntityDeleter.java | 48 +
.../storage/jdbc/entity/JdbcEntityReader.java | 49 +
.../jdbc/entity/JdbcEntitySerDeserHelper.java | 220 +
.../storage/jdbc/entity/JdbcEntityUpdater.java | 34 +
.../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 | 109 +
.../jdbc/entity/impl/JdbcEntityUpdaterImpl.java | 82 +
.../jdbc/entity/impl/JdbcEntityWriterImpl.java | 103 +
.../eagle/storage/jdbc/entity/package-info.java | 25 +
.../apache/eagle/storage/jdbc/package-info.java | 84 +
.../jdbc/schema/JdbcEntityDefinition.java | 101 +
.../schema/JdbcEntityDefinitionManager.java | 125 +
.../jdbc/schema/ddl/JdbcEntityDdlManager.java | 24 +
.../storage/jdbc/schema/ddl/package-info.java | 24 +
.../schema/serializer/DefaultJdbcSerDeser.java | 52 +
.../jdbc/schema/serializer/JdbcSerDeser.java | 31 +
.../schema/serializer/JsonJdbcSerDeser.java | 57 +
.../jdbc/spi/JdbcStorageServiceProvider.java | 38 +
...eagle.storage.spi.DataStorageServiceProvider | 1 -
...eagle.storage.spi.DataStorageServiceProvider | 1 +
.../eagle/storage/jdbc/TestJdbcStorage.java | 233 -
.../jdbc/conn/TestConnectionFactory.java | 55 -
.../jdbc/criteria/TestQueryCriteriaBuilder.java | 88 -
.../eagle/storage/jdbc/criteria/TestTorque.java | 120 -
.../eagle/storage/jdbc/schema/TestDllUtils.java | 40 -
.../eagle/storage/jdbc/TestJdbcStorage.java | 233 +
.../jdbc/conn/TestConnectionFactory.java | 55 +
.../jdbc/criteria/TestQueryCriteriaBuilder.java | 88 +
.../eagle/storage/jdbc/criteria/TestTorque.java | 119 +
.../eagle/storage/jdbc/schema/TestDllUtils.java | 40 +
.../resources/conf/log4j-template.properties | 4 +-
.../eagle/log4j/kafka/JKafkaLog4jAppender.scala | 136 -
.../eagle/log4j/kafka/KafkaLog4jAppender.scala | 163 -
.../main/scala/eagle/log4j/kafka/Keyer.scala | 32 -
.../scala/eagle/log4j/kafka/TopicPicker.scala | 32 -
.../log4j/kafka/hadoop/AuditLogKeyer.scala | 34 -
.../log4j/kafka/hadoop/AuditLogUtils.scala | 29 -
.../kafka/hadoop/AuditSecurityLogKeyer.scala | 44 -
.../hadoop/FailedAuthenticationFilter.scala | 42 -
.../log4j/kafka/hadoop/GenericLogKeyer.scala | 46 -
.../log4j/kafka/hadoop/SecurityLogKeyer.scala | 50 -
.../kafka/hadoop/SecurityLogTopicPicker.scala | 53 -
.../eagle/log4j/kafka/JKafkaLog4jAppender.scala | 136 +
.../eagle/log4j/kafka/KafkaLog4jAppender.scala | 163 +
.../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 | 4 +-
.../eagle.log4j.kafka/TestGenericLogKeyer.scala | 49 -
.../TestKafkaLog4jAppender.scala | 32 -
.../eagle/log4j/kafka/TestGenericLogKeyer.scala | 48 +
.../log4j/kafka/TestKafkaLog4jAppender.scala | 32 +
.../security/hbase/HbaseResourceEntity.java | 105 -
.../HbaseResourceSensitivityAPIEntity.java | 47 -
.../hbase/HbaseSecurityEntityRepository.java | 27 -
.../eagle/security/hdfs/HDFSAuditLogObject.java | 30 -
.../eagle/security/hdfs/HDFSAuditLogParser.java | 175 -
.../hdfs/entity/FileSensitivityAPIEntity.java | 52 -
.../security/hdfs/entity/FileStatusEntity.java | 176 -
.../entity/HDFSFileSystemResponseEntity.java | 48 -
.../entity/HDFSSecurityEntityRepository.java | 26 -
.../security/hdfs/entity/IPZoneEntity.java | 52 -
.../hive/entity/HiveResourceEntity.java | 104 -
.../HiveResourceSensitivityAPIEntity.java | 53 -
.../entity/HiveSecurityEntityRepository.java | 25 -
.../resolver/AbstractCommandResolver.java | 72 -
.../AbstractSensitivityTypeResolver.java | 82 -
.../AbstractResourceSensitivityPollingJob.java | 56 -
.../util/BadMetadataAccessConfigException.java | 30 -
.../eagle/security/util/ExternalDataCache.java | 43 -
.../eagle/security/util/ExternalDataJoiner.java | 104 -
.../security/util/JVMSingleQuartzScheduler.java | 51 -
.../security/hbase/HbaseResourceEntity.java | 105 +
.../HbaseResourceSensitivityAPIEntity.java | 47 +
.../hbase/HbaseSecurityEntityRepository.java | 26 +
.../eagle/security/hdfs/HDFSAuditLogObject.java | 30 +
.../eagle/security/hdfs/HDFSAuditLogParser.java | 175 +
.../hdfs/entity/FileSensitivityAPIEntity.java | 52 +
.../security/hdfs/entity/FileStatusEntity.java | 176 +
.../entity/HDFSFileSystemResponseEntity.java | 48 +
.../entity/HDFSSecurityEntityRepository.java | 26 +
.../security/hdfs/entity/IPZoneEntity.java | 52 +
.../hive/entity/HiveResourceEntity.java | 104 +
.../HiveResourceSensitivityAPIEntity.java | 53 +
.../entity/HiveSecurityEntityRepository.java | 25 +
.../resolver/AbstractCommandResolver.java | 72 +
.../AbstractSensitivityTypeResolver.java | 82 +
.../AbstractResourceSensitivityPollingJob.java | 56 +
.../util/BadMetadataAccessConfigException.java | 30 +
.../eagle/security/util/ExternalDataCache.java | 43 +
.../eagle/security/util/ExternalDataJoiner.java | 104 +
.../security/util/JVMSingleQuartzScheduler.java | 51 +
.../crawler/audit/TestHDFSAuditLogParser.java | 40 -
.../crawler/audit/TestHDFSAuditLogParser.java | 40 +
.../hbase/HbaseAuditLogProcessorMain.java | 50 -
.../parse/HbaseAuditLogKafkaDeserializer.java | 65 -
.../hbase/parse/HbaseAuditLogObject.java | 28 -
.../hbase/parse/HbaseAuditLogParser.java | 146 -
...baseResourceSensitivityDataJoinExecutor.java | 95 -
.../HbaseResourceSensitivityPollingJob.java | 63 -
.../hbase/HbaseAuditLogProcessorMain.java | 50 +
.../parse/HbaseAuditLogKafkaDeserializer.java | 65 +
.../hbase/parse/HbaseAuditLogObject.java | 28 +
.../hbase/parse/HbaseAuditLogParser.java | 146 +
...baseResourceSensitivityDataJoinExecutor.java | 95 +
.../HbaseResourceSensitivityPollingJob.java | 66 +
.../src/main/resources/application.conf | 4 +-
.../security/hbase/TestHbaseAuditLogParser.java | 46 -
.../security/hbase/TestHbaseAuditLogParser.java | 46 +
.../hbase/HbaseMetadataBrowseWebResource.java | 145 -
.../hbase/HbaseMetadataBrowseWebResponse.java | 45 -
.../hbase/HbaseSensitivityResourceService.java | 80 -
.../hbase/dao/HbaseMetadataAccessConfig.java | 43 -
.../dao/HbaseMetadataAccessConfigDAOImpl.java | 61 -
.../hbase/dao/HbaseMetadataDAOImpl.java | 94 -
.../hbase/resolver/HbaseActionResolver.java | 36 -
.../hbase/resolver/HbaseMetadataResolver.java | 107 -
.../hbase/resolver/HbaseRequestResolver.java | 60 -
.../resolver/HbaseSensitivityTypeResolver.java | 38 -
.../hbase/HbaseMetadataBrowseWebResource.java | 145 +
.../hbase/HbaseMetadataBrowseWebResponse.java | 45 +
.../hbase/HbaseSensitivityResourceService.java | 80 +
.../hbase/dao/HbaseMetadataAccessConfig.java | 43 +
.../dao/HbaseMetadataAccessConfigDAOImpl.java | 61 +
.../hbase/dao/HbaseMetadataDAOImpl.java | 94 +
.../hbase/resolver/HbaseActionResolver.java | 36 +
.../hbase/resolver/HbaseMetadataResolver.java | 107 +
.../hbase/resolver/HbaseRequestResolver.java | 60 +
.../resolver/HbaseSensitivityTypeResolver.java | 38 +
.../hbase/TestHbaseMetadataResolver.java | 41 -
.../hbase/TestHbaseMetadataResolver.java | 41 +
.../FileSensitivityDataJoinExecutor.java | 85 -
.../auditlog/HdfsAuditLogKafkaDeserializer.java | 69 -
.../auditlog/HdfsAuditLogProcessorMain.java | 72 -
.../auditlog/IPZoneDataJoinExecutor.java | 63 -
.../auditlog/kafka/UserPartitioner.java | 33 -
.../timer/FileSensitivityPollingJob.java | 82 -
.../auditlog/timer/IPZonePollingJob.java | 83 -
.../security/auditlog/util/SimplifyPath.java | 53 -
.../FileSensitivityDataJoinExecutor.java | 85 +
.../auditlog/HdfsAuditLogKafkaDeserializer.java | 70 +
.../auditlog/HdfsAuditLogProcessorMain.java | 72 +
.../auditlog/IPZoneDataJoinExecutor.java | 65 +
.../auditlog/kafka/UserPartitioner.java | 33 +
.../timer/FileSensitivityPollingJob.java | 84 +
.../auditlog/timer/IPZonePollingJob.java | 84 +
.../security/auditlog/util/SimplifyPath.java | 53 +
.../src/main/resources/application.conf | 4 +-
.../auditlogtraining/util/TestSimplifyPath.java | 31 -
.../security/dataproc/TestIPZonePollingJob.java | 45 -
.../security/dataproc/TestOuterDataJoiner.java | 59 -
.../auditlogtraining/util/TestSimplifyPath.java | 31 +
.../security/dataproc/TestIPZonePollingJob.java | 45 +
.../security/dataproc/TestOuterDataJoiner.java | 59 +
.../service/security/hdfs/HDFSFileSystem.java | 190 -
.../security/hdfs/HDFSResourceAccessConfig.java | 45 -
.../security/hdfs/HDFSResourceConstants.java | 25 -
.../hdfs/HDFSResourceSensitivityDataJoiner.java | 151 -
.../hdfs/HDFSResourceSensitivityService.java | 101 -
.../security/hdfs/HDFSResourceUtils.java | 103 -
.../hdfs/resolver/HDFSCommandResolver.java | 72 -
.../hdfs/resolver/HDFSResourceResolver.java | 124 -
.../resolver/HDFSSensitivityTypeResolver.java | 75 -
.../rest/HDFSResourceWebRequestValidator.java | 38 -
.../hdfs/rest/HDFSResourceWebResource.java | 76 -
.../hdfs/rest/HDFSResourceWebResponse.java | 53 -
.../service/security/hdfs/HDFSFileSystem.java | 190 +
.../security/hdfs/HDFSResourceAccessConfig.java | 45 +
.../security/hdfs/HDFSResourceConstants.java | 25 +
.../hdfs/HDFSResourceSensitivityDataJoiner.java | 150 +
.../hdfs/HDFSResourceSensitivityService.java | 101 +
.../security/hdfs/HDFSResourceUtils.java | 103 +
.../hdfs/resolver/HDFSCommandResolver.java | 72 +
.../hdfs/resolver/HDFSResourceResolver.java | 124 +
.../resolver/HDFSSensitivityTypeResolver.java | 75 +
.../rest/HDFSResourceWebRequestValidator.java | 38 +
.../hdfs/rest/HDFSResourceWebResource.java | 76 +
.../hdfs/rest/HDFSResourceWebResponse.java | 53 +
.../hdfs/test/HDFSChildSensitivityTypeTest.java | 49 -
.../security/hdfs/test/HDFSFileSystemTest.java | 34 -
.../hdfs/test/HDFSResourceAccessConfigTest.java | 35 -
.../hdfs/test/HDFSResourceConfigAccessTest.java | 34 -
.../hdfs/test/HDFSResourceResolverTest.java | 36 -
.../HDFSResourceSensitivityServiceTest.java | 43 -
.../security/hdfs/test/HDFSResourceWebTest.java | 36 -
.../hdfs/test/HDFSChildSensitivityTypeTest.java | 49 +
.../security/hdfs/test/HDFSFileSystemTest.java | 34 +
.../hdfs/test/HDFSResourceAccessConfigTest.java | 35 +
.../hdfs/test/HDFSResourceConfigAccessTest.java | 34 +
.../hdfs/test/HDFSResourceResolverTest.java | 36 +
.../HDFSResourceSensitivityServiceTest.java | 42 +
.../security/hdfs/test/HDFSResourceWebTest.java | 35 +
.../BadHiveMetadataAccessConfigException.java | 27 -
.../hive/dao/HiveMetadataAccessConfig.java | 70 -
.../hive/dao/HiveMetadataAccessConfigDAO.java | 26 -
.../dao/HiveMetadataAccessConfigDAOImpl.java | 75 -
.../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 -
.../dao/HiveSensitivityMetadataDAOImpl.java | 81 -
.../hive/res/HiveMetadataBrowseWebResource.java | 145 -
.../hive/res/HiveMetadataBrowseWebResponse.java | 46 -
.../hive/resolver/HiveCommandResolver.java | 70 -
.../hive/resolver/HiveMetadataResolver.java | 114 -
.../resolver/HiveSensitivityTypeResolver.java | 73 -
.../BadHiveMetadataAccessConfigException.java | 27 +
.../hive/dao/HiveMetadataAccessConfig.java | 70 +
.../hive/dao/HiveMetadataAccessConfigDAO.java | 26 +
.../dao/HiveMetadataAccessConfigDAOImpl.java | 75 +
.../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 +
.../dao/HiveSensitivityMetadataDAOImpl.java | 81 +
.../hive/res/HiveMetadataBrowseWebResource.java | 145 +
.../hive/res/HiveMetadataBrowseWebResponse.java | 46 +
.../hive/resolver/HiveCommandResolver.java | 70 +
.../hive/resolver/HiveMetadataResolver.java | 114 +
.../resolver/HiveSensitivityTypeResolver.java | 73 +
.../java/TestHiveDataSourceConfigDAOImpl.java | 32 -
.../src/test/java/TestHiveMetadataDAO.java | 55 -
.../src/test/java/TestHiveSensitivityDAO.java | 32 -
.../hive/TestHiveDataSourceConfigDAOImpl.java | 32 +
.../security/hive/TestHiveMetadataDAO.java | 55 +
.../security/hive/TestHiveSensitivityDAO.java | 32 +
.../HiveJobRunningMonitoringMain.java | 54 -
...HiveJobRunningSourcedStormSpoutProvider.java | 79 -
.../jobrunning/HiveQueryParserExecutor.java | 146 -
.../JobConfigurationAdaptorExecutor.java | 73 -
.../security/hive/ql/HiveQLParserContent.java | 55 -
.../java/eagle/security/hive/ql/Parser.java | 346 --
...HiveResourceSensitivityDataJoinExecutor.java | 100 -
.../HiveResourceSensitivityPollingJob.java | 86 -
.../HiveJobRunningMonitoringMain.java | 54 +
...HiveJobRunningSourcedStormSpoutProvider.java | 79 +
.../jobrunning/HiveQueryParserExecutor.java | 148 +
.../JobConfigurationAdaptorExecutor.java | 73 +
.../security/hive/ql/HiveQLParserContent.java | 55 +
.../apache/eagle/security/hive/ql/Parser.java | 346 ++
...HiveResourceSensitivityDataJoinExecutor.java | 100 +
.../HiveResourceSensitivityPollingJob.java | 87 +
.../src/main/resources/application.conf | 4 +-
.../java/eagle/security/hive/ql/TestParser.java | 155 -
.../eagle/security/hive/ql/TestParser.java | 155 +
.../security/userprofile/UserPartitioner.java | 32 -
.../userprofile/UserProfileConstants.java | 37 -
.../security/userprofile/UserProfileUtils.java | 53 -
.../model/ScheduleCommandEntity.java | 73 -
.../model/UserActivityAggModelDeserializer.java | 52 -
.../model/UserActivityAggModelEntity.java | 86 -
.../model/UserCommandStatistics.java | 83 -
.../model/UserProfileEigenModelEntity.java | 203 -
.../model/UserProfileEntityRepository.java | 25 -
.../model/UserProfileKDEModelEntity.java | 128 -
.../userprofile/model/package-info.java | 20 -
.../security/userprofile/UserPartitioner.java | 32 +
.../userprofile/UserProfileConstants.java | 37 +
.../security/userprofile/UserProfileUtils.java | 53 +
.../model/ScheduleCommandEntity.java | 73 +
.../model/UserActivityAggModelDeserializer.java | 52 +
.../model/UserActivityAggModelEntity.java | 87 +
.../model/UserCommandStatistics.java | 83 +
.../model/UserProfileEigenModelEntity.java | 204 +
.../model/UserProfileEntityRepository.java | 25 +
.../model/UserProfileKDEModelEntity.java | 129 +
.../userprofile/model/package-info.java | 20 +
.../userprofile/model/AuditlogParser.scala | 54 -
.../userprofile/model/EntityConversion.scala | 27 -
.../model/UserActivityAggModel.scala | 28 -
.../model/UserProfileEigenModel.scala | 44 -
.../userprofile/model/UserProfileKDEModel.scala | 37 -
.../userprofile/model/UserProfileModel.scala | 22 -
.../userprofile/model/AuditlogParser.scala | 54 +
.../userprofile/model/EntityConversion.scala | 27 +
.../model/UserActivityAggModel.scala | 28 +
.../model/UserProfileEigenModel.scala | 44 +
.../userprofile/model/UserProfileKDEModel.scala | 37 +
.../userprofile/model/UserProfileModel.scala | 22 +
.../common/TestUserProfileUtils.java | 4 +-
.../eagle/security/userprofile/TimeWindow.java | 45 -
.../userprofile/UserActivityAggregator.java | 35 -
.../UserProfileAggregatorExecutor.java | 77 -
.../userprofile/UserProfileAnomalyDetector.java | 44 -
.../UserProfileDetectionBatchMain.java | 79 -
.../UserProfileDetectionConstants.java | 25 -
.../userprofile/UserProfileDetectionMain.java | 24 -
.../UserProfileDetectionStreamMain.java | 67 -
.../UserProfileMLAlgorithmEvaluator.java | 114 -
.../impl/AbstractUserProfileEigenEvaluator.java | 47 -
.../impl/AbstractUserProfileKDEEvaluator.java | 39 -
.../userprofile/impl/TimeWindowImpl.java | 87 -
.../impl/UserActivityAggregatorImpl.java | 166 -
.../impl/UserProfileAnomalyEigenEvaluator.java | 171 -
.../impl/UserProfileAnomalyKDEEvaluator.java | 138 -
.../eagle/security/userprofile/TimeWindow.java | 45 +
.../userprofile/UserActivityAggregator.java | 34 +
.../UserProfileAggregatorExecutor.java | 79 +
.../userprofile/UserProfileAnomalyDetector.java | 44 +
.../UserProfileDetectionBatchMain.java | 79 +
.../UserProfileDetectionConstants.java | 25 +
.../userprofile/UserProfileDetectionMain.java | 24 +
.../UserProfileDetectionStreamMain.java | 67 +
.../UserProfileMLAlgorithmEvaluator.java | 115 +
.../impl/AbstractUserProfileEigenEvaluator.java | 50 +
.../impl/AbstractUserProfileKDEEvaluator.java | 40 +
.../userprofile/impl/TimeWindowImpl.java | 87 +
.../impl/UserActivityAggregatorImpl.java | 169 +
.../impl/UserProfileAnomalyEigenEvaluator.java | 173 +
.../impl/UserProfileAnomalyKDEEvaluator.java | 142 +
....alert.policy.PolicyEvaluatorServiceProvider | 1 -
....alert.policy.PolicyEvaluatorServiceProvider | 1 +
.../src/main/resources/application-batch.conf | 4 +-
.../src/main/resources/application-stream.conf | 4 +-
.../userprofile/TestUserActivityAggregator.java | 85 -
.../TestUserProfileAnomalyEigenEvaluator.java | 96 -
.../userprofile/TestUserActivityAggregator.java | 84 +
.../TestUserProfileAnomalyEigenEvaluator.java | 98 +
....alert.policy.PolicyEvaluatorServiceProvider | 1 -
....alert.policy.PolicyEvaluatorServiceProvider | 1 +
.../eagle-security-userprofile/training/pom.xml | 2 +-
.../model/JavaUserProfileModeler.java | 30 -
.../model/eigen/UserProfileEigenModeler.java | 297 --
.../model/kde/UserProfileKDEModeler.java | 144 -
.../model/JavaUserProfileModeler.java | 30 +
.../model/eigen/UserProfileEigenModeler.java | 297 ++
.../model/kde/UserProfileKDEModeler.java | 147 +
.../userprofile/UserProfileJobFactory.scala | 31 -
.../userprofile/UserProfileTrainingApp.scala | 80 -
.../userprofile/UserProfileTrainingCLI.scala | 58 -
.../security/userprofile/daemon/Command.scala | 114 -
.../security/userprofile/daemon/Consumers.scala | 83 -
.../userprofile/daemon/Coordinator.scala | 58 -
.../security/userprofile/daemon/Producers.scala | 154 -
.../userprofile/daemon/SchedulePolicy.scala | 100 -
.../security/userprofile/daemon/Scheduler.scala | 62 -
.../userprofile/daemon/SchedulerContext.scala | 144 -
.../daemon/UserProfileCommandDao.scala | 90 -
.../security/userprofile/daemon/Utils.scala | 78 -
.../job/AuditLogTrainingSparkJob.scala | 157 -
.../job/UserProfileTrainingJob.scala | 64 -
.../userprofile/model/UserProfileContext.scala | 22 -
.../userprofile/model/UserProfileModeler.scala | 36 -
.../userprofile/sink/UserActivityAggSink.scala | 84 -
.../userprofile/sink/UserProfileModelSink.scala | 89 -
.../userprofile/UserProfileJobFactory.scala | 31 +
.../userprofile/UserProfileTrainingApp.scala | 80 +
.../userprofile/UserProfileTrainingCLI.scala | 58 +
.../security/userprofile/daemon/Command.scala | 116 +
.../security/userprofile/daemon/Consumers.scala | 83 +
.../userprofile/daemon/Coordinator.scala | 58 +
.../security/userprofile/daemon/Producers.scala | 154 +
.../userprofile/daemon/SchedulePolicy.scala | 100 +
.../security/userprofile/daemon/Scheduler.scala | 62 +
.../userprofile/daemon/SchedulerContext.scala | 143 +
.../daemon/UserProfileCommandDao.scala | 90 +
.../security/userprofile/daemon/Utils.scala | 77 +
.../job/AuditLogTrainingSparkJob.scala | 157 +
.../job/UserProfileTrainingJob.scala | 64 +
.../userprofile/model/UserProfileContext.scala | 22 +
.../userprofile/model/UserProfileModeler.scala | 36 +
.../userprofile/sink/UserActivityAggSink.scala | 84 +
.../userprofile/sink/UserProfileModelSink.scala | 89 +
.../model/UserProfileEigenModelerTest.java | 56 -
.../model/UserProfileKDEModelerTest.java | 54 -
.../model/UserProfileEigenModelerTest.java | 56 +
.../model/UserProfileKDEModelerTest.java | 55 +
.../security/userprofile/daemon/UtilsSpec.scala | 39 -
.../security/userprofile/daemon/UtilsSpec.scala | 39 +
....alert.policy.PolicyEvaluatorServiceProvider | 17 -
....alert.policy.PolicyEvaluatorServiceProvider | 17 +
.../security/auth/AuthenticationResource.java | 54 -
.../security/auth/AuthenticationResult.java | 47 -
.../security/auth/LogoutSuccessHandlerImpl.java | 47 -
.../service/security/auth/package-info.java | 23 -
.../profile/EagleServiceProfileInitializer.java | 41 -
.../pwdgen/BasicAuthenticationEncoder.java | 26 -
.../pwdgen/PasswordEncoderGenerator.java | 28 -
.../security/auth/AuthenticationResource.java | 54 +
.../security/auth/AuthenticationResult.java | 47 +
.../security/auth/LogoutSuccessHandlerImpl.java | 47 +
.../service/security/auth/package-info.java | 23 +
.../profile/EagleServiceProfileInitializer.java | 41 +
.../pwdgen/BasicAuthenticationEncoder.java | 26 +
.../pwdgen/PasswordEncoderGenerator.java | 28 +
.../src/main/resources/applicationContext.xml | 2 +-
.../src/main/resources/eagleSecurity.xml | 2 +-
.../src/main/webapp/WEB-INF/web.xml | 2 +-
1586 files changed, 71346 insertions(+), 71361 deletions(-)
----------------------------------------------------------------------