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.

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

[Website] update links with 404 status code #24635

Merged
merged 1 commit into from
Dec 22, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
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
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