Skip to content

Commit

Permalink
Add input boxes for required user inputs
Browse files Browse the repository at this point in the history
  • Loading branch information
Claude committed Nov 21, 2024
1 parent a06454a commit e6c456e
Show file tree
Hide file tree
Showing 15 changed files with 1,998 additions and 2,353 deletions.
619 changes: 318 additions & 301 deletions examples/notebooks/beam-ml/automatic_model_refresh.ipynb

Large diffs are not rendered by default.

458 changes: 229 additions & 229 deletions examples/notebooks/beam-ml/bigquery_enrichment_transform.ipynb

Large diffs are not rendered by default.

40 changes: 20 additions & 20 deletions examples/notebooks/beam-ml/bigtable_enrichment_transform.ipynb
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

0 comments on commit e6c456e

Please sign in to comment.