Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 7919E200B59 for ; Mon, 8 Aug 2016 13:52:22 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 77B7B160A8F; Mon, 8 Aug 2016 11:52:22 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id C05B5160A91 for ; Mon, 8 Aug 2016 13:52:21 +0200 (CEST) Received: (qmail 81200 invoked by uid 500); 8 Aug 2016 11:52:20 -0000 Mailing-List: contact dev-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hive.apache.org Delivered-To: mailing list dev@hive.apache.org Received: (qmail 81173 invoked by uid 99); 8 Aug 2016 11:52:20 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 08 Aug 2016 11:52:20 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 716482C029E for ; Mon, 8 Aug 2016 11:52:20 +0000 (UTC) Date: Mon, 8 Aug 2016 11:52:20 +0000 (UTC) From: "Jesus Camacho Rodriguez (JIRA)" To: dev@hive.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Created] (HIVE-14470) Read results for Druid TopN query MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Mon, 08 Aug 2016 11:52:22 -0000 Jesus Camacho Rodriguez created HIVE-14470: ---------------------------------------------- Summary: Read results for Druid TopN query Key: HIVE-14470 URL: https://issues.apache.org/jira/browse/HIVE-14470 Project: Hive Issue Type: Sub-task Components: Druid integration Affects Versions: 2.2.0 Reporter: Jesus Camacho Rodriguez Assignee: Jesus Camacho Rodriguez Format of results for Druid TopN queries is as follows: {code:json} [ { "timestamp": "2013-08-31T00:00:00.000Z", "result": [ { "dim1": "dim1_val", "count": 111, "some_metrics": 10669, "average": 96.11711711711712 }, { "dim1": "another_dim1_val", "count": 88, "some_metrics": 28344, "average": 322.09090909090907 }, { "dim1": "dim1_val3", "count": 70, "some_metrics": 871, "average": 12.442857142857143 }, { "dim1": "dim1_val4", "count": 62, "some_metrics": 815, "average": 13.14516129032258 }, { "dim1": "dim1_val5", "count": 60, "some_metrics": 2787, "average": 46.45 } ] } ] {code} Out of this query results, we will generate Hive records with the following format: {code} [ new LongWritable(1377907200000L), new Text("dim1_val"), new LongWritable(111), new FloatWritable(10669F), new FloatWritable(96.11711711711712F) ] [ new LongWritable(1377907200000L), new Text("another_dim1_val"), new LongWritable(88), new FloatWritable(28344F), new FloatWritable(322.09090909090907F) ] [ new LongWritable(1377907200000L), new Text("dim1_val3"), new LongWritable(70), new FloatWritable(871F), new FloatWritable(12.442857142857143F) ] [ new LongWritable(1377907200000L), new Text("dim1_val4"), new LongWritable(62), new FloatWritable(815F), new FloatWritable(13.14516129032258F) ] [ new LongWritable(1377907200000L), new Text("dim1_val5"), new LongWritable(60), new FloatWritable(2787F), new FloatWritable(46.45F) ] {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)