Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add input boxes for required user inputs #33183

Merged
merged 2 commits into from
Nov 22, 2024
Merged

Add input boxes for required user inputs #33183

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
e6c456e
Add input boxes for required user inputs
Nov 21, 2024
ad21e96
Remove unnecessary comments.
Nov 22, 2024
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
621 changes: 318 additions & 303 deletions examples/notebooks/beam-ml/automatic_model_refresh.ipynb
View file
Open in desktop

Large diffs are not rendered by default.

458 changes: 229 additions & 229 deletions examples/notebooks/beam-ml/bigquery_enrichment_transform.ipynb
View file
Open in desktop

Large diffs are not rendered by default.

40 changes: 20 additions & 20 deletions examples/notebooks/beam-ml/bigtable_enrichment_transform.ipynb
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -151,9 +151,9 @@
},
"outputs": [],
"source": [
"PROJECT_ID = \"<PROJECT_ID>\"\n",
"INSTANCE_ID = \"<INSTANCE_ID>\"\n",
"TABLE_ID = \"<TABLE_ID>\""
"PROJECT_ID = \"<PROJECT_ID>\" # @param {type:'string'}\n",
"INSTANCE_ID = \"<INSTANCE_ID>\" # @param {type:'string'}\n",
"TABLE_ID = \"<TABLE_ID>\" # @param {type:'string'}"
]
},
{
Expand Down Expand Up @@ -457,10 +457,10 @@
"outputs": [],
"source": [
"# Replace <TOPIC_NAME> with the name of your Pub/Sub topic.\n",
"TOPIC = \"<TOPIC_NAME>\"\n",
"TOPIC = \"<TOPIC_NAME>\" # @param {type:'string'}\n",
"\n",
"# Replace <SUBSCRIPTION_PATH> with the subscription for your topic.\n",
"SUBSCRIPTION = \"<SUBSCRIPTION_PATH>\"\n"
"SUBSCRIPTION = \"<SUBSCRIPTION_PATH>\" # @param {type:'string'}\n"
]
},
{
Expand Down Expand Up @@ -532,16 +532,16 @@
},
{
"cell_type": "markdown",
"metadata": {
"id": "UEpjy_IsW4P4"
},
"source": [
"The `row_key` parameter represents the field in input schema (`beam.Row`) that contains the row key for a row in the table.\n",
"\n",
"Starting with Apache Beam version 2.54.0, you can perform either of the following tasks when a table uses composite row keys:\n",
"* Modify the input schema to contain the row key in the format required by Bigtable.\n",
"* Use a custom enrichment handler. For more information, see the [example handler with composite row key support](https://www.toptal.com/developers/paste-gd/BYFGUL08#)."
],
"metadata": {
"id": "UEpjy_IsW4P4"
}
]
},
{
"cell_type": "code",
Expand Down Expand Up @@ -636,6 +636,9 @@
},
{
"cell_type": "markdown",
"metadata": {
"id": "fe3bIclV1jZ5"
},
"source": [
"To provide a `lambda` function for using a custom join with the enrichment transform, see the following example.\n",
"\n",
Expand All @@ -648,13 +651,13 @@
" ...\n",
" )\n",
"```"
],
"metadata": {
"id": "fe3bIclV1jZ5"
}
]
},
{
"cell_type": "markdown",
"metadata": {
"id": "uilxdknE3ihO"
},
"source": [
"Because the enrichment transform makes API calls to the remote service, use the `timeout` parameter to specify a timeout duration of 10 seconds:\n",
"\n",
Expand All @@ -667,10 +670,7 @@
" ...\n",
" )\n",
"```"
],
"metadata": {
"id": "uilxdknE3ihO"
}
]
},
{
"cell_type": "markdown",
Expand Down Expand Up @@ -855,11 +855,11 @@
],
"metadata": {
"colab": {
"provenance": [],
"toc_visible": true,
"collapsed_sections": [
"RpqZFfFfA_Dt"
]
],
"provenance": [],
"toc_visible": true
},
"kernelspec": {
"display_name": "Python 3",
Expand Down
Loading
Loading