Skip to content
This repository was archived by the owner on Aug 12, 2022. It is now read-only.

Commit 3e10935

Browse files
committed
Fixed issue with extractor and buffered reader
1 parent da00dd6 commit 3e10935

File tree

1 file changed

+14
-2
lines changed

1 file changed

+14
-2
lines changed

src/main/java/com/orientechnologies/orient/etl/extractor/ORowExtractor.java

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,13 +18,13 @@
1818

1919
package com.orientechnologies.orient.etl.extractor;
2020

21+
import com.orientechnologies.orient.etl.OExtractedItem;
22+
2123
import java.io.BufferedReader;
2224
import java.io.IOException;
2325
import java.io.Reader;
2426
import java.util.NoSuchElementException;
2527

26-
import com.orientechnologies.orient.etl.OExtractedItem;
27-
2828
public class ORowExtractor extends OAbstractSourceExtractor {
2929
protected BufferedReader bReader;
3030

@@ -33,6 +33,18 @@ public String getName() {
3333
return "row";
3434
}
3535

36+
@Override
37+
public boolean hasNext() {
38+
if (bReader == null)
39+
return false;
40+
41+
try {
42+
return bReader.ready();
43+
} catch (IOException e) {
44+
throw new OExtractorException(e);
45+
}
46+
}
47+
3648
@Override
3749
public OExtractedItem next() {
3850
if (!hasNext())

0 commit comments

Comments
 (0)