Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -573,16 +573,16 @@ for i in $(seq 1 100000); do echo "$i"; done | \
Delete all records with `id` greater than 10:

```bash
{{ ydb-cli }} -p quickstart sql \
-s 'SELECT t.id FROM test_delete_1 AS t WHERE t.id > 10' \
--format json-unicode | \
{{ ydb-cli }} -p quickstart sql \
-s 'DECLARE $lines AS List<Struct<id:UInt64>>;
DELETE FROM test_delete_1 WHERE id IN (SELECT tl.id FROM AS_TABLE($lines) AS tl)' \
--input-framing newline-delimited \
--input-param-name lines \
--input-batch adaptive \
--input-batch-max-rows 10000
--input-batch-max-rows 10000 \
--input-file <(ydb -p quickstart sql \
-s 'SELECT t.id FROM test_delete_1 AS t WHERE t.id < 10' \
--format json-unicode)
```

#### Processing messages read from a topic {#example-adaptive-pipeline-from-topic}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -570,16 +570,16 @@ for i in $(seq 1 100000); do echo "$i";done | \
Удалим все записи со значениями `id` больше 10:

```bash
{{ ydb-cli }} -p quickstart sql \
-s 'SELECT t.id FROM test_delete_1 AS t WHERE t.id > 10' \
--format json-unicode | \
{{ ydb-cli }} -p quickstart sql \
-s 'DECLARE $lines AS List<Struct<id:UInt64>>;
DELETE FROM test_delete_1 WHERE id IN (SELECT tl.id FROM AS_TABLE($lines) AS tl)' \
--input-framing newline-delimited \
--input-param-name lines \
--input-batch adaptive \
--input-batch-max-rows 10000
--input-batch-max-rows 10000 \
--input-file <(ydb -p quickstart sql \
-s 'SELECT t.id FROM test_delete_1 AS t WHERE t.id < 10' \
--format json-unicode)
```

#### Обработка сообщений, считываемых из топика {#example-adaptive-pipeline-from-topic}
Expand Down