此函數(shù)接受日期時(shí)間對(duì)象作為參數(shù),并返回給定日期時(shí)間對(duì)象的當(dāng)前小時(shí)的分鐘。
這是 GetMinute() 函數(shù)的語(yǔ)法。
grunt> GetMinute(datetime)
假設(shè)在 HDFS 目錄 /pig_data/ 中有一個(gè)名為 date.txt 的文件,如下所示。此文件包含特定人員的出生日期的詳細(xì)信息:id,日期和時(shí)間。
date.txt
001,1989/09/26 09:00:00 002,1980/06/20 10:22:00 003,1990/12/19 03:11:44
通過(guò)使用 date_data 關(guān)系將此文件加載到Pig中,如下所示。
grunt> date_data = LOAD 'hdfs://localhost:9000/pig_data/date.txt' USING PigStorage(',') as (id:int,date:chararray);
以下是 GetMinute() 函數(shù)的示例。 GetMinute() 函數(shù)將從給定的日期時(shí)間對(duì)象中檢索小時(shí)的分鐘。因此,首先,讓我們使用 todate() 函數(shù)生成所有員工的日期時(shí)間對(duì)象。
grunt> todate_data = foreach date_data generate ToDate(date,'yyyy/MM/dd HH:mm:ss') as (date_time:DateTime ); grunt> Dump todate_data; (1989-09-26T09:00:00.000+05:30) (1980-06-20T10:22:00.000+05:30) (1990-12-19T03:11:44.000+05:30)
現(xiàn)在,讓我們使用 GetMinute() 獲得每個(gè)員工出生時(shí)間的分鐘,并將其存儲(chǔ)在名為 getminute_data 的關(guān)系中,如下所示。
grunt> getminute_data = foreach todate_data generate (date_time), GetMinute(date_time);
現(xiàn)在使用Dump運(yùn)算符驗(yàn)證getminute_data關(guān)系的內(nèi)容,如下所示。
grunt> Dump getminute_data; (1989-09-26T09:00:00.000+05:30,0) (1980-06-20T10:22:00.000+05:30,22) (1990-12-19T03:11:44.000+05:30,11)
更多建議: