Skip to content

Commit

Permalink
Merge pull request #23571: Replace website references to deprecated a…
Browse files Browse the repository at this point in the history
…ws / kinesis modules with more recent aws2 module.
  • Loading branch information
aromanenko-dev authored Oct 11, 2022
2 parents 36d52b7 + da9d686 commit 5595f40
Show file tree
Hide file tree
Showing 3 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -82,7 +82,7 @@ and <a href="https://spark.apache.org/docs/latest/api/java/org/apache/spark/stre
<tr>
<td>S3<br>(Using the <code>s3://</code> URI)
</td>
<td><a href="https://beam.apache.org/releases/javadoc/{{< param release_latest >}}/org/apache/beam/sdk/io/FileIO.html">FileIO</a> + <a href="https://beam.apache.org/releases/javadoc/{{< param release_latest >}}/org/apache/beam/sdk/io/aws/options/S3Options.html">S3Options</a>
<td><a href="https://beam.apache.org/releases/javadoc/{{< param release_latest >}}/org/apache/beam/sdk/io/FileIO.html">FileIO</a> + <a href="https://beam.apache.org/releases/javadoc/{{< param release_latest >}}/org/apache/beam/sdk/io/aws2/options/S3Options.html">S3Options</a>
</td>
</tr>
<tr>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -729,7 +729,7 @@ static SnowflakeIO.CsvMapper<GenericRecord> getCsvMapper() {
{{< /highlight >}}
## Using SnowflakeIO with AWS S3
To be able to use AWS S3 bucket as `stagingBucketName` is required to:
1. Create `PipelineOptions` interface which is [extending](https://beam.apache.org/documentation/io/built-in/snowflake/#extending-pipeline-options) `SnowflakePipelineOptions` and [S3Options](https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/aws/options/S3Options.html)
1. Create `PipelineOptions` interface which is [extending](https://beam.apache.org/documentation/io/built-in/snowflake/#extending-pipeline-options) `SnowflakePipelineOptions` and [S3Options](https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/aws2/options/S3Options.html)
with `AwsAccessKey` and `AwsSecretKey` options. Example:

{{< highlight >}}
Expand Down Expand Up @@ -763,7 +763,7 @@ options.setAwsCredentialsProvider(
Pipeline p = Pipeline.create(options);
{{< /highlight >}}

**Note**: Remember to set `awsRegion` from [S3Options](https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/aws/options/S3Options.html).
**Note**: Remember to set `awsRegion` from [S3Options](https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/aws2/options/S3Options.html).

## Using SnowflakeIO in Python SDK
### Intro
Expand Down
4 changes: 2 additions & 2 deletions website/www/site/content/en/documentation/io/connectors.md
Original file line number Diff line number Diff line change
Expand Up @@ -221,7 +221,7 @@ This table provides a consolidated, at-a-glance overview of the available built-
<td class="present">✔</td>
<td class="present">
<a href="https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/aws/s3/S3FileSystemRegistrar.html">native</a>
<a href="https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/aws2/s3/S3FileSystemRegistrar.html">native</a>
</td>
<td class="present">
Expand Down Expand Up @@ -250,7 +250,7 @@ This table provides a consolidated, at-a-glance overview of the available built-
<td class="present">✔</td>
<td class="present">
<a href="https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/kinesis/KinesisIO.html">native</a>
<a href="https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/aws2/kinesis/KinesisIO.html">native</a>
</td>
<td class="present">
Expand Down

0 comments on commit 5595f40

Please sign in to comment.