eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject [51/55] [abbrv] [partial] incubator-eagle git commit: [EAGLE-46] Rename package name as "org.apache.eagle"
Date Thu, 19 Nov 2015 10:47:58 GMT
[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 <hao@apache.org>
Authored: Thu Nov 19 16:50:07 2015 +0800
Committer: Hao Chen <hao@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(-)
----------------------------------------------------------------------




Mime
View raw message