eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject [04/51] [partial] incubator-eagle git commit: EAGLE-184 Migrate eagle website from https://github.com/eaglemonitoring/eaglemonitoring.github.io to document branch
Date Thu, 03 Mar 2016 18:09:37 GMT
http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/java/org/apache/eagle/example/persist/PersistTopoTestMain2.java
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/java/org/apache/eagle/example/persist/PersistTopoTestMain2.java b/eagle-examples/eagle-topology-example/src/main/java/org/apache/eagle/example/persist/PersistTopoTestMain2.java
deleted file mode 100644
index d9a7bbb..0000000
--- a/eagle-examples/eagle-topology-example/src/main/java/org/apache/eagle/example/persist/PersistTopoTestMain2.java
+++ /dev/null
@@ -1,60 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *    http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.eagle.example.persist;
-
-import org.apache.eagle.dataproc.impl.storm.StormSpoutProvider;
-import org.apache.eagle.datastream.ExecutionEnvironments;
-import org.apache.eagle.datastream.core.StorageType;
-import org.apache.eagle.datastream.core.StreamProducer;
-import org.apache.eagle.datastream.storm.StormExecutionEnvironment;
-import org.apache.eagle.partition.PartitionStrategy;
-
-import java.util.Arrays;
-
-/**
- * Created on 1/10/16.
- */
-public class PersistTopoTestMain2 {
-
-    public static void main(String[] args) {
-        System.setProperty("config.resource", "application.conf");// customize the application.conf
-        StormExecutionEnvironment env = ExecutionEnvironments.getStorm();
-        StormSpoutProvider provider = PersistTopoTestMain.createProvider(env.getConfig());
-        exec(env, provider);
-    }
-
-    private static void exec(StormExecutionEnvironment env, StormSpoutProvider provider) {
-        StreamProducer source = env.fromSpout(provider).withOutputFields(4).nameAs("kafkaMsgConsumer");
-        StreamProducer filter = source;
-
-        // "timestamp", "host", "cpu", "mem"
-        String cql = " define stream eagleQuery(eagleAlertContext object, timestamp long, host string, cpu int, mem long);"
-                + " @info(name='query')"
-                + " from eagleQuery#window.externalTime(timestamp, 10 min) "
-                + " select eagleAlertContext, min(timestamp) as starttime, avg(cpu) as avgCpu, avg(mem) as avgMem insert into tmp;";
-        StreamProducer aggregate = filter.aggregate(Arrays.asList("ealgeQuery"), cql, new PartitionStrategy() {
-            @Override
-            public int balance(String key, int buckNum) {
-                return 0;
-            }
-        });
-
-        StreamProducer persist = aggregate.persist("persistExecutor1", StorageType.KAFKA());
-
-        env.execute();
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/resources/add-notification-for-plugin-test.sh
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/resources/add-notification-for-plugin-test.sh b/eagle-examples/eagle-topology-example/src/main/resources/add-notification-for-plugin-test.sh
deleted file mode 100644
index e9288fa..0000000
--- a/eagle-examples/eagle-topology-example/src/main/resources/add-notification-for-plugin-test.sh
+++ /dev/null
@@ -1,50 +0,0 @@
-#!/bin/bash
-
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with`
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-CUR_DIR=$(dirname $0)
-source $CUR_DIR/../../../../../eagle-assembly/src/main/bin/eagle-env.sh
-
-##### delete email notification ##########
-echo ""
-echo "Importing policy ... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertDefinitionService" \
- -d '
- [
-     {
-       "prefix": "alertdef",
-       "tags": {
-         "site": "sandbox",
-         "dataSource": "testSpout",
-         "policyId": "pluginTestPolicy",
-         "alertExecutorId": "testExecutor",
-         "policyType": "siddhiCEPEngine"
-       },
-       "description": "pluginTest",
-       "policyDef": "{\"expression\":\"from testStream[(testAttribute == \\\"testValue\\\")] select * insert into outputStream;\",\"type\":\"siddhiCEPEngine\"}",
-       "notificationDef": "[{\"notificationType\":\"eagleStore\"},{\"subject\":\"just for test\",\"sender\":\"nobody@test.com\",\"recipients\":\"nobody@test.com\",\"flavor\":\"email\",\"id\":\"email_1\",\"tplFileName\":\"\"}]",
-       "remediationDef":"",
-       "enabled":true
-     }
- ]
- '
-
-## Finished
-echo ""
-echo "Finished initialization for NotificationPluginTest"
-
-exit 0

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/resources/application-plugintest.conf
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/resources/application-plugintest.conf b/eagle-examples/eagle-topology-example/src/main/resources/application-plugintest.conf
deleted file mode 100644
index b35abc8..0000000
--- a/eagle-examples/eagle-topology-example/src/main/resources/application-plugintest.conf
+++ /dev/null
@@ -1,59 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{
-  "envContextConfig" : {
-    "env" : "storm",
-    "mode" : "local",
-    "topologyName" : "pluginTest",
-    "stormConfigFile" : "persist-test-storm.yaml",
-    "parallelismConfig" : {
-      "testSpout" : 1,
-      "testExecutor*" : 1
-    }
-  },
-  "dataSourceConfig": {
-  },
-  "alertExecutorConfigs" : {
-     "testExecutor" : {
-       "parallelism" : 1,
-       "partitioner" : "org.apache.eagle.policy.DefaultPolicyPartitioner"
-       "needValidation" : "true"
-     }
-  },
-  "eagleProps" : {
-    "site" : "sandbox",
-    "application": "testSpout",
-  	"dataJoinPollIntervalSec" : 30,
-    "mailHost" : "mailHost.com",
-    "mailSmtpPort":"25",
-    "mailDebug" : "true",
-    "balancePartitionEnabled" : true,
-    #"partitionRefreshIntervalInMin" : 60,
-    #"kafkaStatisticRangeInMin" : 60,
-    "eagleService": {
-      "host": "localhost",
-      "port": 9099,
-      "username": "admin",
-      "password": "secret"
-    },
-    "readHdfsUserCommandPatternFrom" : "file"
-  },
-  "dynamicConfigSource" : {
-  	"enabled" : true,
-  	"initDelayMillis" : 0,
-  	"delayMillis" : 30000
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/resources/application.conf
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/resources/application.conf b/eagle-examples/eagle-topology-example/src/main/resources/application.conf
deleted file mode 100644
index 9629917..0000000
--- a/eagle-examples/eagle-topology-example/src/main/resources/application.conf
+++ /dev/null
@@ -1,86 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{
-  "envContextConfig" : {
-    "env" : "storm",
-    "mode" : "local",
-    "topologyName" : "persistTestTopology",
-    "stormConfigFile" : "persist-test-storm.yaml",
-    "parallelismConfig" : {
-      "kafkaMsgConsumer" : 1,
-      "hdfsAuditLogAlertExecutor*" : 1
-    }
-  },
-  "dataSourceConfig": {
-    "topic" : "persist_test_log",
-    "zkConnection" : "localhost:2181",
-    "zkConnectionTimeoutMS" : 15000,
-    "consumerGroupId" : "EagleConsumer",
-    "fetchSize" : 1048586,
-    "deserializerClass" : "org.apache.eagle.example.persist.MetricSerializer",
-    "transactionZKServers" : "localhost",
-    "transactionZKPort" : 2181,
-    "transactionZKRoot" : "/consumers",
-    "transactionStateUpdateMS" : 2000
-  },
-  "alertExecutorConfigs" : {
-     "hdfsAuditLogAlertExecutor" : {
-       "parallelism" : 1,
-       "partitioner" : "org.apache.eagle.policy.DefaultPolicyPartitioner"
-       "needValidation" : "true"
-     }
-  },
-  "persistExecutorConfigs" {
-    "persistExecutor1" : {
-      "kafka": {
-        "bootstrap_servers" : "www.xyz.com",
-        "topics" : {
-          "defaultOutput" : "downSampleOutput"
-        }
-      }
-    }
-  },
-  "aggregateExecutorConfigs" : {
-    "aggregateExecutor1" : {
-      "parallelism" : 1,
-      "partitioner" : "org.apache.eagle.policy.DefaultPolicyPartitioner"
-      "needValidation" : "true"
-    }
-  },
-  "eagleProps" : {
-    "site" : "sandbox",
-    "application": "persistTest",
-  	"dataJoinPollIntervalSec" : 30,
-    "mailHost" : "mailHost.com",
-    "mailSmtpPort":"25",
-    "mailDebug" : "true",
-    "balancePartitionEnabled" : true,
-    #"partitionRefreshIntervalInMin" : 60,
-    #"kafkaStatisticRangeInMin" : 60,
-    "eagleService": {
-      "host": "localhost",
-      "port": 9099,
-      "username": "admin",
-      "password": "secret"
-    },
-    "readHdfsUserCommandPatternFrom" : "file"
-  },
-  "dynamicConfigSource" : {
-  	"enabled" : true,
-  	"initDelayMillis" : 0,
-  	"delayMillis" : 30000
-  }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/resources/create-policy-for-plugin-test.sh
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/resources/create-policy-for-plugin-test.sh b/eagle-examples/eagle-topology-example/src/main/resources/create-policy-for-plugin-test.sh
deleted file mode 100644
index 3fd2752..0000000
--- a/eagle-examples/eagle-topology-example/src/main/resources/create-policy-for-plugin-test.sh
+++ /dev/null
@@ -1,99 +0,0 @@
-#!/bin/bash
-
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with`
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-CUR_DIR=$(dirname $0)
-source $CUR_DIR/../../../../../eagle-assembly/src/main/bin/eagle-env.sh
-
-#####################################################################
-#            Import stream metadata
-#####################################################################
-
-## AlertDataSource: data sources bound to sites
-echo "Importing AlertDataSourceService for persist... "
-
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertDataSourceService" \
-  -d '[{"prefix":"alertDataSource","tags":{"site" : "sandbox", "dataSource":"testSpout"}, "enabled": "true", "config" : " just some description", "desc":"pluginTest"}]'
-
-
-## AlertStreamService: alert streams generated from data source
-echo ""
-echo "Importing AlertStreamService for HDFS... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertStreamService" \
- -d '[{"prefix":"alertStream","tags":{"dataSource":"testSpout","streamName":"testStream"},"desc":"pluginTest"}]'
-
-## AlertExecutorService: what alert streams are consumed by alert executor
-echo ""
-echo "Importing AlertExecutorService for HDFS... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertExecutorService" \
- -d '[{"prefix":"alertExecutor","tags":{"dataSource":"testSpout","alertExecutorId":"testExecutor","streamName":"testStream"},"desc":"testStream->testExecutor"}]'
-
-## AlertStreamSchemaService: schema for event from alert stream
-echo ""
-echo "Importing AlertStreamSchemaService for HDFS... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
-"http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertStreamSchemaService" \
- -d '
- [
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "testSpout",
-          "streamName": "testStream",
-          "attrName": "testAttribute"
-       },
-       "attrDescription": "testAttribute",
-       "attrType": "string",
-       "category": "",
-       "attrValueResolver": ""
-    }
- ]
- '
-
-##### add policies ##########
-echo ""
-echo "Importing policy ... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertDefinitionService" \
- -d '
- [
-     {
-       "prefix": "alertdef",
-       "tags": {
-         "site": "sandbox",
-         "dataSource": "testSpout",
-         "policyId": "pluginTestPolicy",
-         "alertExecutorId": "testExecutor",
-         "policyType": "siddhiCEPEngine"
-       },
-       "description": "pluginTest",
-       "policyDef": "{\"expression\":\"from testStream[(testAttribute == \\\"testValue\\\")] select * insert into outputStream;\",\"type\":\"siddhiCEPEngine\"}",
-       "dedupeDef": "{\"alertDedupIntervalMin\":0,\"emailDedupIntervalMin\":1440}",
-       "notificationDef": "[{\"subject\":\"just for test\",\"sender\":\"nobody@test.com\",\"recipients\":\"nobody@test.com\",\"flavor\":\"email\",\"id\":\"email_1\",\"tplFileName\":\"\"}]",
-       "remediationDef":"",
-       "enabled":true
-     }
- ]
- '
-
-## Finished
-echo ""
-echo "Finished initialization for NotificationPluginTest"
-
-exit 0

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/resources/delete-email-for-plugin-test.sh
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/resources/delete-email-for-plugin-test.sh b/eagle-examples/eagle-topology-example/src/main/resources/delete-email-for-plugin-test.sh
deleted file mode 100644
index 30d277f..0000000
--- a/eagle-examples/eagle-topology-example/src/main/resources/delete-email-for-plugin-test.sh
+++ /dev/null
@@ -1,50 +0,0 @@
-#!/bin/bash
-
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with`
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-CUR_DIR=$(dirname $0)
-source $CUR_DIR/../../../../../eagle-assembly/src/main/bin/eagle-env.sh
-
-##### delete email notification ##########
-echo ""
-echo "Importing policy ... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertDefinitionService" \
- -d '
- [
-     {
-       "prefix": "alertdef",
-       "tags": {
-         "site": "sandbox",
-         "dataSource": "testSpout",
-         "policyId": "pluginTestPolicy",
-         "alertExecutorId": "testExecutor",
-         "policyType": "siddhiCEPEngine"
-       },
-       "description": "pluginTest",
-       "policyDef": "{\"expression\":\"from testStream[(testAttribute == \\\"testValue\\\")] select * insert into outputStream;\",\"type\":\"siddhiCEPEngine\"}",
-       "notificationDef": "[{\"subject\":\"just for test\",\"sender\":\"nobody@test.com\",\"recipients\":\"nobody@test.com\",\"flavor\":\"email\",\"id\":\"email_1\",\"tplFileName\":\"\"}]",
-       "remediationDef":"",
-       "enabled":true
-     }
- ]
- '
-
-## Finished
-echo ""
-echo "Finished initialization for NotificationPluginTest"
-
-exit 0

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/resources/log4j.properties
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/resources/log4j.properties b/eagle-examples/eagle-topology-example/src/main/resources/log4j.properties
deleted file mode 100644
index 07f8402..0000000
--- a/eagle-examples/eagle-topology-example/src/main/resources/log4j.properties
+++ /dev/null
@@ -1,40 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-log4j.rootLogger=INFO, stdout, DRFA
-
-eagle.log.dir=./logs
-eagle.log.file=eagle.log
-
-
-#log4j.logger.org.apache.eagle.security.auditlog.IPZoneDataJoinExecutor=DEBUG
-#log4j.logger.org.apache.eagle.security.auditlog.FileSensitivityDataJoinExecutor=DEBUG
-log4j.logger.org.apache.eagle.security.auditlog.HdfsUserCommandReassembler=DEBUG
-#log4j.logger.org.apache.eagle.executor.AlertExecutor=DEBUG
-# standard output
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=%d{ISO8601} %p [%t] %c{2}[%L]: %m%n
-
-# Daily Rolling File Appender
-log4j.appender.DRFA=org.apache.log4j.DailyRollingFileAppender
-log4j.appender.DRFA.File=${eagle.log.dir}/${eagle.log.file}
-log4j.appender.DRFA.DatePattern=yyyy-MM-dd
-## 30-day backup
-# log4j.appender.DRFA.MaxBackupIndex=30
-log4j.appender.DRFA.layout=org.apache.log4j.PatternLayout
-
-# Pattern format: Date LogLevel LoggerName LogMessage
-log4j.appender.DRFA.layout.ConversionPattern=%d{ISO8601} %p [%t] %c{2}[%L]: %m%n
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/resources/persist-test-topo-init.sh
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/resources/persist-test-topo-init.sh b/eagle-examples/eagle-topology-example/src/main/resources/persist-test-topo-init.sh
deleted file mode 100644
index 5805cf3..0000000
--- a/eagle-examples/eagle-topology-example/src/main/resources/persist-test-topo-init.sh
+++ /dev/null
@@ -1,194 +0,0 @@
-#!/bin/bash
-
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with`
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-source $(dirname $0)/eagle-env.sh
-eagle_bin=$EAGLE_HOME/bin
-
-#####################################################################
-#            Import stream metadata for HDFS
-#####################################################################
-
-## AlertDataSource: data sources bound to sites
-echo "Importing AlertDataSourceService for persist... "
-
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertDataSourceService" \
-  -d '[{"prefix":"alertDataSource","tags":{"site" : "sandbox", "dataSource":"persistTest"}, "enabled": "true", "config" : " just some description", "desc":"persistTest"}]'
-
-
-## AlertStreamService: alert streams generated from data source
-echo ""
-echo "Importing AlertStreamService for HDFS... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertStreamService" \
- -d '[{"prefix":"alertStream","tags":{"dataSource":"persistTest","streamName":"persistTestEventStream"},"desc":"persistTest metrics"}]'
-
-## AlertExecutorService: what alert streams are consumed by alert executor
-echo ""
-echo "Importing AlertExecutorService for HDFS... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertExecutorService" \
- -d '[{"prefix":"alertExecutor","tags":{"dataSource":"persistTest","alertExecutorId":"aggregateExecutor1","streamName":"persistTestEventStream"},"desc":"aggregate executor for persist test log event stream"}]'
-
-## AlertStreamSchemaService: schema for event from alert stream
-echo ""
-echo "Importing AlertStreamSchemaService for HDFS... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
-"http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AlertStreamSchemaService" \
- -d '
- [
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "src"
-       },
-       "attrDescription": "source directory or file, such as /tmp",
-       "attrType": "string",
-       "category": "",
-       "attrValueResolver": "org.apache.eagle.service.security.hdfs.resolver.HDFSResourceResolver"
-    },
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "dst"
-       },
-       "attrDescription": "destination directory, such as /tmp",
-       "attrType": "string",
-       "category": "",
-       "attrValueResolver": "org.apache.eagle.service.security.hdfs.resolver.HDFSResourceResolver"
-    },
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "host"
-       },
-       "attrDescription": "hostname, such as localhost",
-       "attrType": "string",
-       "category": "",
-       "attrValueResolver": ""
-    },
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "timestamp"
-       },
-       "attrDescription": "milliseconds of the datetime",
-       "attrType": "long",
-       "category": "",
-       "attrValueResolver": ""
-    },
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "allowed"
-       },
-       "attrDescription": "true, false or none",
-       "attrType": "bool",
-       "category": "",
-       "attrValueResolver": ""
-    },
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "user"
-       },
-       "attrDescription": "process user",
-       "attrType": "string",
-       "category": "",
-       "attrValueResolver": ""
-    },
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "cmd"
-       },
-       "attrDescription": "file/directory operation, such as getfileinfo, open, listStatus and so on",
-       "attrType": "string",
-       "category": "",
-       "attrValueResolver": "org.apache.eagle.service.security.hdfs.resolver.HDFSCommandResolver"
-    },
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "sensitivityType"
-       },
-       "attrDescription": "mark such as AUDITLOG, SECURITYLOG",
-       "attrType": "string",
-       "category": "",
-       "attrValueResolver": "org.apache.eagle.service.security.hdfs.resolver.HDFSSensitivityTypeResolver"
-    },
-    {
-       "prefix": "alertStreamSchema",
-       "tags": {
-          "dataSource": "persistTest",
-          "streamName": "persistTestEventStream",
-          "attrName": "securityZone"
-       },
-       "attrDescription": "",
-       "attrType": "string",
-       "category": "",
-       "attrValueResolver": ""
-    }
- ]
- '
-
-##### add policies ##########
-echo ""
-echo "Importing AlertStreamSchemaService for HDFS... "
-curl -u ${EAGLE_SERVICE_USER}:${EAGLE_SERVICE_PASSWD} -X POST -H 'Content-Type:application/json' \
- "http://${EAGLE_SERVICE_HOST}:${EAGLE_SERVICE_PORT}/eagle-service/rest/entities?serviceName=AggregateDefinitionService" \
- -d '
- [
-     {
-       "prefix": "aggregatedef",
-       "tags": {
-         "site": "sandbox",
-         "dataSource": "persistTest",
-         "policyId": "persitTestPolicy1",
-         "executorId": "aggregateExecutor1",
-         "policyType": "siddhiCEPEngine"
-       },
-       "description": "persistetest",
-       "policyDef": "{\"expression\":\"from persistTestEventStream[(logLevel == 'ERROR')] select * insert into outputStream;\",\"type\":\"siddhiCEPEngine\"}",
-       "enabled": true
-     }
- ]
- '
-
-
-
- ## Finished
-echo ""
-echo "Finished initialization for eagle topology"
-
-exit 0

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/eagle-topology-example/src/main/resources/persit-test-storm.yaml
----------------------------------------------------------------------
diff --git a/eagle-examples/eagle-topology-example/src/main/resources/persit-test-storm.yaml b/eagle-examples/eagle-topology-example/src/main/resources/persit-test-storm.yaml
deleted file mode 100644
index a68a323..0000000
--- a/eagle-examples/eagle-topology-example/src/main/resources/persit-test-storm.yaml
+++ /dev/null
@@ -1,18 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-topology.workers: 1
-topology.acker.executors: 1
-topology.tasks: 1
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-examples/pom.xml
----------------------------------------------------------------------
diff --git a/eagle-examples/pom.xml b/eagle-examples/pom.xml
deleted file mode 100644
index 486ab2d..0000000
--- a/eagle-examples/pom.xml
+++ /dev/null
@@ -1,35 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<!--
-  ~ Licensed to the Apache Software Foundation (ASF) under one or more
-  ~ contributor license agreements.  See the NOTICE file distributed with
-  ~ this work for additional information regarding copyright ownership.
-  ~ The ASF licenses this file to You under the Apache License, Version 2.0
-  ~ (the "License"); you may not use this file except in compliance with
-  ~ the License.  You may obtain a copy of the License at
-  ~
-  ~    http://www.apache.org/licenses/LICENSE-2.0
-  ~
-  ~ Unless required by applicable law or agreed to in writing, software
-  ~ distributed under the License is distributed on an "AS IS" BASIS,
-  ~ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-  ~ See the License for the specific language governing permissions and
-  ~ limitations under the License.
-  -->
-<project xmlns="http://maven.apache.org/POM/4.0.0"
-         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <parent>
-        <artifactId>eagle-parent</artifactId>
-        <groupId>eagle</groupId>
-        <version>0.3.0</version>
-    </parent>
-    <modelVersion>4.0.0</modelVersion>
-
-    <artifactId>eagle-examples</artifactId>
-    <packaging>pom</packaging>
-    <modules>
-        <module>eagle-topology-example</module>
-    </modules>
-
-
-</project>

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/.gitignore
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/.gitignore b/eagle-external/eagle-ambari/.gitignore
deleted file mode 100644
index a4c0e46..0000000
--- a/eagle-external/eagle-ambari/.gitignore
+++ /dev/null
@@ -1,3 +0,0 @@
-**/*.zip
-**/.hash
-**/*.pyc

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/README.md
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/README.md b/eagle-external/eagle-ambari/README.md
deleted file mode 100644
index c7b0a58..0000000
--- a/eagle-external/eagle-ambari/README.md
+++ /dev/null
@@ -1,47 +0,0 @@
-<!--
-{% comment %}
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-# 
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-{% endcomment %}
--->
-
-eagle-ambari-plugin
-===================
-
-Requirements
-------------
-1. Ambari `2.2.4` (has problems for higher version)
-
-Installation
-------------
-1. Download certain version of eagle release package and install under to `/usr/hdp/current/eagle`
-2. Execute ambari install
-
-        ./bin/eagle-ambari.sh install
-
-Uninstallation
-------------
-1. Uninstall services from amabri cluster
-
-        ./bin/eagle-ambari.sh uninstall
-
-Usage
------
-[https://wiki.vip.xyz.com/display/GDI/Eagle+in+Ambari](https://wiki.vip.xyz.com/display/GDI/Eagle+in+Ambari)
-
-Reference
----------
-* [Ambari: Create and Add the Service](https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=38571133#Overview\(Ambari1.5.0orlater\)-CreateandAddtheService)
-* [Quick links for custom services](https://issues.apache.org/jira/browse/AMBARI-11268)

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/bin/eagle-ambari.sh
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/bin/eagle-ambari.sh b/eagle-external/eagle-ambari/bin/eagle-ambari.sh
deleted file mode 100755
index d392e61..0000000
--- a/eagle-external/eagle-ambari/bin/eagle-ambari.sh
+++ /dev/null
@@ -1,215 +0,0 @@
-#!/bin/bash
-
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-# Eagle Ambari Plugin
-#
-# Author: hchen9@xyz.com
-# Version: 0.0.1
-#
-# Plan:
-# 1. Implement create service through REST API: https://cwiki.apache.org/confluence/display/AMBARI/Adding+a+New+Service+to+an+Existing+Cluster
-# 2. Integrate with ambari configuration
-
-AMBARI_HOST=localhost
-AMBARI_PORT=8080
-AMBARI_CLUSTER_NAME=Sandbox
-AMBARI_USER=admin
-AMBARI_PASSWORD=admin
-
-EAGLE_VERSION=0.0.1
-HDP_VERSION=2.0.6
-
-AMBARI_SERVER_HOME=/var/lib/ambari-server/
-AMBARI_EAGLE_STACK_DIR=/var/lib/ambari-server/resources/stacks/HDP/${HDP_VERSION}/services/EAGLE/
-AMBARI_EAGLE_COMMON_DIR=/var/lib/ambari-server/resources/common-services/EAGLE/${EAGLE_VERSION}/
-DEFAULT_EAGLE_HOME=/usr/hdp/current/eagle
-AMBARI_SERVER_APP_JS=/usr/lib/ambari-server/web/javascripts/app.js.gz
-
-cd `dirname $0`/../
-
-function usage() {
-	echo "Usage: $0 [options] {start|stop|install|uninstall}"
-
-	echo ""
-	echo "Eagle Version: ${EAGLE_VERSION} HDP Version: ${HDP_VERSION}"
-	echo ""
-	echo "Commands:"
-	echo "  start           Start EAGLE components in Ambari"
-	echo "  stop            Stop EAGLE components in Ambari"
-	echo "  install         Install EAGLE components into Ambari"
-	echo "  uninstall       Uninstall EAGLE components from from Ambari"
-	echo "Options:"
-	echo "  --host          Ambari server host, default: localhost"
-	echo "  --port          Ambari server port, default: 8080"
-	echo "  --cluster       Ambari cluster name, default: Sandbox"
-	echo "  --user          Ambari account username, default: admin"
-	echo "  --password      Ambari account password, default: admin"
-	echo ""
-	exit 1
-}
-
-function install(){
-	if [ -z "$EAGLE_HOME" ];then
-		EAGLE_HOME=$DEFAULT_EAGLE_HOME
-	else
-		echo "EAGLE_HOME: $EAGLE_HOME"
-	fi
-
-	if [ ! -e $EAGLE_HOME ]; then
-	    echo "Failure: ${EAGLE_HOME} not exists, please download latest eagle package and install to ${EAGLE_HOME}"
-	    exit 1
-	fi
-
-	if [ ! -e $AMBARI_SERVER_HOME ];then
-	    echo "Failure: $AMBARI_SERVER_HOME not exists, maybe because Ambari server is not installed"
-	    exit 1
-	fi
-
-	echo "Install EAGLE Ambari Plugin"
-	# 1. Install EAGLE service into /var/lib/ambari-server/resources/stacks/HDP/2.0.6/services/EAGLE/
-	echo "> Installing $AMBARI_EAGLE_STACK_DIR"
-	if [ -e $AMBARI_EAGLE_STACK_DIR ];then
-	    echo "${AMBARI_EAGLE_STACK_DIR} already exists, override ..."
-	    rm -rf $AMBARI_EAGLE_STACK_DIR
-	fi
-
-    mkdir -p $AMBARI_EAGLE_STACK_DIR
-    cp lib/metainfo.xml $AMBARI_EAGLE_STACK_DIR
-
-	# 2. Install EAGLE package into /var/lib/ambari-server/resources/common-services/EAGLE/0.0.1/
-	echo "> Installing $AMBARI_EAGLE_COMMON_DIR"
-	if [ -e $AMBARI_EAGLE_COMMON_DIR ];then
-	    echo "${AMBARI_EAGLE_COMMON_DIR} already exists, override ..."
-    fi
-
-    mkdir -p $AMBARI_EAGLE_COMMON_DIR
-    cp -rf lib/EAGLE/* $AMBARI_EAGLE_COMMON_DIR
-
-	# 3. Install eagle quick links
-	echo "> Installing eagle quick links"
-	cp lib/EAGLE/package/patches/app.js.gz $AMBARI_SERVER_APP_JS
-
-	# create
-	echo ""
-
-	which ambari-server >/dev/null 2>&1
-	if [ $? == 0 ];then
-		echo "Restarting ambari server"
-		ambari-server restart
-		echo "Congratulations! you almost finish, please add EAGLE through Ambari UI"
-	else
-		echo "Congratulations! you almost finish, please restart ambari server by 'ambari-sever restart' and add EAGLE through Ambari UI"
-	fi
-
-	exit 0
-}
-
-function uninstall(){
-	echo "Stopping EAGLE"
-	echo ""
-	curl -u $AMBARI_USER:$AMBARI_PASSWORD -i -H 'X-Requested-By: ${AMBARI_USER}' -X PUT -d '{"RequestInfo": {"context" :"Stop EAGLE via REST"}, "Body": {"ServiceInfo": {"state": "INSTALLED"}}}' http://${AMBARI_HOST}:${AMBARI_PORT}/api/v1/clusters/${AMBARI_CLUSTER_NAME}/services/EAGLE
-
-	echo "Uninstalling EAGLE"
-	curl -H "X-Requested-By: $AMBARI_USER" -u $AMBARI_USER:$AMBARI_PASSWORD -X DELETE  http://${AMBARI_HOST}:${AMBARI_PORT}/api/v1/clusters/${AMBARI_CLUSTER_NAME}/services/EAGLE
-
-	echo "Finished to uninstall EAGLE from Ambari"
-}
-
-function create(){
-	# TODO: Fix bug in service creation
-
-	echo "WARNING: Creating EAGLE service in Ambari, which still has problem"
-	echo ""
-	curl -u $AMBARI_USER:$AMBARI_PASSWORD -i -H 'X-Requested-By: ${AMBARI_USER}' -i -X POST -d '{"ServiceInfo":{"service_name":"EAGLE"}}' http://${AMBARI_HOST}:${AMBARI_PORT}/api/v1/clusters/${AMBARI_CLUSTER_NAME}/services
-	curl -u $AMBARI_USER:$AMBARI_PASSWORD -i -H 'X-Requested-By: ${AMBARI_USER}' -i -X POST -d '{"components":[{"ServiceComponentInfo":{"component_name":"EAGLE_SERVICE"}},{"ServiceComponentInfo":{"component_name":"EAGLE_TOPOLOGY"}}]}' http://${AMBARI_HOST}:${AMBARI_PORT}/api/v1/clusters/${AMBARI_CLUSTER_NAME}/services?ServiceInfo/service_name=EAGLE
-	curl -u $AMBARI_USER:$AMBARI_PASSWORD -i -H 'X-Requested-By: ${AMBARI_USER}' -X PUT -d '{"RequestInfo": {"context" :"Installing EAGLE via REST", "operation_level":{"level":"CLUSTER","cluster_name":"$AMABRI_CLUSTER_NAME"}}, "Body": {"ServiceInfo": {"state": "INSTALLED"}}}' "http://${AMBARI_HOST}:${AMBARI_PORT}/api/v1/clusters/${AMBARI_CLUSTER_NAME}/services?ServiceInfo/service_name.in(EAGLE)"
-}
-
-function start(){
-	echo "Starting EAGLE"
-	echo ""
-	curl -u $AMBARI_USER:$AMBARI_PASSWORD -i -H 'X-Requested-By: ${AMBARI_USER}' -X PUT -d '{"RequestInfo": {"context" :"Start EAGLE via REST"}, "Body": {"ServiceInfo": {"state": "STARTED"}}}' http://${AMBARI_HOST}:${AMBARI_PORT}/api/v1/clusters/${AMBARI_CLUSTER_NAME}/services/EAGLE
-}
-
-function stop(){
-	echo "Stopping EAGLE"
-	echo ""
-	curl -u $AMBARI_USER:$AMBARI_PASSWORD -i -H 'X-Requested-By: ${AMBARI_USER}' -X PUT -d '{"RequestInfo": {"context" :"Stop EAGLE via REST"}, "Body": {"ServiceInfo": {"state": "INSTALLED"}}}' http://${AMBARI_HOST}:${AMBARI_PORT}/api/v1/clusters/${AMBARI_CLUSTER_NAME}/services/EAGLE
-}
-
-case $1 in
-"--host")
-	if [ $# -lt 2 ]; then
-        usage
-        exit 1
-     fi
-	 AMBARI_HOST=$2
-     shift 2
-     ;;
-"--port")
-	if [ $# -lt 2 ]; then
-        usage
-        exit 1
-     fi
-	 AMBARI_PORT=$2
-     shift 2
-     ;;
-"--cluster")
-	if [ $# -lt 2 ]; then
-        usage
-        exit 1
-     fi
-	 AMBARI_CLUSTER=$2
-     shift 2
-     ;;
-"--user")
-	if [ $# -lt 2 ]; then
-        usage
-        exit 1
-     fi
-	 AMBARI_USER=$2
-     shift 2
-     ;;
-"--password")
-	if [ $# -lt 2 ]; then
-        usage
-        exit 1
-     fi
-	 AMBARI_PASSWORD=$2
-     shift 2
-     ;;
-"install")
-	install
-	exit
-	;;
-"uninstall")
-	uninstall
-	exit
-	;;
-"start")
-	start
-	exit
-	;;
-"stop")
-	stop
-	exit
-	;;
-*)
-	usage
-	exit 1
-	;;
-esac

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/configuration/application.conf
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/configuration/application.conf b/eagle-external/eagle-ambari/lib/EAGLE/configuration/application.conf
deleted file mode 100644
index 9caef36..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/configuration/application.conf
+++ /dev/null
@@ -1,77 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-{
-  "deployInstanceIdentifier" : {
-    "programId": "hdfsAuditLogMonitoring"
-  },
-  "envContextConfig" : {
-    "env" : "storm",
-    "mode" : "cluster",
-    "topologyName" : "auditLogProcessTology",
-    "stormConfigFile" : "storm.yaml.1",
-    "parallelismConfig" : {
-      "msgConsumer" : 2,
-      "downsampling" : 3
-    }
-  },
-  "dataSourceConfig": {
-    "flavor" : "stormkafka",
-    "topic" : "hdfs_audit_log",
-    "zkConnection" : "localhost:2181",
-    "zkConnectionTimeoutMS" : 15000,
-    "consumerGroupId" : "EagleConsumer",
-    "fetchSize" : 1048586,
-    "deserializerClass" : "eagle.security.auditlog.AuditLogKafkaDeserializer",
-    "transactionZKServers" : "localhost",
-    "transactionZKPort" : 2181,
-    "transactionZKRoot" : "/brokers/topics",
-    "transactionStateUpdateMS" : 2000
-  },
-  "alertExecutorConfigs" : {
-     "hdfsAuditLogAlertExecutor" : {
-       "parallelism" : 2,
-       "partitioner" : "eagle.alert.policy.DefaultPolicyPartitioner",
-       "sourceStreams" : ["hdfsAuditLogEventStream"]
-     }
-  },
-  "eagleProps" : {
-  	"ipLocationLoadFrom" : "jmx",
-  	"namenodeUrl" : "https://dc1-nn.vip.xyz.com:50070",
-  	"ipLocationLoadIntervalSeconds" : "300",
-    "eagleService": {
-      "host": "localhost",
-      "port": 9099,
-      "username": "admin",
-      "password": "secret"
-    }
-  },
-  "metadataJoinConfigs" : {
-  	"ipZoneJoin" : {
-  	   "ipLocationLoadFrom" : "jmx",
-  	   "namenodeUrl" : "https://dc1-nn.vip.xyz.com:50070",
-  	   "ipLocationLoadIntervalSeconds" : "300"
-  	},
-  	"fileMetadataJoin" : {
-  	
-  	}
-  },
-  "dynamicConfigSource" : {
-  	"enabled" : true,
-  	"initDelayMillis" : 0,
-  	"delayMillis" : 30000,
-  	"ignoreDeleteFromSource" : true
-  }
-}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/configuration/eagle-env.sh
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/configuration/eagle-env.sh b/eagle-external/eagle-ambari/lib/EAGLE/configuration/eagle-env.sh
deleted file mode 100644
index 1913bdd..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/configuration/eagle-env.sh
+++ /dev/null
@@ -1,15 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-# 
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/configuration/eagle-service.conf
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/configuration/eagle-service.conf b/eagle-external/eagle-ambari/lib/EAGLE/configuration/eagle-service.conf
deleted file mode 100644
index cb374bd..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/configuration/eagle-service.conf
+++ /dev/null
@@ -1,25 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-# 
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-env=test
-
-eagle.storage.type=hbase
-
-table.name.prefixed.with.environment=false
-
-### begin hbase configuration
-hbase.zookeeper.quorum=127.0.0.1
-hbase.zookeeper.property.clientPort=2181
-### end hbase configuration

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/configuration/log4j.properties
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/configuration/log4j.properties b/eagle-external/eagle-ambari/lib/EAGLE/configuration/log4j.properties
deleted file mode 100644
index 25331ab..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/configuration/log4j.properties
+++ /dev/null
@@ -1,35 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one or more
-# contributor license agreements.  See the NOTICE file distributed with
-# this work for additional information regarding copyright ownership.
-# The ASF licenses this file to You under the Apache License, Version 2.0
-# (the "License"); you may not use this file except in compliance with
-# the License.  You may obtain a copy of the License at
-#
-#    http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-log4j.rootLogger=INFO, stdout
-
- eagle.log.dir=../logs
- eagle.log.file=eagle.log
-
-# standard output
-log4j.appender.stdout=org.apache.log4j.ConsoleAppender
-log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
-log4j.appender.stdout.layout.ConversionPattern=%d{ISO8601} %p [%t] %c{2}[%L]: %m%n
-
-# Daily Rolling File Appender
- log4j.appender.DRFA=org.apache.log4j.DailyRollingFileAppender
- log4j.appender.DRFA.File=${eagle.log.dir}/${eagle.log.file}
- log4j.appender.DRFA.DatePattern=.yyyy-MM-dd
-## 30-day backup
-# log4j.appender.DRFA.MaxBackupIndex=30
- log4j.appender.DRFA.layout=org.apache.log4j.PatternLayout
-
-# Pattern format: Date LogLevel LoggerName LogMessage
-log4j.appender.DRFA.layout.ConversionPattern=%d{ISO8601} %p [%t] %c{2}[%L]: %m%n
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/metainfo.xml
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/metainfo.xml b/eagle-external/eagle-ambari/lib/EAGLE/metainfo.xml
deleted file mode 100644
index 3f03377..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/metainfo.xml
+++ /dev/null
@@ -1,180 +0,0 @@
-<?xml version="1.0"?>
-<!--
-   Licensed to the Apache Software Foundation (ASF) under one or more
-   contributor license agreements.  See the NOTICE file distributed with
-   this work for additional information regarding copyright ownership.
-   The ASF licenses this file to You under the Apache License, Version 2.0
-   (the "License"); you may not use this file except in compliance with
-   the License.  You may obtain a copy of the License at
-
-       http://www.apache.org/licenses/LICENSE-2.0
-
-   Unless required by applicable law or agreed to in writing, software
-   distributed under the License is distributed on an "AS IS" BASIS,
-   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-   See the License for the specific language governing permissions and
-   limitations under the License.
--->
-
-<metainfo>
-    <schemaVersion>2.0</schemaVersion>
-    <services>
-        <service>
-            <name>EAGLE</name>
-            <displayName>Eagle</displayName>
-            <comment>Eagle monitoring framework to secure hadoop platform in realtime</comment>
-            <version>0.0.1</version>
-            <components>
-                <component>
-                    <!-- TODO: fix the tricky walk-around in order to make sure components keep in order, as ambari execute components by alphabetical order -->
-                    <name>0_EAGLE_SERVICE</name>
-                    <displayName>Eagle Server</displayName>
-                    <category>MASTER</category>
-                    <cardinality>1</cardinality>
-                    <versionAdvertised>true</versionAdvertised>
-                    <commandScript>
-                        <script>scripts/eagle_service.py</script>
-                        <scriptType>PYTHON</scriptType>
-                        <timeout>600</timeout>
-                    </commandScript>
-                    <configFiles>
-                        <configFile>
-                            <type>conf</type>
-                            <fileName>eagle-service.conf</fileName>
-                            <dictionaryName>eagle-service</dictionaryName>
-                        </configFile>
-                    </configFiles>
-                </component>
-                           
-                <component>
-                    <name>EAGLE_DAM_HDFS_TOPOLOGY</name>
-                    <displayName>Eagle DAM HDFS</displayName>
-                    <category>MASTER</category>
-                    <cardinality>1+</cardinality>
-                    <versionAdvertised>true</versionAdvertised>
-                    <commandScript>
-                        <script>scripts/eagle_hdfs_topology.py</script>
-                        <scriptType>PYTHON</scriptType>
-                        <timeout>600</timeout>
-                    </commandScript>
-                    <configFiles>
-                        <configFile>
-                            <type>conf</type>
-                            <fileName>sandbox-hdfsAuditLog-application.conf</fileName>
-                            <dictionaryName>hdfsAuditLog</dictionaryName>
-                        </configFile>
-                    </configFiles>
-                </component>                
-
-                <component>
-                    <name>EAGLE_DAM_HIVE_TOPOLOGY</name>
-                    <displayName>Eagle DAM Hive</displayName>
-                    <category>MASTER</category>
-                    <cardinality>1+</cardinality>
-                    <versionAdvertised>true</versionAdvertised>
-                    <commandScript>
-                        <script>scripts/eagle_hive_topology.py</script>
-                        <scriptType>PYTHON</scriptType>
-                        <timeout>600</timeout>
-                    </commandScript>
-                    <configFiles>
-                        <configFile>
-                            <type>conf</type>
-                            <fileName>sandbox-hiveQueryLog-application.conf</fileName>
-                            <dictionaryName>hiveQueryLog</dictionaryName>
-                        </configFile>
-                    </configFiles>
-                </component>
-
-                <component>
-                    <name>EAGLE_USERPROFILE_TOPOLOGY</name>
-                    <displayName>Eagle UserProfile</displayName>
-                    <category>MASTER</category>
-                    <cardinality>1+</cardinality>
-                    <versionAdvertised>true</versionAdvertised>
-                    <commandScript>
-                        <script>scripts/eagle_userprofile_topology.py</script>
-                        <scriptType>PYTHON</scriptType>
-                        <timeout>600</timeout>
-                    </commandScript>
-                    <configFiles>
-                        <configFile>
-                            <type>conf</type>
-                            <fileName>sandbox-userprofile-application.conf</fileName>
-                            <dictionaryName>hiveQueryLog</dictionaryName>
-                        </configFile>
-                    </configFiles>
-                </component>
-
-                <component>
-                    <name>EAGLE_USERPROFILE_DAEMON</name>
-                    <displayName>Eagle UserProfile DAEMON</displayName>
-                    <category>MASTER</category>
-                    <cardinality>1+</cardinality>
-                    <versionAdvertised>true</versionAdvertised>
-                    <commandScript>
-                        <script>scripts/eagle_userprofile_scheduler.py</script>
-                        <scriptType>PYTHON</scriptType>
-                        <timeout>600</timeout>
-                    </commandScript>
-                    <configFiles>
-                        <configFile>
-                            <type>conf</type>
-                            <fileName>sandbox-userprofile-scheduler.conf</fileName>
-                            <dictionaryName>userprofile</dictionaryName>
-                        </configFile>
-                    </configFiles>
-                </component>
-
-                <!--<component>-->
-                    <!--<name>EAGLE_AUDIT2KAFKA_CLIENT</name>-->
-                    <!--<displayName>Eagle Audit2Kafka Client</displayName>-->
-                    <!--<category>CLIENT</category>-->
-                    <!--<cardinality>1+</cardinality>-->
-                    <!--<commandScript>-->
-                        <!--<script>scripts/eagle_audit_kafka.py</script>-->
-                        <!--<scriptType>PYTHON</scriptType>-->
-                        <!--<timeout>600</timeout>-->
-                    <!--</commandScript>-->
-                <!--</component>-->
-
-                <!--
-                <component>
-                    <name>EAGLE_CLIENT</name>
-                    <displayName>Eagle Client</displayName>
-                    <category>CLIENT</category>
-                    <cardinality>1+</cardinality>
-                    <commandScript>
-                        <script>scripts/eagle_client.py</script>
-                        <scriptType>PYTHON</scriptType>
-                        <timeout>600</timeout>
-                    </commandScript>
-                </component>
-        		-->
-            </components>
-
-            <osSpecifics>
-                <osSpecific>
-                    <osFamily>any</osFamily>
-                      <!-- note: use osType rather than osFamily for Ambari 1.5.0 and 1.5.1 -->
-                    <packages>
-                        <package>
-                            <name>eagle</name>
-                        </package>
-                    </packages>
-                </osSpecific>
-                            
-            </osSpecifics>
-            <requiredServices>
-                <service>HBASE</service>
-                <service>STORM</service>
-                <service>KAFKA</service>
-            </requiredServices>
-            <configuration-dependencies>
-                <config-type>eagle-service</config-type>
-                <config-type>data-process-runtime</config-type>
-            </configuration-dependencies>
-                    
-        </service>
-    </services>
-</metainfo>

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/patches/add-eagle-quicklink.patch
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/patches/add-eagle-quicklink.patch b/eagle-external/eagle-ambari/lib/EAGLE/package/patches/add-eagle-quicklink.patch
deleted file mode 100644
index 9c47955..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/patches/add-eagle-quicklink.patch
+++ /dev/null
@@ -1,27 +0,0 @@
-diff --git app.js app.js
-index 673e43b..172d8fa 100644
---- app.js
-+++ app.js
-@@ -57088,7 +57088,8 @@ App.serviceMetricsMapper = App.QuickDataMapper.create({
-       STORM: [31],
-       FALCON: [32],
-       RANGER: [33],
--      SPARK: [34]
-+      SPARK: [34],
-+      EAGLE: [35]
-     };
-     if (quickLinks[item.ServiceInfo.service_name])
-       finalJson.quick_links = quickLinks[item.ServiceInfo.service_name];
-@@ -66814,6 +66815,13 @@ App.QuickLinks.FIXTURES = [
-     site: 'spark-defaults',
-     regex: '^(\\d+)$',
-     default_http_port: 18080
-+  },
-+  {
-+    id: 35,
-+    label:'Eagle Web',
-+    url:'%@://%@:9099/eagle-service',
-+    service_id: 'EAGLE',
-+    template:'%@://%@:9099/eagle-service'
-   }
- ];

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/patches/app.js.gz
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/patches/app.js.gz b/eagle-external/eagle-ambari/lib/EAGLE/package/patches/app.js.gz
deleted file mode 100644
index 8cab877..0000000
Binary files a/eagle-external/eagle-ambari/lib/EAGLE/package/patches/app.js.gz and /dev/null differ

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/__init__.py
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/__init__.py b/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/__init__.py
deleted file mode 100755
index 136e1c6..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/__init__.py
+++ /dev/null
@@ -1,15 +0,0 @@
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/actions.py
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/actions.py b/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/actions.py
deleted file mode 100755
index ffd3c63..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/actions.py
+++ /dev/null
@@ -1,147 +0,0 @@
-#!/usr/bin/python
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-"""
-Eagle Ambari Command
-"""
-from resource_management import *
-
-def eagle_service_exec(action="start"):
-  import params
-
-  eagle_service_init_shell = format("{eagle_bin}/eagle-service-init.sh")
-  eagle_service_shell = format("{eagle_bin}/eagle-service.sh")
-
-  if action == "start":
-    start_cmd=format("{eagle_service_shell} start")
-    Execute(start_cmd, user=params.eagle_user)
-  elif action == "stop":
-    stop_cmd=format("{eagle_service_shell} stop")
-    Execute(stop_cmd,user=params.eagle_user)
-  elif action == "status":
-    status_cmd=format("{eagle_service_shell} status")
-    Execute(status_cmd,user=params.eagle_user)
-  elif action == "init":
-    Execute(eagle_service_init_shell,user=params.eagle_user)
-  else:
-    raise Exception('Unknown eagle service action: '+action)
-
-def eagle_topology_exec(action="start"):
-  import params
-
-  eagle_topology_shell = format("{eagle_bin}/eagle-topology.sh")
-  eagle_topology_init = format("{eagle_bin}/eagle-topology-init.sh")
-
-  if action == "start":
-    start_cmd = format("{eagle_topology_shell} start")
-    Execute(start_cmd, user=params.eagle_user)
-  elif action == "stop":
-    stop_cmd = format("{eagle_topology_shell} stop")
-    Execute(stop_cmd, user=params.eagle_user)
-  elif action == "status":
-    status_cmd = format("{eagle_topology_shell} --storm-ui status")
-    Execute(status_cmd, user=params.eagle_user)
-  elif action == "init":
-    Execute(eagle_topology_init, user=params.eagle_user)
-  else:
-    raise Exception('Unknown eagle topology action: '+action)
-
-def eagle_hive_topology_exec(action="start"):
-    import params
-
-    main_class="eagle.security.hive.jobrunning.HiveJobRunningMonitoringMain"
-    topology_name=format("{eagle_site}-hiveQueryRunningTopology")
-    config_file=format("{eagle_conf}/{eagle_site}-hiveQueryLog-application.conf")
-    eagle_topology_shell=format("{eagle_bin}/eagle-topology.sh")
-    eagle_topology_init=format("{eagle_bin}/eagle-topology-init.sh")
-
-    cmd=None
-
-    if action == "start":
-        cmd = format("{eagle_topology_shell} --main {main_class} --topology {topology_name} --config {config_file} start")
-    elif action == "stop":
-        cmd = format("{eagle_topology_shell} --topology {topology_name} stop")
-    elif action == "status":
-        cmd = format("{eagle_topology_shell} --topology {topology_name} --storm-ui status")
-    elif action == "init":
-        cmd = eagle_topology_init
-
-    if cmd != None:
-        Execute(cmd, user=params.eagle_user)
-    else:
-        raise Exception('Unknown eagle hive topology action: '+action)
-
-def eagle_hdfs_topology_exec(action="start"):
-    import params
-
-    main_class="eagle.security.auditlog.HdfsAuditLogProcessorMain"
-    topology_name=format("{eagle_site}-hdfsAuditLog-topology")
-    config_file=format("{eagle_conf}/{eagle_site}-hdfsAuditLog-application.conf")
-
-    eagle_topology_shell=format("{eagle_bin}/eagle-topology.sh")
-    eagle_topology_init=format("{eagle_bin}/eagle-topology-init.sh")
-
-    cmd=None
-    if action == "start":
-        cmd = format("{eagle_topology_shell} --main {main_class} --topology {topology_name} --config {config_file} start")
-    elif action == "stop":
-        cmd = format("{eagle_topology_shell} --topology {topology_name} stop")
-    elif action == "status":
-        cmd = format("{eagle_topology_shell} --topology {topology_name} --storm-ui status")
-    elif action == "init":
-        cmd = eagle_topology_init
-
-    if cmd != None:
-        Execute(cmd, user=params.eagle_user)
-    else:
-        raise Exception('Unknow eagle hdfs topology action: '+action)
-
-def eagle_userprofile_topology_exec(action="start"):
-    import params
-
-    main_class="eagle.security.userprofile.UserProfileDetectionMain"
-    topology_name=format("{eagle_site}-userprofile-topology")
-    config_file=format("{eagle_conf}/{eagle_site}-userprofile-topology.conf")
-
-    eagle_topology_shell=format("{eagle_bin}/eagle-topology.sh")
-    eagle_topology_init=format("{eagle_bin}/eagle-topology-init.sh")
-
-    cmd=None
-    if action == "start":
-        cmd = format("{eagle_topology_shell} --main {main_class} --topology {topology_name} --config {config_file} start")
-    elif action == "stop":
-        cmd = format("{eagle_topology_shell} --topology {topology_name} stop")
-    elif action == "status":
-        cmd = format("{eagle_topology_shell} --topology {topology_name} --storm-ui status")
-    elif action == "init":
-        cmd = eagle_topology_init
-
-    if cmd != None:
-        Execute(cmd, user=params.eagle_user)
-    else:
-        raise Exception('Unknow eagle userprofile topology action: '+action)
-
-def eagle_userprofile_scheduler_exec(action = "start"):
-    import params
-    userprofile_scheduler_shell=format("{eagle_bin}/eagle-userprofile-scheduler.sh --site {params.eagle_site}")
-    if action == "start":
-        Execute(format("{userprofile_scheduler_shell} --daemon {action}"), user=params.eagle_user)
-    elif action == "stop" or action == "status":
-        Execute(format("{userprofile_scheduler_shell} {action}"), user=params.eagle_user)
-    else:
-        raise Exception("known eagle user profile scheduler action: "+action)

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_audit_kafka.py
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_audit_kafka.py b/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_audit_kafka.py
deleted file mode 100644
index ac489ef..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_audit_kafka.py
+++ /dev/null
@@ -1,61 +0,0 @@
-#!/usr/bin/python
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import sys
-from resource_management import *
-class EagleAuditKafka(Script):
-    def install(self, env):
-        Logger.info('Installing Eagle AuditK2afka Client')
-        # self.install_packages(env)
-        import params
-        env.set_params(params)
-        self.configure(env)
-        # eagle_topology_exec(action = 'init')
-
-    def configure(self,env):
-        Logger.info("Configure Eagle Audit2Kafka Client")
-        import params
-        env.set_params(params)
-
-    def pre_rolling_restart(self,env):
-        Logger.info("Executing rolling pre-restart  Eagle Audit2Kafka Client")
-        import params
-        env.set_params(params)
-
-        # if params.version and compare_versions(format_hdp_stack_version(params.version), '2.2.0.0') >= 0:
-        #  Execute(format("hdp-select set eagle-topology {version}"))
-
-    def stop(self, env):
-        Logger.info('Stopping Eagle Audit2Kafka Client')
-        import params
-        env.set_params(params)
-        self.configure(env)
-
-    def start(self, env):
-        Logger.info('Starting Eagle Audit2Kafka Client')
-        import params
-        env.set_params(params)
-        self.configure(env)
-
-    def status(self, env):
-        Logger.info('Checking  Eagle Audit2Kafka Client')
-        import params
-        env.set_params(params)
-        self.configure(env)
-if __name__ == "__main__":
-    EagleAuditKafka().execute()

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_client.py
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_client.py b/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_client.py
deleted file mode 100644
index dff69b5..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_client.py
+++ /dev/null
@@ -1,27 +0,0 @@
-#!/usr/bin/python
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import sys
-from resource_management import *
-class EagleClient(Script):
-  def install(self, env):
-    print 'Install the eagle client';
-  def configure(self, env):
-    print 'Configure the eagle client';
-if __name__ == "__main__":
-  EagleClient().execute()

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_hdfs_topology.py
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_hdfs_topology.py b/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_hdfs_topology.py
deleted file mode 100755
index 12949b4..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_hdfs_topology.py
+++ /dev/null
@@ -1,88 +0,0 @@
-#!/usr/bin/python
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import sys
-
-from resource_management import *
-from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import get_unique_id_and_date
-from resource_management.libraries.functions.version import compare_versions, format_hdp_stack_version
-from resource_management.libraries.functions.security_commons import build_expectations, \
-  cached_kinit_executor, get_params_from_filesystem, validate_security_config_properties, \
-  FILE_TYPE_JAAS_CONF
-from resource_management.core.shell import call
-from resource_management.core.logger import Logger
-from resource_management.core.resources.system import Execute
-from resource_management.libraries.functions.check_process_status import check_process_status
-from resource_management.libraries.functions.format import format
-from resource_management.libraries.functions.validate import call_and_match_output
-
-from actions import *
-
-class EagleHdfsTopology(Script):
-  # def get_stack_to_component(self):
-  #  return {"HDP": "EAGLE-TOPOLOGY"}
-
-  def install(self, env):
-    Logger.info('Install Eagle DAM HDFS Topology')
-    # self.install_packages(env)
-    import params
-    env.set_params(params)
-    self.configure(env)
-    # eagle_hdfs_topology_exec(action = 'init')
-
-
-  def configure(self,env):
-    Logger.info("Configure Eagle DAM HDFS Topology")
-    import params
-    env.set_params(params)
-    # eagle_hdfs_topology_exec(action = 'init')
-
-  def pre_rolling_restart(self,env):
-    Logger.info("Executing rolling pre-restart Eagle DAM HDFS Topology")
-    import params
-    env.set_params(params)
-
-    # if params.version and compare_versions(format_hdp_stack_version(params.version), '2.2.0.0') >= 0:
-    #  Execute(format("hdp-select set eagle-topology {version}"))
-
-  def stop(self, env):
-    Logger.info('Stopping Eagle DAM HDFS Topology')
-    import params
-    env.set_params(params)
-    self.configure(env)
-    eagle_hdfs_topology_exec(action = 'stop')
-
-  def start(self, env):
-    Logger.info('Starting Eagle DAM HDFS Topology')
-    import params
-    env.set_params(params)
-    self.configure(env)
-
-    eagle_hdfs_topology_exec(action = 'init')
-    eagle_hdfs_topology_exec(action = 'start')
-
-  def status(self, env):
-    Logger.info('Checking Eagle DAM HDFS Topology status')
-    import params
-    env.set_params(params)
-    self.configure(env)
-    eagle_hdfs_topology_exec(action = 'status')
-
-if __name__ == "__main__":
-    EagleHdfsTopology().execute()
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_hive_topology.py
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_hive_topology.py b/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_hive_topology.py
deleted file mode 100755
index 12af6d0..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_hive_topology.py
+++ /dev/null
@@ -1,87 +0,0 @@
-#!/usr/bin/python
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import sys
-
-from resource_management import *
-from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import get_unique_id_and_date
-from resource_management.libraries.functions.version import compare_versions, format_hdp_stack_version
-from resource_management.libraries.functions.security_commons import build_expectations, \
-  cached_kinit_executor, get_params_from_filesystem, validate_security_config_properties, \
-  FILE_TYPE_JAAS_CONF
-from resource_management.core.shell import call
-from resource_management.core.logger import Logger
-from resource_management.core.resources.system import Execute
-from resource_management.libraries.functions.check_process_status import check_process_status
-from resource_management.libraries.functions.format import format
-from resource_management.libraries.functions.validate import call_and_match_output
-
-from actions import *
-
-class EagleHiveTopology(Script):
-  # def get_stack_to_component(self):
-  #  return {"HDP": "EAGLE-TOPOLOGY"}
-
-  def install(self, env):
-    Logger.info('Install Eagle DAM HIVE Topology')
-    # self.install_packages(env)
-    import params
-    env.set_params(params)
-    self.configure(env)
-    # eagle_hive_topology_exec(action = 'init')
-
-  def configure(self,env):
-    Logger.info("Configure Eagle DAM HIVE Topology")
-    import params
-    env.set_params(params)
-    # eagle_hive_topology_exec(action = 'init')
-
-  def pre_rolling_restart(self,env):
-    Logger.info("Executing rolling pre-restart Eagle DAM HIVE Topology")
-    import params
-    env.set_params(params)
-
-    # if params.version and compare_versions(format_hdp_stack_version(params.version), '2.2.0.0') >= 0:
-    #  Execute(format("hdp-select set eagle-topology {version}"))
-
-  def stop(self, env):
-    Logger.info('Stopping Eagle DAM HIVE Topology')
-    import params
-    env.set_params(params)
-    self.configure(env)
-    eagle_hive_topology_exec(action = 'stop')
-
-  def start(self, env):
-    Logger.info('Starting Eagle DAM HIVE Topology')
-    import params
-    env.set_params(params)
-    self.configure(env)
-
-    eagle_hive_topology_exec(action = 'init')
-    eagle_hive_topology_exec(action = 'start')
-
-  def status(self, env):
-    Logger.info('Checking Eagle DAM HIVE Topology status')
-    import params
-    env.set_params(params)
-    self.configure(env)
-    eagle_hive_topology_exec(action = 'status')
-
-if __name__ == "__main__":
-    EagleHiveTopology().execute()
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_service.py
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_service.py b/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_service.py
deleted file mode 100755
index db66f79..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_service.py
+++ /dev/null
@@ -1,85 +0,0 @@
-#!/usr/bin/python
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-import sys
-
-from resource_management import *
-from resource_management.libraries.script.script import Script
-from resource_management.libraries.functions import get_unique_id_and_date
-from resource_management.libraries.functions.version import compare_versions, format_hdp_stack_version
-from resource_management.libraries.functions.security_commons import build_expectations, \
-  cached_kinit_executor, get_params_from_filesystem, validate_security_config_properties, \
-  FILE_TYPE_JAAS_CONF
-from resource_management.core.shell import call
-from resource_management.core.logger import Logger
-from resource_management.core.resources.system import Execute
-from resource_management.libraries.functions.check_process_status import check_process_status
-from resource_management.libraries.functions.format import format
-from resource_management.libraries.functions.validate import call_and_match_output
-
-from actions import *
-
-class EagleService(Script):
-  # def get_stack_to_component(self):
-  #  return {"HDP": "EAGLE-SERVICE"}
-
-  def install(self, env):
-    Logger.info('Install the eagle service')
-    # self.install_packages(env)
-    import params
-    env.set_params(params)
-    self.configure(env)
-    eagle_service_exec(action = 'init')
-
-  def configure(self,env):
-    Logger.info("Configure eagle service")
-    import params
-    env.set_params(params)
-
-  def pre_rolling_restart(self,env):
-    Logger.info("Executing Rolling Upgrade pre-restart")
-    import params
-    env.set_params(params)
-
-    # if params.version and compare_versions(format_hdp_stack_version(params.version), '2.2.0.0') >= 0:
-    #  Execute(format("hdp-select set eagle service {version}"))
-
-  def stop(self, env):
-    Logger.info('Stop the eagle service')
-    import params
-    env.set_params(params)
-    self.configure(env)
-    eagle_service_exec(action = 'stop')
-
-  def start(self, env):
-    Logger.info('Start the eagle service')
-    import params
-    env.set_params(params)
-    self.configure(env)
-    eagle_service_exec(action = 'start')
-
-  def status(self, env):
-    Logger.info('Status of the eagle service')
-    import params
-    env.set_params(params)
-    self.configure(env)
-    # check_process_status(params.eagle_service_pid_file)
-    eagle_service_exec(action = 'status')
-
-if __name__ == "__main__":
-  EagleService().execute()

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/0ea130ef/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_service_check.py
----------------------------------------------------------------------
diff --git a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_service_check.py b/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_service_check.py
deleted file mode 100644
index a11b9f3..0000000
--- a/eagle-external/eagle-ambari/lib/EAGLE/package/scripts/eagle_service_check.py
+++ /dev/null
@@ -1,29 +0,0 @@
-#!/usr/bin/python
-
-# Licensed to the Apache Software Foundation (ASF) under one
-# or more contributor license agreements.  See the NOTICE file
-# distributed with this work for additional information
-# regarding copyright ownership.  The ASF licenses this file
-# to you under the Apache License, Version 2.0 (the
-# "License"); you may not use this file except in compliance
-# with the License.  You may obtain a copy of the License at
-#
-# http://www.apache.org/licenses/LICENSE-2.0
-#
-# Unless required by applicable law or agreed to in writing, software
-# distributed under the License is distributed on an "AS IS" BASIS,
-# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-# See the License for the specific language governing permissions and
-# limitations under the License.
-
-from resource_management import *
-
-class EagleServiceCheck(Script):
-  def service_check(self,env):
-    import params
-    env.set_params(params)
-    import actions
-    eagle_service_exec(action="status")
-
-if __name__ == "__main__":
-  EagleServiceCheck().execute()    


Mime
View raw message