Skip to content

Commit

Permalink
reference in programming guide
Browse files Browse the repository at this point in the history
  • Loading branch information
ahmedabu98 committed Dec 11, 2024
1 parent 55f6860 commit 7aa5860
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -7639,6 +7639,8 @@ In this section, we will use [KafkaIO.Read](https://beam.apache.org/releases/jav

#### 13.1.1. Creating cross-language Java transforms

For Beam versions 2.60.0+, please follow this [guide](sdks/python-custom-multi-language-pipelines-guide.md) instead.

There are two ways to make Java transforms available to other SDKs.

* Option 1: In some cases, you can use existing Java transforms from other SDKs without writing any additional Java code.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -72,8 +72,8 @@ This configuration is surfaced to foreign SDKs. For example, when using this tra

```python
with beam.Pipeline() as p:
(p
| Create([...])
(p
| Create([...])
| MySchemaTransform(foo="abc", bar=123)
```

Expand Down Expand Up @@ -176,7 +176,7 @@ dependencies {

// Beam's expansion service
runtimeOnly "org.apache.beam:beam-sdks-java-expansion-service:$beamVersion"
// AutoService annotation for our SchemaTransform provider
// AutoService annotation for our SchemaTransform provider
compileOnly "com.google.auto.service:auto-service-annotations:1.0.1"
annotationProcessor "com.google.auto.service:auto-service:1.0.1"
// AutoValue annotation for our configuration object
Expand Down Expand Up @@ -264,7 +264,7 @@ inspect.getdoc(MyTransform)
# Output: "This transform does this and that..."

inspect.signature(MyTransform)
# Output: (foo: "str: Description of what foo does...",
# Output: (foo: "str: Description of what foo does...",
# bar: "int: Description of what bar does....")
```

Expand Down Expand Up @@ -299,7 +299,7 @@ Produces a SchemaTransform using a provided configuration. An expansion service
```java
SchemaTransformProvider {
String identifier();

SchemaTransform from(Row configuration);

Schema configurationSchema();
Expand Down

0 comments on commit 7aa5860

Please sign in to comment.