在 Hive 中将分钟添加到日期时间
Add minutes to datetime in Hive
Hive 中是否有一个函数可以用来将分钟(整数)添加到类似于 DATEADD (datepart,number,date)
在 sql 服务器中的日期时间,其中 datepart
可以是 minutes
:
DATEADD(minute,2,'2014-07-06 01:28:02')
returns 2014-07-06 01:28:02
另一方面,Hive 的 date_add(string startdate, int days)
在 days
中。 hours
?
中的任何一个
您的问题可以通过 HiveUdf 轻松解决。
package HiveUDF;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.hadoop.hive.ql.exec.UDF;
public class addMinuteUdf extends UDF{
final long ONE_MINUTE_IN_MILLIS=60000;
private SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
public String evaluate(String t, int minute) throws ParseException{
long time=formatter.parse(t.toString()).getTime();
Date AddingMins=new Date(time + (minute * ONE_MINUTE_IN_MILLIS));
String date = formatter.format(AddingMins);
return date;
}
}
创建后AddMinuteUdf.jar,注册到Hive中;
ADD JAR /home/Kishore/AddMinuteUdf.jar;
create temporary FUNCTION addMinute as 'HiveUDF.addMinuteUdf';
hive> select date from ATable;
OK
2014-07-06 01:28:02
Time taken: 0.108 seconds, Fetched: 1 row(s)
应用函数后
hive> select addMinuteUdf(date, 2) from ATable;
OK
2014-07-06 01:30:02
Time taken: 0.094 seconds, Fetched: 1 row(s)
您可以不使用 UDF,而是将秒数添加到日期时间,将其转换为 unix_timestamp(),然后将结果转换回日期时间。
示例:
select from_unixtime(unix_timestamp('2015-12-12 16:15:17')+3600);
这里我们加了一小时:
hive> select from_unixtime(unix_timestamp('2015-11-12 12:15:17')+${seconds_in_hour});
OK
2015-11-12 13:15:17
Time taken: 0.121 seconds, Fetched: 1 row(s)
因此,如果要添加分钟数,则应添加分钟数*60。
Hive 中是否有一个函数可以用来将分钟(整数)添加到类似于 DATEADD (datepart,number,date)
在 sql 服务器中的日期时间,其中 datepart
可以是 minutes
:
DATEADD(minute,2,'2014-07-06 01:28:02')
returns 2014-07-06 01:28:02
另一方面,Hive 的 date_add(string startdate, int days)
在 days
中。 hours
?
您的问题可以通过 HiveUdf 轻松解决。
package HiveUDF;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.hadoop.hive.ql.exec.UDF;
public class addMinuteUdf extends UDF{
final long ONE_MINUTE_IN_MILLIS=60000;
private SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
public String evaluate(String t, int minute) throws ParseException{
long time=formatter.parse(t.toString()).getTime();
Date AddingMins=new Date(time + (minute * ONE_MINUTE_IN_MILLIS));
String date = formatter.format(AddingMins);
return date;
}
}
创建后AddMinuteUdf.jar,注册到Hive中;
ADD JAR /home/Kishore/AddMinuteUdf.jar;
create temporary FUNCTION addMinute as 'HiveUDF.addMinuteUdf';
hive> select date from ATable;
OK
2014-07-06 01:28:02
Time taken: 0.108 seconds, Fetched: 1 row(s)
应用函数后
hive> select addMinuteUdf(date, 2) from ATable;
OK
2014-07-06 01:30:02
Time taken: 0.094 seconds, Fetched: 1 row(s)
您可以不使用 UDF,而是将秒数添加到日期时间,将其转换为 unix_timestamp(),然后将结果转换回日期时间。
示例:
select from_unixtime(unix_timestamp('2015-12-12 16:15:17')+3600);
这里我们加了一小时:
hive> select from_unixtime(unix_timestamp('2015-11-12 12:15:17')+${seconds_in_hour});
OK
2015-11-12 13:15:17
Time taken: 0.121 seconds, Fetched: 1 row(s)
因此,如果要添加分钟数,则应添加分钟数*60。