[jira] [Closed] (CARBONDATA-2084) Timeseries pre-aggregate table should support min and max when the create datamap don't as select max and min

[Akash R Nilugal (Jira)]

     [ https://issues.apache.org/jira/browse/CARBONDATA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

xubo245 closed CARBONDATA-2084.
-------------------------------
    Resolution: Invalid

> Timeseries pre-aggregate table should support min and max when the create datamap don't as select max and min
> -------------------------------------------------------------------------------------------------------------
>
>                 Key: CARBONDATA-2084
>                 URL: https://issues.apache.org/jira/browse/CARBONDATA-2084
>             Project: CarbonData
>          Issue Type: Bug
>          Components: core, spark-integration
>    Affects Versions: 1.3.0
>            Reporter: xubo245
>            Priority: Major
>             Fix For: 1.3.0
>
>
> {code:java}
>   override def beforeAll: Unit = {
>     SparkUtil4Test.createTaskMockUp(sqlContext)
>     CarbonProperties.getInstance()
>       .addProperty(CarbonCommonConstants.CARBON_TIMESTAMP_FORMAT,
>         CarbonCommonConstants.CARBON_TIMESTAMP_DEFAULT_FORMAT)
>     sql("drop table if exists mainTable")
>     sql("CREATE TABLE mainTable(mytime timestamp, name string, age int) STORED BY 'org.apache.carbondata.format'")
>     sql("create datamap agg0 on table mainTable using 'preaggregate' DMPROPERTIES ('timeseries.eventTime'='mytime', 'timeseries.hierarchy'='second=1,minute=1,hour=1,day=1,month=1,year=1') as select mytime, sum(age) from mainTable group by mytime")
>     sql(s"LOAD DATA LOCAL INPATH '$resourcesPath/timeseriestest.csv' into table mainTable")
>   }
> {code}
> {code:java}
>   // TODO: support max
>   ignore("test PreAggregate table selection 38: filter < and >=, max") {
>     val df = sql(
>       """
>         | select
>         |   timeseries(mytime,'second') as secondLevel,
>         |   max(age) as maxValue
>         | from mainTable
>         | where timeseries(mytime,'second')<'2016-02-23 01:02:00' and timeseries(mytime,'second')>='2016-02-23 01:01:00'
>         | group by
>         |   timeseries(mytime,'second')
>         | order by
>         |   timeseries(mytime,'second')
>       """.stripMargin)
>     df.show()
>     checkAnswer(df, Seq(Row(Timestamp.valueOf("2016-02-23 01:01:50"), 30)))
>   }
>   ignore("test PreAggregate table selection 39: filter < and >=, min") {
>     val df = sql(
>       """
>         | select
>         |   timeseries(mytime,'second') as secondLevel,
>         |   min(age) as minValue
>         | from mainTable
>         | where timeseries(mytime,'second')<'2016-02-23 01:02:00' and timeseries(mytime,'second')>='2016-02-23 01:01:00'
>         | group by
>         |   timeseries(mytime,'second')
>         | order by
>         |   timeseries(mytime,'second')
>       """.stripMargin)
>     df.show()
>     checkAnswer(df, Seq(Row(Timestamp.valueOf("2016-02-23 01:01:30"), 10)))
>   }
> {code}
> detail please see my branch: https://github.com/xubo245/carbondata/tree/usingTimeseries

--
This message was sent by Atlassian JIRA
(v7.6.3#76005)