Skip to content

Commit d3102b9

Browse files
LiebingYuLiebing
andauthored
[blog] Fix text format of "Tiering Service Deep Dive" (#1411)
Co-authored-by: Liebing <[email protected]>
1 parent f2d3b83 commit d3102b9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

website/blog/2025-07-01-tiering-service.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -133,7 +133,7 @@ The **TieringSourceReader** pulls assigned splits from the enumerator, uses a `T
133133
- **LogScanner** for `TieringLogSplit` (append-only tables)
134134
- **BoundedSplitReader** for `TieringSnapshotSplit` (primary-keyed tables)
135135
- **Data Fetch:** The chosen reader fetches the records defined by the split’s offset or snapshot boundaries from the Fluss server.
136-
- **Lake Writing"** Retrieved records are handed off to the lake writer, which persists them into the data lake.
136+
- **Lake Writing:** Retrieved records are handed off to the lake writer, which persists them into the data lake.
137137

138138
By cleanly separating split assignment, reader selection, data fetching, and lake writing, the TieringSourceReader ensures scalable, parallel ingestion of streaming and snapshot data into your lakehouse.
139139

@@ -157,7 +157,7 @@ public interface LakeTieringFactory {
157157
- **createLakeWriter(WriterInitContext)**: builds a `LakeWriter` to convert Fluss rows into the target table format.
158158
- **getWriteResultSerializer()**: supplies a serializer for the writer’s output.
159159
- **createLakeCommitter(CommitterInitContext)**: constructs a `LakeCommitter` to finalize and atomically commit data files.
160-
- **getCommittableSerializer()**: provides a serializer for committable tokens.```
160+
- **getCommittableSerializer()**: provides a serializer for committable tokens.
161161

162162
By default, Fluss includes a Paimon-backed tiering factory; Iceberg support is coming soon. Once the `TieringSourceReader` writes a batch of records through the `LakeWriter`, it emits the resulting write metadata downstream to the **TieringCommitOperator**, which then commits those changes both in the lakehouse and back to the Fluss cluster.
163163

0 commit comments

Comments
 (0)