eagle-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From h..@apache.org
Subject incubator-eagle git commit: [EAGLE-775] add unit test for eagle-service-base
Date Tue, 29 Nov 2016 07:50:00 GMT
Repository: incubator-eagle
Updated Branches:
  refs/heads/master 021c2bddd -> 286034ff3


[EAGLE-775] add unit test for eagle-service-base

https://issues.apache.org/jira/browse/EAGLE-775

Author: koone <luokun1028@126.com>

Closes #689 from koone/EAGLE-775.


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

Branch: refs/heads/master
Commit: 286034ff3b68eb8ba1650c6fd013dd5d6feb68f5
Parents: 021c2bd
Author: koone <luokun1028@126.com>
Authored: Tue Nov 29 15:49:53 2016 +0800
Committer: Hao Chen <hao@apache.org>
Committed: Tue Nov 29 15:49:53 2016 +0800

----------------------------------------------------------------------
 .../eagle-query/eagle-service-base/pom.xml      |  12 +
 .../TestGenericEntityServiceResource.java       | 236 +++++++++++++++++++
 .../service/generic/TestResourceUnmarshal.java  | 125 ++++++++++
 .../service/metric/EagleMetricResourceApp.java  |  41 ++++
 .../service/metric/TestEagleMetricResource.java |  74 ++++++
 5 files changed, 488 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/286034ff/eagle-core/eagle-query/eagle-service-base/pom.xml
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-query/eagle-service-base/pom.xml b/eagle-core/eagle-query/eagle-service-base/pom.xml
index a657581..74f635e 100755
--- a/eagle-core/eagle-query/eagle-service-base/pom.xml
+++ b/eagle-core/eagle-query/eagle-service-base/pom.xml
@@ -139,6 +139,18 @@
             <version>${org.eclipse.jetty.orbit.javax.servlet.version}</version>
             <scope>provided</scope>
         </dependency>
+        <dependency>
+            <groupId>org.powermock</groupId>
+            <artifactId>powermock-module-junit4</artifactId>
+            <version>${powermock.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>org.powermock</groupId>
+            <artifactId>powermock-api-mockito</artifactId>
+            <version>${powermock.version}</version>
+            <scope>test</scope>
+        </dependency>
         <!--<dependency>-->
             <!--<groupId>org.codehaus.jackson</groupId>-->
             <!--<artifactId>jackson-mapper-asl</artifactId>-->

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/286034ff/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/generic/TestGenericEntityServiceResource.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/generic/TestGenericEntityServiceResource.java
b/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/generic/TestGenericEntityServiceResource.java
new file mode 100644
index 0000000..862f09b
--- /dev/null
+++ b/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/generic/TestGenericEntityServiceResource.java
@@ -0,0 +1,236 @@
+/*
+ * 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.service.generic;
+
+import com.fasterxml.jackson.databind.ObjectMapper;
+import io.dropwizard.testing.junit.ResourceTestRule;
+import org.apache.eagle.log.base.taggedlog.EntityJsonModule;
+import org.apache.eagle.log.base.taggedlog.TaggedLogAPIEntity;
+import org.apache.eagle.log.entity.GenericServiceAPIResponseEntity;
+import org.apache.eagle.log.entity.meta.EntityDefinition;
+import org.apache.eagle.log.entity.meta.EntityDefinitionManager;
+import org.apache.eagle.log.entity.test.TestTimeSeriesAPIEntity;
+import org.apache.eagle.storage.DataStorage;
+import org.apache.eagle.storage.DataStorageManager;
+import org.apache.eagle.storage.exception.IllegalDataStorageTypeException;
+import org.apache.eagle.storage.hbase.HBaseStorage;
+import org.apache.eagle.storage.operation.UpdateStatement;
+import org.apache.eagle.storage.result.ModifyResult;
+import org.apache.eagle.storage.result.QueryResult;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.hbase.HBaseConfiguration;
+import org.junit.*;
+import org.junit.runner.RunWith;
+import org.powermock.core.classloader.annotations.PrepareForTest;
+import org.powermock.modules.junit4.PowerMockRunner;
+
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+import static org.mockito.Matchers.any;
+import static org.mockito.Mockito.never;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+import static org.powermock.api.mockito.PowerMockito.mock;
+import static org.powermock.api.mockito.PowerMockito.mockStatic;
+
+@RunWith(PowerMockRunner.class)
+@PrepareForTest({DataStorageManager.class, HBaseConfiguration.class})
+public class TestGenericEntityServiceResource {
+
+    private static final ObjectMapper MAPPER = new ObjectMapper();
+    private DataStorage dataStorage;
+    private GenericEntityServiceResource genericEntityServiceResource = new GenericEntityServiceResource();
+
+    @Rule
+    public ResourceTestRule resources = ResourceTestRule.builder()
+            .addResource(genericEntityServiceResource).setMapper(MAPPER)
+            .build();
+
+    @BeforeClass
+    public static void setupMapper() throws IllegalDataStorageTypeException, IOException
{
+        MAPPER.setFilters(TaggedLogAPIEntity.getFilterProvider());
+        MAPPER.registerModule(new EntityJsonModule());
+    }
+
+    @Before
+    public void setup() throws IllegalDataStorageTypeException {
+        dataStorage = mock(HBaseStorage.class);
+        mockStatic(DataStorageManager.class);
+        mockStatic(HBaseConfiguration.class);
+        when(DataStorageManager.getDataStorageByEagleConfig()).thenReturn(dataStorage);
+        when(HBaseConfiguration.create()).thenReturn(new Configuration());
+    }
+
+    @Test
+    public void testGenericEntityServiceResourceupdateDatabaseNullDataStorage() throws IllegalDataStorageTypeException
{
+        when(DataStorageManager.getDataStorageByEagleConfig()).thenReturn(null);
+        GenericServiceAPIResponseEntity responseEntity = genericEntityServiceResource.updateDatabase(null);
+        Assert.assertFalse(responseEntity.isSuccess());
+        Assert.assertEquals(null, responseEntity.getMeta());
+        Assert.assertEquals(null, responseEntity.getType());
+        Assert.assertEquals(null, responseEntity.getObj());
+        Assert.assertTrue(responseEntity.getException().startsWith("org.apache.eagle.storage.exception.IllegalDataStorageException:
Data storage is null"));
+    }
+
+    @Test
+    public void testGenericEntityServiceResourceupdateDatabaseFalse() throws IllegalDataStorageTypeException,
IOException, IllegalAccessException, InstantiationException {
+        TestTimeSeriesAPIEntity e = new TestTimeSeriesAPIEntity();
+        List<TestTimeSeriesAPIEntity> entities = new ArrayList<>();
+        entities.add(e);
+        EntityDefinition ed = EntityDefinitionManager.getEntityByServiceName("TestTimeSeriesAPIEntity");
+
+        ModifyResult<String> modifyResult = new ModifyResult<>();
+        modifyResult.setSuccess(false);
+        when(dataStorage.update(entities, ed)).thenReturn(modifyResult);
+        GenericServiceAPIResponseEntity responseEntity = genericEntityServiceResource.updateDatabase(new
UpdateStatement(entities, "TestTimeSeriesAPIEntity"));
+        Assert.assertFalse(responseEntity.isSuccess());
+        Assert.assertEquals(null, responseEntity.getMeta());
+        Assert.assertEquals(null, responseEntity.getType());
+        Assert.assertEquals(null, responseEntity.getObj());
+        Assert.assertEquals(null, responseEntity.getException());
+        verify(dataStorage).update(entities, ed);
+    }
+
+    @Test
+    public void testGenericEntityServiceResourceupdateDatabase() throws IllegalDataStorageTypeException,
IOException, IllegalAccessException, InstantiationException {
+        TestTimeSeriesAPIEntity e = new TestTimeSeriesAPIEntity();
+        List<TestTimeSeriesAPIEntity> entities = new ArrayList<>();
+        entities.add(e);
+        EntityDefinition ed = EntityDefinitionManager.getEntityByServiceName("TestTimeSeriesAPIEntity");
+
+        ModifyResult<String> modifyResult = new ModifyResult<>();
+        List<String> identifiers = new ArrayList<>();
+        identifiers.add("test");
+        modifyResult.setSuccess(true);
+        modifyResult.setIdentifiers(identifiers);
+        when(dataStorage.update(entities, ed)).thenReturn(modifyResult);
+        GenericServiceAPIResponseEntity responseEntity = genericEntityServiceResource.updateDatabase(new
UpdateStatement(entities, "TestTimeSeriesAPIEntity"));
+        Assert.assertTrue(responseEntity.isSuccess());
+        Assert.assertTrue(responseEntity.getMeta().toString().startsWith("{totalResults=1"));
+        Assert.assertEquals(String.class, responseEntity.getType());
+        Assert.assertEquals("test", responseEntity.getObj().get(0));
+        Assert.assertEquals(null, responseEntity.getException());
+        verify(dataStorage).update(entities, ed);
+    }
+
+    @Test
+    public void testGenericEntityServiceResourceupdateDatabase1() throws IllegalDataStorageTypeException,
IOException, IllegalAccessException, InstantiationException {
+        TestTimeSeriesAPIEntity e = new TestTimeSeriesAPIEntity();
+        List<TestTimeSeriesAPIEntity> entities = new ArrayList<>();
+        entities.add(e);
+        EntityDefinition ed = EntityDefinitionManager.getEntityByServiceName("TestTimeSeriesAPIEntity");
+
+        ModifyResult<String> modifyResult = new ModifyResult<>();
+        List<String> identifiers = null;
+        modifyResult.setSuccess(true);
+        modifyResult.setIdentifiers(identifiers);
+        when(dataStorage.update(entities, ed)).thenReturn(modifyResult);
+        GenericServiceAPIResponseEntity responseEntity = genericEntityServiceResource.updateDatabase(new
UpdateStatement(entities, "TestTimeSeriesAPIEntity"));
+        Assert.assertTrue(responseEntity.isSuccess());
+        Assert.assertTrue(responseEntity.getMeta().toString().startsWith("{totalResults=0"));
+        Assert.assertEquals(null, responseEntity.getType());
+        Assert.assertEquals(null, responseEntity.getObj());
+        Assert.assertEquals(null, responseEntity.getException());
+        verify(dataStorage).update(entities, ed);
+    }
+
+
+    @Test
+    public void testGenericEntityServiceResourceSearchFalse() throws IllegalAccessException,
InstantiationException, IOException {
+        QueryResult<TestTimeSeriesAPIEntity> queryResult = new QueryResult<>();
+        queryResult.setSuccess(false);
+        List<String> rowkeys = new ArrayList<>();
+        rowkeys.add("test");
+        EntityDefinition ed = EntityDefinitionManager.getEntityByServiceName("TestTimeSeriesAPIEntity");
+        when(dataStorage.queryById(rowkeys, ed)).thenReturn(queryResult);
+        GenericServiceAPIResponseEntity responseEntity = resources.client().resource("/entities/rowkey").queryParam("value",
"test").queryParam("serviceName", "TestTimeSeriesAPIEntity").get(GenericServiceAPIResponseEntity.class);
+
+        Assert.assertFalse(responseEntity.isSuccess());
+        Assert.assertEquals(null, responseEntity.getMeta());
+        Assert.assertEquals(null, responseEntity.getType());
+        Assert.assertEquals(null, responseEntity.getObj());
+        Assert.assertEquals(null, responseEntity.getException());
+        verify(dataStorage).queryById(rowkeys, ed);
+    }
+
+    @Test
+    public void testGenericEntityServiceResourceSearch() throws IllegalAccessException, InstantiationException,
IOException {
+        List<TestTimeSeriesAPIEntity> result = new ArrayList<>();
+        TestTimeSeriesAPIEntity e = new TestTimeSeriesAPIEntity();
+        long timestamp = System.currentTimeMillis();
+        e.setTimestamp(timestamp);
+        e.setField1(1);
+        e.setField2(2);
+        e.setField3(3);
+        e.setField4(4L);
+        e.setField5(5.0);
+        e.setField6(5.0);
+        e.setField7("7");
+        e.setTags(new HashMap<>());
+        e.getTags().put("cluster", "test4UT");
+        e.getTags().put("datacenter", "dc1");
+        e.getTags().put("index", "" + 1);
+        e.getTags().put("jobId", "job_2");
+        result.add(e);
+        QueryResult<TestTimeSeriesAPIEntity> queryResult = new QueryResult<>();
+
+        queryResult.setData(result);
+        queryResult.setSuccess(true);
+        queryResult.setSize(result.size());
+
+
+        EntityDefinition ed = EntityDefinitionManager.getEntityByServiceName("TestTimeSeriesAPIEntity");
+        List<String> rowkeys = new ArrayList<>();
+        rowkeys.add("test");
+        when(dataStorage.queryById(rowkeys, ed)).thenReturn(queryResult);
+        GenericServiceAPIResponseEntity responseEntity = resources.client().resource("/entities/rowkey").queryParam("value",
"test").queryParam("serviceName", "TestTimeSeriesAPIEntity").get(GenericServiceAPIResponseEntity.class);
+
+        Assert.assertTrue(responseEntity.isSuccess());
+        Assert.assertTrue(responseEntity.getMeta().toString().startsWith("{firstTimestamp=null,
totalResults=1, lastTimestamp=null, elapsedms="));
+        Assert.assertEquals(null, responseEntity.getType());
+        Assert.assertEquals("{prefix=null, timestamp=" + timestamp + ", tags={cluster=test4UT,
jobId=job_2, index=1, datacenter=dc1}, exp=null, encodedRowkey=null, serializeAlias=null,
serializeVerbose=true, field1=1, field2=2, field3=3, field4=4, field5=5.0, field6=5.0, field7=7}",
responseEntity.getObj().get(0).toString());
+        Assert.assertEquals(null, responseEntity.getException());
+        verify(dataStorage).queryById(rowkeys, ed);
+    }
+
+    @Test
+    public void testGenericEntityServiceResourceSearchNullServiceName() throws IllegalAccessException,
InstantiationException, IOException {
+        GenericServiceAPIResponseEntity responseEntity = resources.client().resource("/entities/rowkey").queryParam("value",
"test").get(GenericServiceAPIResponseEntity.class);
+        Assert.assertFalse(responseEntity.isSuccess());
+        Assert.assertEquals(null, responseEntity.getMeta());
+        Assert.assertEquals(null, responseEntity.getType());
+        Assert.assertEquals(null, responseEntity.getObj());
+        Assert.assertTrue(responseEntity.getException().startsWith("java.lang.Exception:
java.lang.IllegalArgumentException: serviceName is null"));
+        verify(dataStorage, never()).queryById(any(), any());
+    }
+
+    @Test
+    public void testGenericEntityServiceResourceSearchNullDataStorage() throws IllegalAccessException,
InstantiationException, IOException, IllegalDataStorageTypeException {
+        when(DataStorageManager.getDataStorageByEagleConfig()).thenReturn(null);
+        GenericServiceAPIResponseEntity responseEntity = resources.client().resource("/entities/rowkey").queryParam("value",
"test").queryParam("serviceName", "TestTimeSeriesAPIEntity").get(GenericServiceAPIResponseEntity.class);
+        Assert.assertFalse(responseEntity.isSuccess());
+        Assert.assertEquals(null, responseEntity.getMeta());
+        Assert.assertEquals(null, responseEntity.getType());
+        Assert.assertEquals(null, responseEntity.getObj());
+        Assert.assertTrue(responseEntity.getException().startsWith("java.lang.Exception:
org.apache.eagle.storage.exception.IllegalDataStorageException: data storage is null"));
+        verify(dataStorage, never()).queryById(any(), any());
+    }
+}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/286034ff/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/generic/TestResourceUnmarshal.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/generic/TestResourceUnmarshal.java
b/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/generic/TestResourceUnmarshal.java
new file mode 100644
index 0000000..4e21063
--- /dev/null
+++ b/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/generic/TestResourceUnmarshal.java
@@ -0,0 +1,125 @@
+/*
+ * 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.service.generic;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import org.apache.eagle.log.base.taggedlog.EntityJsonModule;
+import org.apache.eagle.log.base.taggedlog.TaggedLogAPIEntity;
+import org.apache.eagle.log.entity.meta.EntityDefinition;
+import org.apache.eagle.log.entity.meta.EntityDefinitionManager;
+import org.apache.eagle.log.entity.test.TestTimeSeriesAPIEntity;
+import org.apache.eagle.storage.exception.IllegalDataStorageTypeException;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import java.io.ByteArrayInputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.lang.reflect.InvocationTargetException;
+import java.lang.reflect.Method;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+public class TestResourceUnmarshal {
+    private static final ObjectMapper MAPPER = new ObjectMapper();
+
+    @BeforeClass
+    public static void setup() throws IllegalDataStorageTypeException, IOException {
+        MAPPER.setFilters(TaggedLogAPIEntity.getFilterProvider());
+        MAPPER.registerModule(new EntityJsonModule());
+    }
+    @Test
+    public void testUnmarshalEntitiesByServie() throws NoSuchMethodException, InvocationTargetException,
JsonProcessingException, IllegalAccessException, InstantiationException {
+
+        TestTimeSeriesAPIEntity timeSeriesAPIEntity = new TestTimeSeriesAPIEntity();
+        timeSeriesAPIEntity.setTimestamp(System.currentTimeMillis());
+        timeSeriesAPIEntity.setField1(1);
+        timeSeriesAPIEntity.setField2(2);
+        timeSeriesAPIEntity.setField3(3);
+        timeSeriesAPIEntity.setField4(4L);
+        timeSeriesAPIEntity.setField5(5.0);
+        timeSeriesAPIEntity.setField6(5.0);
+        timeSeriesAPIEntity.setField7("7");
+        timeSeriesAPIEntity.setTags(new HashMap<>());
+        timeSeriesAPIEntity.getTags().put("cluster", "test4UT");
+        timeSeriesAPIEntity.getTags().put("datacenter", "dc1");
+        timeSeriesAPIEntity.getTags().put("index", "" + 1);
+        timeSeriesAPIEntity.getTags().put("jobId", "job_" + timeSeriesAPIEntity.getTimestamp());
+
+        List<TestTimeSeriesAPIEntity> timeSeriesAPIEntityList = new ArrayList<>();
+        timeSeriesAPIEntityList.add(timeSeriesAPIEntity);
+
+        GenericEntityServiceResource genericEntityServiceResource = new GenericEntityServiceResource();
+        Method unmarshalEntitiesByServie = genericEntityServiceResource.getClass().getDeclaredMethod("unmarshalEntitiesByServie",
InputStream.class, EntityDefinition.class);
+        unmarshalEntitiesByServie.setAccessible(true);
+        InputStream stream = new ByteArrayInputStream(MAPPER.writeValueAsString(timeSeriesAPIEntityList).getBytes(StandardCharsets.UTF_8));
+        EntityDefinition ed = EntityDefinitionManager.getEntityDefinitionByEntityClass(TestTimeSeriesAPIEntity.class);
+        List<TestTimeSeriesAPIEntity> result = (List<TestTimeSeriesAPIEntity>)
unmarshalEntitiesByServie.invoke(genericEntityServiceResource, stream, ed);
+
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getTimestamp(), result.get(0).getTimestamp());
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getField1(), result.get(0).getField1());
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getField2(), result.get(0).getField2());
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getField3(), result.get(0).getField3());
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getField4(), result.get(0).getField4());
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getField5(), result.get(0).getField5(),
0.1);
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getField6(), result.get(0).getField6());
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getField7(), result.get(0).getField7());
+
+
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getTags().get("cluster"), result.get(0).getTags().get("cluster"));
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getTags().get("datacenter"), result.get(0).getTags().get("datacenter"));
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getTags().get("index"), result.get(0).getTags().get("index"));
+        Assert.assertEquals(timeSeriesAPIEntityList.get(0).getTags().get("jobId"), result.get(0).getTags().get("jobId"));
+
+    }
+
+    @Test
+    public void testUnmarshalAsStringlist() throws NoSuchMethodException, JsonProcessingException,
InvocationTargetException, IllegalAccessException {
+
+        TestTimeSeriesAPIEntity timeSeriesAPIEntity = new TestTimeSeriesAPIEntity();
+        timeSeriesAPIEntity.setTimestamp(1l);
+        timeSeriesAPIEntity.setField1(1);
+        timeSeriesAPIEntity.setField2(2);
+        timeSeriesAPIEntity.setField3(3);
+        timeSeriesAPIEntity.setField4(4L);
+        timeSeriesAPIEntity.setField5(5.0);
+        timeSeriesAPIEntity.setField6(5.0);
+        timeSeriesAPIEntity.setField7("7");
+        timeSeriesAPIEntity.setTags(new HashMap<>());
+        timeSeriesAPIEntity.getTags().put("cluster", "test4UT");
+        timeSeriesAPIEntity.getTags().put("datacenter", "dc1");
+        timeSeriesAPIEntity.getTags().put("index", "" + 1);
+        timeSeriesAPIEntity.getTags().put("jobId", "job_" + timeSeriesAPIEntity.getTimestamp());
+
+        List<TestTimeSeriesAPIEntity> timeSeriesAPIEntityList = new ArrayList<>();
+        timeSeriesAPIEntityList.add(timeSeriesAPIEntity);
+
+        GenericEntityServiceResource genericEntityServiceResource = new GenericEntityServiceResource();
+        Method unmarshalAsStringlist = genericEntityServiceResource.getClass().getDeclaredMethod("unmarshalAsStringlist",
InputStream.class);
+        unmarshalAsStringlist.setAccessible(true);
+
+        InputStream stream = new ByteArrayInputStream(MAPPER.writeValueAsString(timeSeriesAPIEntityList).getBytes(StandardCharsets.UTF_8));
+        List<String> result = (List<String>) unmarshalAsStringlist.invoke(genericEntityServiceResource,
stream);
+
+        Assert.assertEquals("[{, prefix, null, timestamp, 1, tags, {, cluster, test4UT, jobId,
job_1, index, 1, datacenter, dc1, }, exp, null, encodedRowkey, null, serializeAlias, null,
serializeVerbose, true, field1, 1, field2, 2, field3, 3, field4, 4, field5, 5.0, field6, 5.0,
field7, 7, }]", result.toString());
+    }
+}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/286034ff/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/metric/EagleMetricResourceApp.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/metric/EagleMetricResourceApp.java
b/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/metric/EagleMetricResourceApp.java
new file mode 100644
index 0000000..dcb00bd
--- /dev/null
+++ b/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/metric/EagleMetricResourceApp.java
@@ -0,0 +1,41 @@
+/*
+ * 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.service.metric;
+
+import io.dropwizard.Application;
+import io.dropwizard.Configuration;
+import io.dropwizard.jetty.HttpConnectorFactory;
+import io.dropwizard.server.DefaultServerFactory;
+import io.dropwizard.setup.Bootstrap;
+import io.dropwizard.setup.Environment;
+import org.apache.eagle.service.generic.MetadataResource;
+
+
+public class EagleMetricResourceApp extends Application<Configuration> {
+
+    @Override
+    public void initialize(Bootstrap<Configuration> bootstrap) {
+    }
+
+    @Override
+    public void run(Configuration configuration, Environment environment) throws Exception
{
+        ((HttpConnectorFactory) ((DefaultServerFactory) configuration.getServerFactory()).getApplicationConnectors().get(0)).setPort(0);
+        ((HttpConnectorFactory) ((DefaultServerFactory) configuration.getServerFactory()).getAdminConnectors().get(0)).setPort(0);
+        environment.jersey().register(EagleMetricResource.class);
+    }
+}

http://git-wip-us.apache.org/repos/asf/incubator-eagle/blob/286034ff/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/metric/TestEagleMetricResource.java
----------------------------------------------------------------------
diff --git a/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/metric/TestEagleMetricResource.java
b/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/metric/TestEagleMetricResource.java
new file mode 100644
index 0000000..d67ed75
--- /dev/null
+++ b/eagle-core/eagle-query/eagle-service-base/src/test/java/org/apache/eagle/service/metric/TestEagleMetricResource.java
@@ -0,0 +1,74 @@
+package org.apache.eagle.service.metric;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.node.ObjectNode;
+import com.sun.jersey.api.client.Client;
+import io.dropwizard.Configuration;
+import io.dropwizard.jackson.Jackson;
+import io.dropwizard.testing.junit.DropwizardAppRule;
+import org.apache.eagle.log.base.taggedlog.TaggedLogAPIEntity;
+import org.apache.eagle.log.entity.GenericCreateAPIResponseEntity;
+import org.apache.eagle.log.entity.GenericMetricEntity;
+import org.apache.eagle.service.generic.MetadataResource;
+import org.apache.eagle.service.generic.MetadataResourceApp;
+import org.junit.Before;
+import org.junit.ClassRule;
+import org.junit.Test;
+
+import javax.ws.rs.core.MediaType;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import static javax.ws.rs.core.HttpHeaders.ACCEPT;
+import static javax.ws.rs.core.HttpHeaders.CONTENT_TYPE;
+import static org.junit.Assert.*;
+
+/**
+ * Created by luokun on 11/25/16.
+ */
+public class TestEagleMetricResource {
+
+    private String restURL;
+    private String requestJson;
+
+    @ClassRule
+    public static final DropwizardAppRule<Configuration> RULE =
+        new DropwizardAppRule<>(EagleMetricResourceApp.class, null);
+
+
+    private void getMetadataResource( ){
+         new Client().resource(restURL )
+            .header(ACCEPT, MediaType.APPLICATION_JSON)
+            .header(CONTENT_TYPE, MediaType.APPLICATION_JSON)
+            .post(GenericCreateAPIResponseEntity.class, requestJson);
+    }
+
+    @Before
+    public void setUp() throws JsonProcessingException {
+        restURL = "http://localhost:" + RULE.getLocalPort() + EagleMetricResource.METRIC_URL_PATH;
+        List<GenericMetricEntity> entities = new ArrayList<GenericMetricEntity>();
+        Map<String,String> tags = new HashMap<String, String>() {{
+            put("cluster", "cluster4ut");
+            put("datacenter", "datacenter4ut");
+        }};
+        for(int i=0;i<100;i++){
+            GenericMetricEntity entity = new GenericMetricEntity();
+            entity.setTimestamp(System.currentTimeMillis());
+            entity.setTags(tags);
+            entity.setValue(new double[]{1.234});
+            entity.setPrefix("unit.test.metrics");
+            entities.add(entity);
+        }
+        requestJson = TaggedLogAPIEntity.buildObjectMapper().writeValueAsString(entities);
+    }
+
+    @Test
+    public void testCreateGenericMetricEntity() throws Exception {
+        // getMetadataResource();
+    }
+
+}
\ No newline at end of file


Mime
View raw message