Repository: incubator-beam Updated Branches: refs/heads/master 95ab43809 -> a17a99f58
Fix javadoc in Kinesis Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a5005fbe Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a5005fbe Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a5005fbe Branch: refs/heads/master Commit: a5005fbe7c0a43bdd2d825c2fc77556956bf0bfa Parents: bed5056 Author: Dan Halperin <dhalp...@google.com> Authored: Fri Aug 26 15:20:44 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Fri Aug 26 16:11:23 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/kinesis/TransientKinesisException.java | 2 +- .../java/org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java | 2 +- .../java/org/apache/beam/sdk/io/kinesis/CustomOptionalTest.java | 2 +- .../java/org/apache/beam/sdk/io/kinesis/KinesisMockReadTest.java | 2 +- .../java/org/apache/beam/sdk/io/kinesis/KinesisReaderTest.java | 2 +- .../org/apache/beam/sdk/io/kinesis/KinesisRecordCoderTest.java | 2 +- .../test/java/org/apache/beam/sdk/io/kinesis/RoundRobinTest.java | 2 +- .../org/apache/beam/sdk/io/kinesis/ShardRecordsIteratorTest.java | 2 +- 8 files changed, 8 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a5005fbe/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/TransientKinesisException.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/TransientKinesisException.java b/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/TransientKinesisException.java index a1a974b..57ad8a8 100644 --- a/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/TransientKinesisException.java +++ b/sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/TransientKinesisException.java @@ -20,7 +20,7 @@ package org.apache.beam.sdk.io.kinesis; import com.amazonaws.AmazonServiceException; /** - * Created by p.pastuszka on 21.06.2016. + * A transient exception thrown by Kinesis. */ class TransientKinesisException extends Exception { public TransientKinesisException(String s, AmazonServiceException e) { http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a5005fbe/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/AmazonKinesisMock.java ---------------------------------------------------------------------- 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 b007fa4..046c9d9 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 @@ -74,7 +74,7 @@ import org.apache.commons.lang.builder.EqualsBuilder; import org.joda.time.Instant; /** - * Created by p.pastuszka on 21.07.2016. + * Mock implemenation of {@link AmazonKinesis} for testing. */ class AmazonKinesisMock implements AmazonKinesis { http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a5005fbe/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/CustomOptionalTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/CustomOptionalTest.java b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/CustomOptionalTest.java index cb0d0e2..20e8372 100644 --- a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/CustomOptionalTest.java +++ b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/CustomOptionalTest.java @@ -21,7 +21,7 @@ import java.util.NoSuchElementException; import org.junit.Test; /** - * Created by ppastuszka on 12.12.15. + * Tests {@link CustomOptional}. */ public class CustomOptionalTest { @Test(expected = NoSuchElementException.class) http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a5005fbe/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisMockReadTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisMockReadTest.java b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisMockReadTest.java index 304220b..f0ab46c 100644 --- a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisMockReadTest.java +++ b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisMockReadTest.java @@ -32,7 +32,7 @@ import org.joda.time.DateTime; import org.junit.Test; /** - * Created by p.pastuszka on 22.07.2016. + * Tests {@link AmazonKinesisMock}. */ public class KinesisMockReadTest { @Test http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a5005fbe/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisReaderTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisReaderTest.java b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisReaderTest.java index 29a24821..3111029 100644 --- a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisReaderTest.java +++ b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisReaderTest.java @@ -30,7 +30,7 @@ import org.mockito.Mock; import org.mockito.runners.MockitoJUnitRunner; /** - * Created by ppastuszka on 12.12.15. + * Tests {@link KinesisReader}. */ @RunWith(MockitoJUnitRunner.class) public class KinesisReaderTest { http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a5005fbe/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisRecordCoderTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisRecordCoderTest.java b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisRecordCoderTest.java index d301f25..8771c86 100644 --- a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisRecordCoderTest.java +++ b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisRecordCoderTest.java @@ -23,7 +23,7 @@ import org.joda.time.Instant; import org.junit.Test; /** - * Created by p.pastuszka on 20.07.2016. + * Tests {@link KinesisRecordCoder}. */ public class KinesisRecordCoderTest { @Test http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a5005fbe/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/RoundRobinTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/RoundRobinTest.java b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/RoundRobinTest.java index aedc89e..f032eea 100644 --- a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/RoundRobinTest.java +++ b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/RoundRobinTest.java @@ -25,7 +25,7 @@ import java.util.List; import org.junit.Test; /** - * Created by ppastuszka on 12.12.15. + * Tests {@link RoundRobin}. */ public class RoundRobinTest { @Test(expected = IllegalArgumentException.class) http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/a5005fbe/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardRecordsIteratorTest.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardRecordsIteratorTest.java b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardRecordsIteratorTest.java index 585b884..49e806d 100644 --- a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardRecordsIteratorTest.java +++ b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardRecordsIteratorTest.java @@ -36,7 +36,7 @@ import org.mockito.runners.MockitoJUnitRunner; import org.mockito.stubbing.Answer; /** - * Created by ppastuszka on 12.12.15. + * Tests {@link ShardRecordsIterator}. */ @RunWith(MockitoJUnitRunner.class) public class ShardRecordsIteratorTest {
