0

作業情報

私は2つの異なるデータセットのソースを持っているので、最初のデータ(A)セットでいくつかの変換を行ってシンクにロードし、別のデータセット(B)で同様にいくつかの変換とロードを実行しているデータファクトリでデータフローを作成しました別のシンクに。

問題

ここで、日付列 DT_COLUMN_B(01-01-2020 16:32) と比較する必要がある最初のデータセット (A) に日付列 DT_COLUMN_A(11-04-2020 01:17:40) があるといういくつかの要件があります。 :00) を 2 番目のデータセット (B) に格納し、比較した出力を列として 2 番目のデータセット (B) に格納します。

したがって、データセット A の日付列の最小値と最大値 (日付範囲) が必要です。それをデータセット B の日付列の最小値と最大値に適用し、A と B で一致する日付を見つけて、NO と一致しない場合は YES として保存します。 .

コードアプローチの考え方

必要なロジック:

if(min(DT_COLUMN_A) and max(DT_COLUMN_A) == min(DT_COLUMN_B) and max(DT_COLUMN_B) then YES else No.

ADF データ フローでこれを達成しようとしていますが、実行できません。

4

1 に答える 1