Repository: beam Updated Branches: refs/heads/master c1a757476 -> d64f2cce8
BEAM-2581: KinesisClientProvider interface needs to be public Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/43fafcd1 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/43fafcd1 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/43fafcd1 Branch: refs/heads/master Commit: 43fafcd18c755ec38cb0c8e469927fe6323c97f6 Parents: c1a7574 Author: Nawaid Shamim <[email protected]> Authored: Tue Jul 11 15:19:43 2017 +0100 Committer: Chamikara Jayalath <[email protected]> Committed: Tue Aug 29 16:05:02 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/kinesis/KinesisClientProvider.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/beam/blob/43fafcd1/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisClientProvider.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisClientProvider.java b/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisClientProvider.java index b5b721e..c48f9cc 100644 --- a/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisClientProvider.java +++ b/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/KinesisClientProvider.java @@ -27,7 +27,7 @@ import java.io.Serializable; * <p>Please note, that any instance of {@link KinesisClientProvider} must be * {@link Serializable} to ensure it can be sent to worker machines. */ -interface KinesisClientProvider extends Serializable { +public interface KinesisClientProvider extends Serializable { AmazonKinesis get(); }
