Skip to content

Commit 7fb0778

Browse files
committed
Add looker metrics for IcebergIO
1 parent 5312b03 commit 7fb0778

5 files changed

Lines changed: 85 additions & 1 deletion

File tree

.github/workflows/beam_PostCommit_Java_IO_Performance_Tests.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -64,7 +64,7 @@ jobs:
6464
matrix:
6565
job_name: ["beam_PostCommit_Java_IO_Performance_Tests"]
6666
job_phrase: ["Run Java PostCommit IO Performance Tests"]
67-
test_case: ["IcebergPerformanceTest"]
67+
test_case: ["IcebergPerformanceTest", "GCSPerformanceTest", "BigTablePerformanceTest", "BigQueryStorageApiStreamingPerformanceTest"]
6868
steps:
6969
- uses: actions/checkout@v7
7070
- name: Setup repository

.test-infra/tools/refresh_looker_metrics.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,8 @@
3434
("33", ["21", "70", "116", "69", "115"]), # BigTableIO_Write
3535
("34", ["22", "56", "96", "55", "95"]), # TextIO_Read
3636
("35", ["23", "64", "110", "63", "109"]), # TextIO_Write
37+
("113", ["386", "388", "390", "392", "394"]), # IcebergIO_Read
38+
("114", ["387", "389", "391", "393", "395"]), # IcebergIO_Write
3739
("75", ["258", "259", "260", "261", "262"]), # TensorFlow MNIST
3840
("76", ["233", "234", "235", "236", "237"]), # PyTorch BERT base uncased
3941
("77", ["238", "239", "240", "241", "242"]), # PyTorch BERT large uncased

website/www/site/content/en/performance/_index.md

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@ writing to various Beam IOs.
3838
- [BigQuery](/performance/bigquery)
3939
- [BigTable](/performance/bigtable)
4040
- [TextIO](/performance/textio)
41+
- [IcebergIO](/performance/icebergio)
4142

4243
# Measured Beam Python ML Pipelines
4344

Lines changed: 50 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,50 @@
1+
---
2+
title: "IcebergIO Performance"
3+
---
4+
5+
<!--
6+
Licensed under the Apache License, Version 2.0 (the "License");
7+
you may not use this file except in compliance with the License.
8+
You may obtain a copy of the License at
9+
10+
http://www.apache.org/licenses/LICENSE-2.0
11+
12+
Unless required by applicable law or agreed to in writing, software
13+
distributed under the License is distributed on an "AS IS" BASIS,
14+
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15+
See the License for the specific language governing permissions and
16+
limitations under the License.
17+
-->
18+
19+
# IcebergIO Performance
20+
21+
The following graphs show various metrics when reading from or writing to Apache Iceberg tables using
22+
IcebergIO. See the [glossary](/performance/glossary) for definitions.
23+
24+
## Read
25+
26+
### What is the estimated cost of reading from Apache Iceberg tables using IcebergIO?
27+
28+
{{< performance_looks io="icebergio" read_or_write="read" section="test_name" >}}
29+
30+
### How has various metrics changed when reading from Apache Iceberg tables using IcebergIO for different Beam SDK versions?
31+
32+
{{< performance_looks io="icebergio" read_or_write="read" section="version" >}}
33+
34+
### How has various metrics changed over time when reading from Apache Iceberg tables using IcebergIO?
35+
36+
{{< performance_looks io="icebergio" read_or_write="read" section="date" >}}
37+
38+
## Write
39+
40+
### What is the estimated cost of writing to Apache Iceberg tables using IcebergIO?
41+
42+
{{< performance_looks io="icebergio" read_or_write="write" section="test_name" >}}
43+
44+
### How has various metrics changed when writing to Apache Iceberg tables using IcebergIO for different Beam SDK versions?
45+
46+
{{< performance_looks io="icebergio" read_or_write="write" section="version" >}}
47+
48+
### How has various metrics changed over time when writing to Apache Iceberg tables using IcebergIO?
49+
50+
{{< performance_looks io="icebergio" read_or_write="write" section="date" >}}

website/www/site/data/performance.yaml

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,6 +107,37 @@ looks:
107107
title: AvgInputThroughputBytesPerSec by Version
108108
- id: fVVHhXCrHNgBG52TJsTjR8VbmWCCQnVN
109109
title: AvgInputThroughputElementsPerSec by Version
110+
icebergio:
111+
read:
112+
folder: 113
113+
test_name:
114+
- id: x5R7w8VnzkccgzrBTWQ82J7JBNtkGxH2
115+
title: Read IcebergIO RunTime and EstimatedCost
116+
date:
117+
- id: HQsKkmn7cS7m5bCYzPBYqnnFM6MXvJgV
118+
title: AvgOutputThroughputBytesPerSec by Date
119+
- id: MNYqD2ZCwV2XfYjwDg4NDVT7vr4Ytpz2
120+
title: AvgOutputThroughputElementsPerSec by Date
121+
version:
122+
- id: Cf7wGQfrM4hn8Wdf64ZjwshrHHdZKmKs
123+
title: AvgOutputThroughputBytesPerSec by Version
124+
- id: MGSX85MhCnCFFWYzSCGS36JRWxcBccqd
125+
title: AvgOutputThroughputElementsPerSec by Version
126+
write:
127+
folder: 114
128+
test_name:
129+
- id: yvvWB2JbbbFQ4R5MTwF2hbVW2X4bDxnY
130+
title: Write IcebergIO RunTime and EstimatedCost
131+
date:
132+
- id: Gcw6jfhvvkkHKDwqqTkhZtYYNNH2Z8DZ
133+
title: AvgInputThroughputBytesPerSec by Date
134+
- id: RYtRGKsxBRkyRgWk6RGjshFnZPk76vhM
135+
title: AvgInputThroughputElementsPerSec by Date
136+
version:
137+
- id: B5q25ktnXNhHxpYrGmqzgcGMgX26zvM3
138+
title: AvgInputThroughputBytesPerSec by Version
139+
- id: VfMWk6rk26JQNr8wRpsK5Gk6XQPfd7vW
140+
title: AvgInputThroughputElementsPerSec by Version
110141
pytorchbertbase:
111142
write:
112143
folder: 76

0 commit comments

Comments
 (0)