Skip to content
Merged
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
8 changes: 4 additions & 4 deletions docs/docs/flink/procedures/compaction.md
Original file line number Diff line number Diff line change
Expand Up @@ -130,9 +130,9 @@ To compact databases. Arguments:

- `mode`: compact mode. "divided" (default): start a sink for each table, detecting the new table requires restarting the job; "combined": start a single combined sink for all tables, the new table will be automatically detected.

- `includingTables`: to specify tables. You can use regular expression.
- `includingTables`: to specify tables. The format is `databaseName.tableName`, and the whole name must match. You can use regular expression, for example `.*\.table_.*`.

- `excludingTables`: to specify tables that are not compacted. You can use regular expression.
- `excludingTables`: to specify tables that are not compacted. The usage is same as `includingTables`.

- `tableOptions`: additional dynamic options of the table.

Expand Down Expand Up @@ -198,8 +198,8 @@ CALL [catalog.]sys.compact_database(
CALL sys.compact_database(
including_databases => 'db1|db2',
mode => 'combined',
including_tables => 'table_.*',
excluding_tables => 'ignore',
including_tables => '.*\.table_.*',
excluding_tables => '.*\.ignore',
table_options => 'sink.parallelism=4',
compact_strategy => 'full');
```
Expand Down
6 changes: 3 additions & 3 deletions docs/docs/maintenance/dedicated-compaction.mdx
Original file line number Diff line number Diff line change
Expand Up @@ -221,8 +221,8 @@ CALL sys.compact_database(
CALL sys.compact_database(
including_databases => 'db1|db2',
mode => 'combined',
including_tables => 'table_.*',
excluding_tables => 'ignore',
including_tables => '.*\.table_.*',
excluding_tables => '.*\.ignore',
table_options => 'sink.parallelism=4'
)
```
Expand Down Expand Up @@ -444,7 +444,7 @@ Example: compact historical partitions for tables in database
```sql
-- history partition compact table
CALL sys.compact_database(
includingDatabases => 'test_db',
including_databases => 'test_db',
mode => 'combined',
partition_idle_time => '1 d'
);
Expand Down
Loading