Bump 6 dependencies
Bump commons-codec from 1.13 to 1.16.0
Bump commons-dbcp2 from 2.9.0 to 2.11.0
Bump commons-io from 2.11.0 to 2.15.0
Bump commons-lang3 from 3.8 to 3.13.0
Bump commons-pool2 from 2.6.2 to 2.12.0
Bump commons-text from 1.10.0 to 1.11.0
diff --git a/core/src/main/java/org/apache/calcite/util/Sources.java b/core/src/main/java/org/apache/calcite/util/Sources.java
index 59c8cb1..d184650 100644
--- a/core/src/main/java/org/apache/calcite/util/Sources.java
+++ b/core/src/main/java/org/apache/calcite/util/Sources.java
@@ -16,8 +16,6 @@
*/
package org.apache.calcite.util;
-import org.apache.commons.io.input.ReaderInputStream;
-
import com.google.common.io.CharSource;
import org.checkerframework.checker.nullness.qual.Nullable;
@@ -137,8 +135,7 @@
}
@Override public InputStream openStream() throws IOException {
- // use charSource.asByteSource() once calcite can use guava v21+
- return new ReaderInputStream(reader(), StandardCharsets.UTF_8);
+ return charSource.asByteSource(StandardCharsets.UTF_8).openStream();
}
@Override public String protocol() {
diff --git a/file/src/main/java/org/apache/calcite/adapter/file/CsvStreamReader.java b/file/src/main/java/org/apache/calcite/adapter/file/CsvStreamReader.java
index 1c7aed8..2bbcb45 100644
--- a/file/src/main/java/org/apache/calcite/adapter/file/CsvStreamReader.java
+++ b/file/src/main/java/org/apache/calcite/adapter/file/CsvStreamReader.java
@@ -28,6 +28,7 @@
import java.io.Closeable;
import java.io.IOException;
import java.io.StringReader;
+import java.time.Duration;
import java.util.ArrayDeque;
import java.util.Queue;
@@ -79,8 +80,15 @@
contentQueue = new ArrayDeque<>();
TailerListener listener = new CsvContentListener(contentQueue);
tailer =
- Tailer.create(source.file(), listener, DEFAULT_MONITOR_DELAY,
- false, true, 4096);
+ Tailer.builder()
+ .setFile(source.file())
+ .setTailerListener(listener)
+ .setDelayDuration(Duration.ofMillis(DEFAULT_MONITOR_DELAY))
+ .setTailFromEnd(false)
+ .setReOpen(true)
+ .setBufferSize(4096)
+ .get();
+
this.parser =
new CSVParser(separator, quoteChar, escape, strictQuotes,
ignoreLeadingWhiteSpace);
diff --git a/gradle.properties b/gradle.properties
index ec9078f..cdcb9aa 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -90,14 +90,14 @@
cassandra-java-driver-core.version=4.13.0
cassandra-unit.version=4.3.1.0
chinook-data-hsqldb.version=0.2
-commons-codec.version=1.13
-commons-dbcp2.version=2.9.0
-commons-io.version=2.11.0
-commons-lang3.version=3.8
+commons-codec.version=1.16.0
+commons-dbcp2.version=2.11.0
+commons-io.version=2.15.0
+commons-lang3.version=3.13.0
commons-math3.version=3.6.1
-commons-pool2.version=2.6.2
+commons-pool2.version=2.12.0
commons-collections4.version=4.4
-commons-text.version=1.10.0
+commons-text.version=1.11.0
dropwizard-metrics.version=4.0.5
# do not upgrade this, new versions are Category X license.
