Skip to content

Commit c222436

Browse files
authored
[docs] Fixing documentation about lookup change log producers (#6860)
1 parent 8c41658 commit c222436

File tree

3 files changed

+3
-6
lines changed

3 files changed

+3
-6
lines changed

docs/content/primary-key-table/changelog-producer.md

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,8 +61,7 @@ By specifying `'changelog-producer' = 'input'`, Paimon writers rely on their inp
6161
If your input can’t produce a complete changelog but you still want to get rid of the costly normalized operator, you
6262
may consider using the `'lookup'` changelog producer.
6363

64-
By specifying `'changelog-producer' = 'lookup'`, Paimon will generate changelog through `'lookup'` before committing
65-
the data writing (You can also enable [Async Compaction]({{< ref "primary-key-table/compaction#asynchronous-compaction" >}})).
64+
By specifying `'changelog-producer' = 'lookup'`, Paimon will generate changelog through `'lookup'` during compaction (You can also enable [Async Compaction]({{< ref "primary-key-table/compaction#asynchronous-compaction" >}})). By default, lookup compaction is performed before committing written data unless disabled by `write-only` property.
6665

6766
{{< img src="/img/changelog-producer-lookup.png">}}
6867

docs/layouts/shortcodes/generated/core_configuration.html

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -126,7 +126,7 @@
126126
<td><h5>changelog-producer</h5></td>
127127
<td style="word-wrap: break-word;">none</td>
128128
<td><p>Enum</p></td>
129-
<td>Whether to double write to a changelog file. This changelog file keeps the details of data changes, it can be read directly during stream reads. This can be applied to tables with primary keys. <br /><br />Possible values:<ul><li>"none": No changelog file.</li><li>"input": Double write to a changelog file when flushing memory table, the changelog is from input.</li><li>"full-compaction": Generate changelog files with each full compaction.</li><li>"lookup": Generate changelog files through 'lookup' before committing the data writing.</li></ul></td>
129+
<td>Whether to double write to a changelog file. This changelog file keeps the details of data changes, it can be read directly during stream reads. This can be applied to tables with primary keys. <br /><br />Possible values:<ul><li>"none": No changelog file.</li><li>"input": Double write to a changelog file when flushing memory table, the changelog is from input.</li><li>"full-compaction": Generate changelog files with each full compaction.</li><li>"lookup": Generate changelog files through 'lookup' compaction.</li></ul></td>
130130
</tr>
131131
<tr>
132132
<td><h5>changelog-producer.row-deduplicate</h5></td>

paimon-api/src/main/java/org/apache/paimon/CoreOptions.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3494,9 +3494,7 @@ public enum ChangelogProducer implements DescribedEnum {
34943494

34953495
FULL_COMPACTION("full-compaction", "Generate changelog files with each full compaction."),
34963496

3497-
LOOKUP(
3498-
"lookup",
3499-
"Generate changelog files through 'lookup' before committing the data writing.");
3497+
LOOKUP("lookup", "Generate changelog files through 'lookup' compaction.");
35003498

35013499
private final String value;
35023500
private final String description;

0 commit comments

Comments
 (0)