Skip to content

Commit

Permalink
Shorten code_sample label (apache#26693)
Browse files Browse the repository at this point in the history
avoiding "Line too long" pylint
  • Loading branch information
RyuSA committed May 28, 2023
1 parent ce41d2b commit ec60e32
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions sdks/python/apache_beam/examples/snippets/snippets.py
Original file line number Diff line number Diff line change
Expand Up @@ -1206,14 +1206,14 @@ def model_bigqueryio(
}
# [END model_bigqueryio_write_schema]

# [START model_bigqueryio_storage_write_api_with_frequency_and_multiple_streams]
# [START model_bigqueryio_storage_write_api_with_frequency]
# The SDK for Python does not support `withNumStorageWriteApiStreams`
quotes | "StorageWriteAPIWithFrequency" >> beam.io.WriteToBigQuery(
table_spec,
schema=table_schema,
method=beam.io.WriteToBigQuery.Method.STORAGE_WRITE_API,
triggering_frequency=5)
# [END model_bigqueryio_storage_write_api_with_frequency_and_multiple_streams]
# [END model_bigqueryio_storage_write_api_with_frequency]

# [START model_bigqueryio_write_dynamic_destinations]
fictional_characters_view = beam.pvalue.AsDict(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -845,7 +845,7 @@ BigQueryIO.writeTableRows()
);
{{< /highlight >}}
{{< highlight py >}}
{{< code_sample "sdks/python/apache_beam/examples/snippets/snippets.py" model_bigqueryio_storage_write_api_with_frequency_and_multiple_streams >}}
{{< code_sample "sdks/python/apache_beam/examples/snippets/snippets.py" model_bigqueryio_storage_write_api_with_frequency >}}
{{< /highlight >}}

The number of streams defines the parallelism of the BigQueryIO Write transform
Expand Down

0 comments on commit ec60e32

Please sign in to comment.