diff options
| author | chaochaoc <[email protected]> | 2024-07-01 15:40:35 +0800 |
|---|---|---|
| committer | chaochaoc <[email protected]> | 2024-07-01 15:40:35 +0800 |
| commit | 67a40e271922f0a0da130c9e2ee5fce52a6c2264 (patch) | |
| tree | 26c4981ca0c085c115049920d667f6c7676fb1cf /src | |
| parent | 7723c48e5bf81f45fb5876fc06a3d79d3f3259bb (diff) | |
[GAL-602] feat: update key-by expression
Diffstat (limited to 'src')
| -rw-r--r-- | src/main/resources/jobs/job.yml | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/resources/jobs/job.yml b/src/main/resources/jobs/job.yml index 1eca050..3f8b7d3 100644 --- a/src/main/resources/jobs/job.yml +++ b/src/main/resources/jobs/job.yml @@ -1348,7 +1348,7 @@ pipeline: data-type: INT where: - on: sip-double-way-records.ok - key-by: vsys_id, SORT_ADDRESS( sip_originator_sdp_connect_ip, sip_originator_sdp_media_port, sip_responder_sdp_connect_ip, sip_responder_sdp_media_port ) + key-by: vsys_id, SORT_ADDRESS( sip_originator_sdp_connect_ip, sip_originator_sdp_media_port, sip_responder_sdp_connect_ip, sip_responder_sdp_media_port ) AS address # SIP process: - SET sip FROM withColumns(recv_time to rtp_originator_dir) @@ -1434,7 +1434,7 @@ pipeline: # TODO USE EVENT - SCHEDULING USING PROCESS TIME FOR NOW + 6 * 60 * 1000 - on: rtp-records - key-by: vsys_id, SORT_ADDRESS( client_ip, client_port, server_ip, server_port ) + key-by: vsys_id, SORT_ADDRESS( client_ip, client_port, server_ip, server_port ) AS address process: - APPEND rtp FROM withColumns(recv_time to rtp_originator_dir) - if: '@sip.isNotNull' |