Additional schema change to reconcile with Perl importer
This commit is contained in:
parent
ff7c6fa0ad
commit
10498b57e1
1 changed files with 8 additions and 8 deletions
|
|
@ -245,7 +245,7 @@ CREATE TABLE IF NOT EXISTS ble_observation (
|
|||
payload_kind TEXT,
|
||||
payload_node TEXT,
|
||||
payload_seq INTEGER,
|
||||
payload_tx_payload_epoch_ms INTEGER,
|
||||
payload_tx_epoch_ms INTEGER,
|
||||
payload_legacy_uptime INTEGER,
|
||||
|
||||
parse_warning TEXT
|
||||
|
|
@ -477,26 +477,26 @@ WITH x AS (
|
|||
receiver,
|
||||
heard,
|
||||
payload_seq,
|
||||
MIN(payload_tx_payload_epoch_ms) AS payload_tx_payload_epoch_ms
|
||||
MIN(payload_tx_epoch_ms) AS payload_tx_epoch_ms
|
||||
FROM ble_observation
|
||||
WHERE payload_tx_payload_epoch_ms IS NOT NULL
|
||||
AND payload_tx_payload_epoch_ms > 0
|
||||
WHERE payload_tx_epoch_ms IS NOT NULL
|
||||
AND payload_tx_epoch_ms > 0
|
||||
GROUP BY trial_id, receiver, heard, payload_seq
|
||||
),
|
||||
y AS (
|
||||
SELECT
|
||||
x.*,
|
||||
LAG(payload_tx_payload_epoch_ms) OVER (
|
||||
LAG(payload_tx_epoch_ms) OVER (
|
||||
PARTITION BY trial_id, receiver, heard
|
||||
ORDER BY payload_seq
|
||||
) AS prev_payload_tx_payload_epoch_ms
|
||||
) AS prev_payload_tx_epoch_ms
|
||||
FROM x
|
||||
)
|
||||
SELECT
|
||||
*,
|
||||
payload_tx_payload_epoch_ms - prev_payload_tx_payload_epoch_ms AS tx_payload_epoch_step_ms
|
||||
payload_tx_epoch_ms - prev_payload_tx_epoch_ms AS tx_payload_epoch_step_ms
|
||||
FROM y
|
||||
WHERE prev_payload_tx_payload_epoch_ms IS NOT NULL;
|
||||
WHERE prev_payload_tx_epoch_ms IS NOT NULL;
|
||||
|
||||
-- ---------------------------------------------------------------------------
|
||||
-- v_map_observation_points
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue