You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2022/08/16 21:22:13 UTC
[beam] 01/01: Making TypedSchemaTransformProvider fully public
This is an automated email from the ASF dual-hosted git repository.
pabloem pushed a commit to branch pabloem-patch-1
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 0dc74af3ea2ebbd9abb3fbd88233556562d2da58
Author: Pablo Estrada <pa...@users.noreply.github.com>
AuthorDate: Tue Aug 16 17:22:06 2022 -0400
Making TypedSchemaTransformProvider fully public
So others can depend on it.
---
.../beam/sdk/schemas/transforms/TypedSchemaTransformProvider.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/TypedSchemaTransformProvider.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/TypedSchemaTransformProvider.java
index 944f33a596d..6393c178ad5 100644
--- a/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/TypedSchemaTransformProvider.java
+++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/schemas/transforms/TypedSchemaTransformProvider.java
@@ -42,19 +42,19 @@ import org.apache.beam.sdk.values.Row;
@Experimental(Kind.SCHEMAS)
public abstract class TypedSchemaTransformProvider<ConfigT> implements SchemaTransformProvider {
- protected abstract Class<ConfigT> configurationClass();
+ public abstract Class<ConfigT> configurationClass();
/**
* Produce a SchemaTransform from ConfigT. Can throw a {@link InvalidConfigurationException} or a
* {@link InvalidSchemaException}.
*/
- protected abstract SchemaTransform from(ConfigT configuration);
+ public abstract SchemaTransform from(ConfigT configuration);
/**
* List the dependencies needed for this transform. Jars from classpath are used by default when
* Optional.empty() is returned.
*/
- Optional<List<String>> dependencies(ConfigT configuration, PipelineOptions options) {
+ public Optional<List<String>> dependencies(ConfigT configuration, PipelineOptions options) {
return Optional.empty();
}