[beam] branch master updated: [BEAM-6330] KinesisIO, updated AWS SDK version

[ie...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 024199f  [BEAM-6330] KinesisIO, updated AWS SDK version
     new 2e56253  Merge pull request #8072: [BEAM-6330] Update AWS SDK version to version 1.11.519 (for KinesisIO)
024199f is described below

commit 024199f0b418e5c715dda630ad01d80ce068f076
Author: Alexey Romanenko <ar...@gmail.com>
AuthorDate: Fri Mar 15 18:44:44 2019 +0100

    [BEAM-6330] KinesisIO, updated AWS SDK version
---
 sdks/java/io/kinesis/build.gradle                  |  2 +-
 .../beam/sdk/io/kinesis/AmazonKinesisMock.java     | 39 ++++++++++++++++++++++
 2 files changed, 40 insertions(+), 1 deletion(-)

diff --git a/sdks/java/io/kinesis/build.gradle b/sdks/java/io/kinesis/build.gradle
index 127db4f..8c5cee3 100644
--- a/sdks/java/io/kinesis/build.gradle
+++ b/sdks/java/io/kinesis/build.gradle
@@ -37,7 +37,7 @@ test {
   forkEvery 1
 }
 
-def aws_version = "1.11.255"
+def aws_version = "1.11.519"
 
 dependencies {
   shadow project(path: ":beam-sdks-java-core", configuration: "shadow")
diff --git a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java
index 4749d2f..dc3fdbe 100644
--- a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java
+++ b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java
@@ -37,8 +37,12 @@ import com.amazonaws.services.kinesis.model.DecreaseStreamRetentionPeriodRequest
 import com.amazonaws.services.kinesis.model.DecreaseStreamRetentionPeriodResult;
 import com.amazonaws.services.kinesis.model.DeleteStreamRequest;
 import com.amazonaws.services.kinesis.model.DeleteStreamResult;
+import com.amazonaws.services.kinesis.model.DeregisterStreamConsumerRequest;
+import com.amazonaws.services.kinesis.model.DeregisterStreamConsumerResult;
 import com.amazonaws.services.kinesis.model.DescribeLimitsRequest;
 import com.amazonaws.services.kinesis.model.DescribeLimitsResult;
+import com.amazonaws.services.kinesis.model.DescribeStreamConsumerRequest;
+import com.amazonaws.services.kinesis.model.DescribeStreamConsumerResult;
 import com.amazonaws.services.kinesis.model.DescribeStreamRequest;
 import com.amazonaws.services.kinesis.model.DescribeStreamResult;
 import com.amazonaws.services.kinesis.model.DescribeStreamSummaryRequest;
@@ -53,6 +57,10 @@ import com.amazonaws.services.kinesis.model.GetShardIteratorRequest;
 import com.amazonaws.services.kinesis.model.GetShardIteratorResult;
 import com.amazonaws.services.kinesis.model.IncreaseStreamRetentionPeriodRequest;
 import com.amazonaws.services.kinesis.model.IncreaseStreamRetentionPeriodResult;
+import com.amazonaws.services.kinesis.model.ListShardsRequest;
+import com.amazonaws.services.kinesis.model.ListShardsResult;
+import com.amazonaws.services.kinesis.model.ListStreamConsumersRequest;
+import com.amazonaws.services.kinesis.model.ListStreamConsumersResult;
 import com.amazonaws.services.kinesis.model.ListStreamsRequest;
 import com.amazonaws.services.kinesis.model.ListStreamsResult;
 import com.amazonaws.services.kinesis.model.ListTagsForStreamRequest;
@@ -64,6 +72,8 @@ import com.amazonaws.services.kinesis.model.PutRecordResult;
 import com.amazonaws.services.kinesis.model.PutRecordsRequest;
 import com.amazonaws.services.kinesis.model.PutRecordsResult;
 import com.amazonaws.services.kinesis.model.Record;
+import com.amazonaws.services.kinesis.model.RegisterStreamConsumerRequest;
+import com.amazonaws.services.kinesis.model.RegisterStreamConsumerResult;
 import com.amazonaws.services.kinesis.model.RemoveTagsFromStreamRequest;
 import com.amazonaws.services.kinesis.model.RemoveTagsFromStreamResult;
 import com.amazonaws.services.kinesis.model.Shard;
@@ -278,6 +288,12 @@ class AmazonKinesisMock implements AmazonKinesis {
   }
 
   @Override
+  public DeregisterStreamConsumerResult deregisterStreamConsumer(
+      DeregisterStreamConsumerRequest deregisterStreamConsumerRequest) {
+    throw new RuntimeException("Not implemented");
+  }
+
+  @Override
   public DescribeLimitsResult describeLimits(DescribeLimitsRequest describeLimitsRequest) {
     throw new RuntimeException("Not implemented");
   }
@@ -299,6 +315,12 @@ class AmazonKinesisMock implements AmazonKinesis {
   }
 
   @Override
+  public DescribeStreamConsumerResult describeStreamConsumer(
+      DescribeStreamConsumerRequest describeStreamConsumerRequest) {
+    throw new RuntimeException("Not implemented");
+  }
+
+  @Override
   public DescribeStreamSummaryResult describeStreamSummary(
       DescribeStreamSummaryRequest describeStreamSummaryRequest) {
     throw new RuntimeException("Not implemented");
@@ -335,6 +357,17 @@ class AmazonKinesisMock implements AmazonKinesis {
   }
 
   @Override
+  public ListShardsResult listShards(ListShardsRequest listShardsRequest) {
+    throw new RuntimeException("Not implemented");
+  }
+
+  @Override
+  public ListStreamConsumersResult listStreamConsumers(
+      ListStreamConsumersRequest listStreamConsumersRequest) {
+    throw new RuntimeException("Not implemented");
+  }
+
+  @Override
   public ListStreamsResult listStreams(ListStreamsRequest listStreamsRequest) {
     throw new RuntimeException("Not implemented");
   }
@@ -393,6 +426,12 @@ class AmazonKinesisMock implements AmazonKinesis {
   }
 
   @Override
+  public RegisterStreamConsumerResult registerStreamConsumer(
+      RegisterStreamConsumerRequest registerStreamConsumerRequest) {
+    throw new RuntimeException("Not implemented");
+  }
+
+  @Override
   public RemoveTagsFromStreamResult removeTagsFromStream(
       RemoveTagsFromStreamRequest removeTagsFromStreamRequest) {
     throw new RuntimeException("Not implemented");