Skip to content

Commit 286f6ae

Browse files
committed
more -> needsMore
1 parent 17d2570 commit 286f6ae

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

embulk-input-s3/src/main/java/org/embulk/input/s3/AbstractS3FileInputPlugin.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ public static void listS3FilesByPrefix(FileList.Builder builder,
168168
for (S3ObjectSummary s : ol.getObjectSummaries()) {
169169
if (s.getSize() > 0) {
170170
builder.add(s.getKey(), s.getSize());
171-
if (!builder.more()) {
171+
if (!builder.needsMore()) {
172172
return;
173173
}
174174
}

embulk-input-s3/src/main/java/org/embulk/input/s3/FileList.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ public int size()
9999
return entries.size();
100100
}
101101

102-
public boolean more()
102+
public boolean needsMore()
103103
{
104104
return size() < limitCount;
105105
}
@@ -108,7 +108,7 @@ public synchronized boolean add(String path, long size)
108108
{
109109
// TODO throw IllegalStateException if stream is already closed
110110

111-
if (!more()) {
111+
if (!needsMore()) {
112112
return false;
113113
}
114114

0 commit comments

Comments
 (0)