はじめに
トランスフォーメーション言語
定数
演算子
変数
日付
関数
- 関数の分類
  - 集計関数
  - 集計関数とNULL
    - フィルタ条件
  - 文字関数
  - 変換関数
  - データクレンジング関数
  - 日付関数
  - エンコード関数
  - 財務関数
  - 数値関数
  - 科学関数
  - 特殊関数
  - 文字列関数
  - テスト関数
  - ウィンドウ関数
  - 変数関数
- ABORT
- ABS
- ADD_TO_DATE
- AES_DECRYPT
- AES_ENCRYPT
- ASCII
- AVG
- CEIL
- CHOOSE
- CHR
- CHRCODE
- COMPRESS
- CONCAT
- CONVERT_BASE
- COS
- COSH
- COUNT
- CRC32
- CUME
- DATE_COMPARE
- DATE_DIFF
- DEC_BASE64
- DECODE
- DECOMPRESS
- ENC_BASE64
- ERROR
- EXP
- FIRST
- FLOOR
- FV
- GET_DATE_PART
- GREATEST
- IIF
- IN
- INDEXOF
- INITCAP
- INSTR
- ISNULL
- IS_DATE
- IS_NUMBER
- IS_SPACES
- LAG
- LAST
- LAST_DAY
- LEAD
- LEAST
- LENGTH
- LN
- LOG
- LOOKUP
- LOWER
- LPAD
- LTRIM
- MAKE_DATE_TIME
- MAX (Dates)
- MAX (Numbers)
- MAX (String)
- MD5
- MEDIAN
- METAPHONE
- MIN (Dates)
- MIN (Numbers)
- MIN (String)
- MOD
- MOVINGAVG
- MOVINGSUM
- NPER
- PERCENTILE
- PMT
- POWER
- PV
- RAND
- RATE
- REG_EXTRACT
- REG_MATCH
- REG_REPLACE
- REPLACECHR
- REPLACESTR
- REVERSE
- ROUND (Dates)
- ROUND（数値）
- RPAD
- RTRIM
- SETCOUNTVARIABLE
- SET_DATE_PART
- SETMAXVARIABLE
- SETMINVARIABLE
- SETVARIABLE
- SIGN
- SIN
- SINH
- SOUNDEX
- SQRT
- STDDEV
- SUBSTR
- SUM
- SYSTIMESTAMP
- TAN
- TANH
- TIME_RANGE
- TO_BIGINT
- TO_CHAR (Dates)
- TO_CHAR（数値）
- TO_DATE
- TO_DECIMAL
- TO_FLOAT
- TO_INTEGER
- TRUNC (Dates)
- TRUNC（数値）
- UPPER
- VARIANCE
カスタム関数の作成
カスタム関数APIリファレンス

トランスフォーメーション言語リファレンス

10.4.0
- 10.5

前へ次へ

LAG

式トランスフォーメーションで現在の行の前にある行のオフセット番号である値を返します。この関数は、Hadoop環境のSparkエンジンでマッピングを実行するときに、現在の行の値を前の行の値と比較するために使用します。

遅延値は一連のデータの現在の行の前に表示されます。

トランスフォーメーションでLAGを使用するときは、ウィンドウ化のトランスフォーメーションを構成する必要があります。ウィンドウ化プロパティは、データのパーティション化と順序付けの方法を定義します。

構文

LAG ( column_name, offset, default )

以下の表に、このコマンドの引数を示します。

引数	必須/ オプション	説明
column_name	必須	関数で操作する対象の列または式。
offset	必須	整数データ型。値の取得元である現在の行の前の行数。
default	オプション	オフセットがパーティションまたはテーブルの境界の外側にある場合に返されるデフォルト値。デフォルトはNULLです。

戻り値

指定されたcolumn_name
のデータ型。

戻り値が指定されたパーティションの境界の外側にある場合はDefault
。

default
が省略されている場合、またはNULLに設定されている場合は、NULL。

例

次の式は、前の順序が配置された日付を返します。

LAG ( ORDER_DATE, 1, NULL )

ORDER_DATE	ORDER_ID	RETURN VALUE
2017/09/25	1	NULL
2017/09/26	2	2017/09/25
2017/09/27	3	2017/09/26
2017/09/28	4	2017/09/27
2017/09/29	5	2017/09/28
2017/09/30	6	2017/09/29

最初の行の遅延値はパーティションの外側にあるため、関数はデフォルト値であるNULLを返しました。

次の例では、組織がトリップID、イベントID、およびタイムスタンプを含む車両からのGPS pingを受信します。各pingの時間差を計算するとします。

次の式は、2つの別々のトリップについて、現在の行と前の行の時間差を計算します。

DATE_DIFF( EVENT_TIME, LAG ( EVENT_TIME, 1, NULL ), 'ss' )

データをトリップIDでパーティション化し、イベントIDで順序付けします。

TRIP_ID	EVENT_ID	EVENT_TIME	RETURN VALUE
101	1	2017-05-03 12:00:00	NULL
101	2	2017-05-03 12:00:34	34
101	3	2017-05-03 12:02:00	86
102	1	2017-05-03 12:00:00	NULL
102	2	2017-05-03 12:01:56	116
102	3	2017-05-03 12:02:00	4