From 7d7baf7d419c873ecb58545c7feaaea25a862c23 Mon Sep 17 00:00:00 2001 From: Eugene Kirpichov Date: Tue, 19 Sep 2017 19:30:45 -0700 Subject: [PATCH] Marks TikaIO as experimental to allow backward-incompatible changes --- .../src/main/java/org/apache/beam/sdk/io/tika/TikaIO.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/TikaIO.java b/sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/TikaIO.java index 5d6eea7db7c73..4876dcfdb75f8 100644 --- a/sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/TikaIO.java +++ b/sdks/java/io/tika/src/main/java/org/apache/beam/sdk/io/tika/TikaIO.java @@ -21,7 +21,7 @@ import com.google.auto.value.AutoValue; import javax.annotation.Nullable; - +import org.apache.beam.sdk.annotations.Experimental; import org.apache.beam.sdk.coders.Coder; import org.apache.beam.sdk.coders.StringUtf8Coder; import org.apache.beam.sdk.io.Read.Bounded; @@ -53,7 +53,10 @@ * // A simple Read of a local PDF file (only runs locally): * PCollection content = p.apply(TikaInput.from("/local/path/to/file.pdf")); * } + * + * Warning: the API of this IO is likely to change in the next release. */ +@Experimental(Experimental.Kind.SOURCE_SINK) public class TikaIO { /**