Skip to content

Commit

Permalink
Merge pull request #24635: [Website] update links with 404 status code
Browse files Browse the repository at this point in the history
  • Loading branch information
aromanenko-dev authored Dec 22, 2022
2 parents ce5fcac + 4764f0e commit 3f67b2c
Show file tree
Hide file tree
Showing 5 changed files with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -168,7 +168,7 @@ and <a href="https://spark.apache.org/docs/latest/api/python/reference/api/pyspa
</td>
<td><a href="https://beam.apache.org/releases/pydoc/{{< param release_latest >}}/apache_beam.io.gcp.gcsio.html">io.gcp.gcsio</a>
</td>
<td rowspan="2" ><a href="https://spark.apache.org/docs/latest/api/python/pyspark.streaming.html#pyspark.streaming.StreamingContext.textFileStream">textFileStream</a>
<td rowspan="2" ><a href="https://spark.apache.org/docs/latest/api/python/reference/api/pyspark.streaming.StreamingContext.html#pyspark.streaming.StreamingContext">textFileStream</a>
</td>
</tr>
<tr>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ When a post-commit test fails, follow the provided steps for your situation.

### I found a test failure {#found-failing-test}

1. Create a [GitHub issue](https://github.com/apache/tag-beam-it/issues/new/choose) and assign it to yourself.
1. Create a [GitHub issue](https://github.com/apache/beam/issues/new/choose) and assign it to yourself.
- Components: testing, anything else relevant
- Label: precommit
- Reference this page in the description.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -55,8 +55,8 @@ down to a specific test suite by clicking on it.
## Triage Process

1. [Search for existing
issues](https://github.com/apache/tag-beam-it/issues)
1. Create a new issue if needed: [GitHub Issues](https://github.com/apache/tag-beam-it/issues/new/choose)
issues](https://github.com/apache/beam/issues)
1. Create a new issue if needed: [GitHub Issues](https://github.com/apache/beam/issues/new/choose)
- Components: testing, anything else relevant
- Label: precommit
- Reference this page in the description.
Expand Down
2 changes: 1 addition & 1 deletion website/www/site/content/en/contribute/runner-guide.md
Original file line number Diff line number Diff line change
Expand Up @@ -630,7 +630,7 @@ depend on the particulars of the Java SDK.
## The Runner API protos

The [Runner
API](https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/beam_runner_api.proto)
API](https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/beam_runner_api.proto)
refers to a specific manifestation of the concepts in the Beam model, as a
protocol buffers schema. Even though you should not manipulate these messages
directly, it can be helpful to know the canonical data that makes up a
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7421,7 +7421,7 @@ To create an SDK wrapper for use in a Python pipeline, do the following:
1. Create a Python module for your cross-language transform(s).
2. In the module, use one of the [`PayloadBuilder`](https://beam.apache.org/releases/pydoc/current/apache_beam.transforms.external.html#apache_beam.transforms.external.PayloadBuilder) classes to build the payload for the initial cross-language transform expansion request.

The parameter names and types of the payload should map to parameter names and types of the configuration POJO provided to the Java `ExternalTransformBuilder`. Parameter types are mapped across SDKs using a [Beam schema](https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/schema.proto). Parameter names are mapped by simply converting Python underscore-separated variable names to camel-case (Java standard).
The parameter names and types of the payload should map to parameter names and types of the configuration POJO provided to the Java `ExternalTransformBuilder`. Parameter types are mapped across SDKs using a [Beam schema](https://github.com/apache/beam/blob/master/model/pipeline/src/main/proto/org/apache/beam/model/pipeline/v1/schema.proto). Parameter names are mapped by simply converting Python underscore-separated variable names to camel-case (Java standard).

In the following example, [kafka.py](https://github.com/apache/beam/blob/master/sdks/python/apache_beam/io/kafka.py) uses `NamedTupleBasedPayloadBuilder` to build the payload. The parameters map to the Java [KafkaIO.External.Configuration](https://github.com/apache/beam/blob/master/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java) config object defined in the previous section.

Expand Down

0 comments on commit 3f67b2c

Please sign in to comment.