Skip to content

Commit 434ea77

Browse files
author
Liebing
committed
[blog] Fix text format of "Tiering Service Deep Dive"
1 parent a0788b1 commit 434ea77

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
@@ -151,7 +151,7 @@ The **TieringSourceReader** pulls assigned splits from the enumerator, uses a `T
151151
- **LogScanner** for `TieringLogSplit` (append-only tables)
152152
- **BoundedSplitReader** for `TieringSnapshotSplit` (primary-keyed tables)
153153
- **Data Fetch:** The chosen reader fetches the records defined by the split’s offset or snapshot boundaries from the Fluss server.
154-
- **Lake Writing"** Retrieved records are handed off to the lake writer, which persists them into the data lake.
154+
- **Lake Writing:** Retrieved records are handed off to the lake writer, which persists them into the data lake.
155155

156156
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.
157157

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

180180
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.
181181

0 commit comments

Comments
 (0)