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();
   }