8864

Build # 8864

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/3a1bb5a7151de28305a767627f6bc01a1270d03a">3a1bb5a71<a href="https://github.com/apache/carbondata/commit/3a1bb5a7151de28305a767627f6bc01a1270d03a">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/d635431b0891df4f7da8b4726f94a206f8d4e626">d635431b0</a>">d635431b0</a><a href="https://github.com/apache/carbondata/commit/3a1bb5a7151de28305a767627f6bc01a1270d03a"> into 5d17ff40b">5d17ff40b</a>

Run Details

18 of 18 new or added lines in 2 files covered. (100.0%)

52343 of 75013 relevant lines covered (69.78%)

0.96 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

60.0

/core/src/main/java/org/apache/carbondata/core/preagg/TimeSeriesUDF.java

/*
 * 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.carbondata.core.preagg;

import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.GregorianCalendar;
import java.util.List;

/**
 * class for applying timeseries udf
 */
public class TimeSeriesUDF {

  public final List<String> TIMESERIES_FUNCTION = new ArrayList<>();

  // thread local for keeping calender instance
  private ThreadLocal<Calendar> calanderThreadLocal = new ThreadLocal<>();

  /**
   * singleton instance
   */
  public static final TimeSeriesUDF INSTANCE = new TimeSeriesUDF();

  private TimeSeriesUDF() {
    initialize();
  }

  /**
   * Below method will be used to apply udf on data provided
   * Method will work based on below logic.
   * Data: 2016-7-23 01:01:30,10
   * Year Level UDF will return: 2016-1-1 00:00:00,0
   * Month Level UDF will return: 2016-7-1 00:00:00,0
   * Day Level UDF will return: 2016-7-23 00:00:00,0
   * Hour Level UDF will return: 2016-7-23 01:00:00,0
   * Minute Level UDF will return: 2016-7-23 01:01:00,0
   * Second Level UDF will return: 2016-7-23 01:01:30,0
   * If function does not match with any of the above functions
   * it will throw IllegalArgumentException
   *
   * @param data     timestamp data
   * @param function time series function name
   * @return data after applying udf
   */
  public Timestamp applyUDF(Timestamp data, String function) {
    if (null == data) {
      return data;
    }
    initialize();
    Calendar calendar = calanderThreadLocal.get();
    calendar.clear();
    calendar.setTimeInMillis(data.getTime());
    TimeSeriesFunctionEnum timeSeriesFunctionEnum =
        TimeSeriesFunctionEnum.valueOf(function.toUpperCase());
    switch (timeSeriesFunctionEnum) {
      case SECOND:
        calendar.set(Calendar.MILLISECOND, 0);
        break;
      case MINUTE:
        calendar.set(Calendar.MILLISECOND, 0);
        calendar.set(Calendar.SECOND, 0);
        break;
      case HOUR:
        calendar.set(Calendar.MILLISECOND, 0);
        calendar.set(Calendar.SECOND, 0);
        calendar.set(Calendar.MINUTE, 0);
        break;
      case DAY:
        calendar.set(Calendar.HOUR_OF_DAY, 0);
        calendar.set(Calendar.MINUTE, 0);
        calendar.set(Calendar.SECOND, 0);
        calendar.set(Calendar.MILLISECOND, 0);
        break;
      case MONTH:
        calendar.set(Calendar.MILLISECOND, 0);
        calendar.set(Calendar.SECOND, 0);
        calendar.set(Calendar.MINUTE, 0);
        calendar.set(Calendar.HOUR_OF_DAY, 0);
        calendar.set(Calendar.DAY_OF_MONTH, 1);
        break;
      case YEAR:
        calendar.set(Calendar.MONTH, 1);
        calendar.set(Calendar.DAY_OF_YEAR, 1);
        calendar.set(Calendar.HOUR_OF_DAY, 0);
        calendar.set(Calendar.MINUTE, 0);
        calendar.set(Calendar.SECOND, 0);
        calendar.set(Calendar.MILLISECOND, 0);
        break;
      default:
        throw new IllegalArgumentException("Invalid timeseries function name: " + function);
    }
    data.setTime(calendar.getTimeInMillis());
    return data;
  }

  /**
   * Below method will be used to initialize the thread local
   */
  private void initialize() {
    if (calanderThreadLocal.get() == null) {
      calanderThreadLocal.set(new GregorianCalendar());
    }
    if (TIMESERIES_FUNCTION.isEmpty()) {
      TIMESERIES_FUNCTION.add("second");
      TIMESERIES_FUNCTION.add("minute");
      TIMESERIES_FUNCTION.add("hour");
      TIMESERIES_FUNCTION.add("day");
      TIMESERIES_FUNCTION.add("month");
      TIMESERIES_FUNCTION.add("year");
    }
  }
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17	package org.apache.carbondata.core.preagg;
18
19	import java.sql.Timestamp;
20	import java.util.ArrayList;
21	import java.util.Calendar;
22	import java.util.GregorianCalendar;
23	import java.util.List;
24
25	/**
26	* class for applying timeseries udf
27	*/
28	public class TimeSeriesUDF {
29
30	public final List<String> TIMESERIES_FUNCTION = new ArrayList<>();	2✔
31
32	// thread local for keeping calender instance
33	private ThreadLocal<Calendar> calanderThreadLocal = new ThreadLocal<>();	2✔
34
35	/**
36	* singleton instance
37	*/
38	public static final TimeSeriesUDF INSTANCE = new TimeSeriesUDF();	2✔
39
40	private TimeSeriesUDF() {	2✔
41	initialize();	2✔
42	}	2✔
43
44	/**
45	* Below method will be used to apply udf on data provided
46	* Method will work based on below logic.
47	* Data: 2016-7-23 01:01:30,10
48	* Year Level UDF will return: 2016-1-1 00:00:00,0
49	* Month Level UDF will return: 2016-7-1 00:00:00,0
50	* Day Level UDF will return: 2016-7-23 00:00:00,0
51	* Hour Level UDF will return: 2016-7-23 01:00:00,0
52	* Minute Level UDF will return: 2016-7-23 01:01:00,0
53	* Second Level UDF will return: 2016-7-23 01:01:30,0
54	* If function does not match with any of the above functions
55	* it will throw IllegalArgumentException
56	*
57	* @param data timestamp data
58	* @param function time series function name
59	* @return data after applying udf
60	*/
61	public Timestamp applyUDF(Timestamp data, String function) {
62	if (null == data) {	1✔
63	return data;	×
64	}
65	initialize();	1✔
66	Calendar calendar = calanderThreadLocal.get();	1✔
67	calendar.clear();	1✔
68	calendar.setTimeInMillis(data.getTime());	1✔
69	TimeSeriesFunctionEnum timeSeriesFunctionEnum =	1✔
70	TimeSeriesFunctionEnum.valueOf(function.toUpperCase());	1✔
71	switch (timeSeriesFunctionEnum) {	1✔
72	case SECOND:
73	calendar.set(Calendar.MILLISECOND, 0);	1✔
74	break;	1✔
75	case MINUTE:
76	calendar.set(Calendar.MILLISECOND, 0);	×
77	calendar.set(Calendar.SECOND, 0);	×
78	break;	×
79	case HOUR:
80	calendar.set(Calendar.MILLISECOND, 0);	×
81	calendar.set(Calendar.SECOND, 0);	×
82	calendar.set(Calendar.MINUTE, 0);	×
83	break;	×
84	case DAY:
85	calendar.set(Calendar.HOUR_OF_DAY, 0);	1✔
86	calendar.set(Calendar.MINUTE, 0);	1✔
87	calendar.set(Calendar.SECOND, 0);	1✔
88	calendar.set(Calendar.MILLISECOND, 0);	1✔
89	break;	1✔
90	case MONTH:
91	calendar.set(Calendar.MILLISECOND, 0);	×
92	calendar.set(Calendar.SECOND, 0);	×
93	calendar.set(Calendar.MINUTE, 0);	×
94	calendar.set(Calendar.HOUR_OF_DAY, 0);	×
95	calendar.set(Calendar.DAY_OF_MONTH, 1);	×
96	break;	×
97	case YEAR:
98	calendar.set(Calendar.MONTH, 1);	×
99	calendar.set(Calendar.DAY_OF_YEAR, 1);	×
100	calendar.set(Calendar.HOUR_OF_DAY, 0);	×
101	calendar.set(Calendar.MINUTE, 0);	×
102	calendar.set(Calendar.SECOND, 0);	×
103	calendar.set(Calendar.MILLISECOND, 0);	×
104	break;	×
105	default:
106	throw new IllegalArgumentException("Invalid timeseries function name: " + function);	×
107	}
108	data.setTime(calendar.getTimeInMillis());	1✔
109	return data;	1✔
110	}
111
112	/**
113	* Below method will be used to initialize the thread local
114	*/
115	private void initialize() {
116	if (calanderThreadLocal.get() == null) {	2✔
117	calanderThreadLocal.set(new GregorianCalendar());	2✔
118	}
119	if (TIMESERIES_FUNCTION.isEmpty()) {	2✔
120	TIMESERIES_FUNCTION.add("second");	2✔
121	TIMESERIES_FUNCTION.add("minute");	2✔
122	TIMESERIES_FUNCTION.add("hour");	2✔
123	TIMESERIES_FUNCTION.add("day");	2✔
124	TIMESERIES_FUNCTION.add("month");	2✔
125	TIMESERIES_FUNCTION.add("year");	2✔
126	}
127	}	2✔
128	}

apache / carbondata / 8864

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous