Skip to content

Commit f9724e9

Browse files
committed
added @OverRide to RetryableInputStream
1 parent 0f891e6 commit f9724e9

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

src/main/java/org/embulk/input/s3/RetryExecutor.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,8 @@
33
import java.util.concurrent.Callable;
44
import java.util.concurrent.ExecutionException;
55

6-
public class RetryExecutor {
6+
public class RetryExecutor
7+
{
78
public static RetryExecutor retryExecutor()
89
{
910
// TODO default configuration

src/main/java/org/embulk/input/s3/RetryableInputStream.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@
22

33
import java.io.InputStream;
44
import java.io.IOException;
5-
import java.io.FilterInputStream;
65

76
public class RetryableInputStream
87
extends InputStream
@@ -39,6 +38,7 @@ private void reopen(Exception exception) throws IOException
3938
in = opener.open(offset, exception);
4039
}
4140

41+
@Override
4242
public int read() throws IOException
4343
{
4444
while (true) {
@@ -52,6 +52,7 @@ public int read() throws IOException
5252
}
5353
}
5454

55+
@Override
5556
public int read(byte[] b) throws IOException
5657
{
5758
while (true) {
@@ -65,6 +66,7 @@ public int read(byte[] b) throws IOException
6566
}
6667
}
6768

69+
@Override
6870
public int read(byte[] b, int off, int len) throws IOException
6971
{
7072
while (true) {
@@ -78,6 +80,7 @@ public int read(byte[] b, int off, int len) throws IOException
7880
}
7981
}
8082

83+
@Override
8184
public long skip(long n) throws IOException
8285
{
8386
while (true) {

0 commit comments

Comments
 (0)