|
|
f20be41 |
From 14cf13929f03bbfce7a309ab6628d0e4ffe513d4 Mon Sep 17 00:00:00 2001
|
|
|
f20be41 |
From: Jakub Janco <jjanco@redhat.com>
|
|
|
f20be41 |
Date: Tue, 13 Feb 2018 11:54:45 +0100
|
|
|
f20be41 |
Subject: [PATCH] Remove Guava code for
|
|
|
f20be41 |
|
|
|
f20be41 |
---
|
|
|
f20be41 |
.../datastax/driver/core/GuavaCompatibility.java | 48 +---------------------
|
|
|
f20be41 |
pom.xml | 2 +-
|
|
|
f20be41 |
2 files changed, 2 insertions(+), 48 deletions(-)
|
|
|
f20be41 |
|
|
|
f20be41 |
diff --git a/driver-core/src/main/java/com/datastax/driver/core/GuavaCompatibility.java b/driver-core/src/main/java/com/datastax/driver/core/GuavaCompatibility.java
|
|
|
f20be41 |
index 0744197c7..465e8ba1f 100644
|
|
|
f20be41 |
--- a/driver-core/src/main/java/com/datastax/driver/core/GuavaCompatibility.java
|
|
|
f20be41 |
+++ b/driver-core/src/main/java/com/datastax/driver/core/GuavaCompatibility.java
|
|
|
f20be41 |
@@ -133,59 +133,13 @@ public abstract class GuavaCompatibility {
|
|
|
f20be41 |
return new Version19OrHigher();
|
|
|
f20be41 |
} else if (isGuava_16_0_1_OrHigher()) {
|
|
|
f20be41 |
logger.info("Detected Guava < 19 in the classpath, using legacy compatibility layer");
|
|
|
f20be41 |
- return new Version18OrLower();
|
|
|
f20be41 |
+ throw new java.lang.UnsupportedOperationException();
|
|
|
f20be41 |
} else {
|
|
|
f20be41 |
throw new DriverInternalError("Detected incompatible version of Guava in the classpath. " +
|
|
|
f20be41 |
"You need 16.0.1 or higher.");
|
|
|
f20be41 |
}
|
|
|
f20be41 |
}
|
|
|
f20be41 |
|
|
|
f20be41 |
- private static class Version18OrLower extends GuavaCompatibility {
|
|
|
f20be41 |
-
|
|
|
f20be41 |
- @Override
|
|
|
f20be41 |
- public <V> ListenableFuture<V> withFallback(ListenableFuture input,
|
|
|
f20be41 |
- final AsyncFunction<Throwable, V> fallback) {
|
|
|
f20be41 |
- return Futures.withFallback(input, new FutureFallback<V>() {
|
|
|
f20be41 |
- @Override
|
|
|
f20be41 |
- public ListenableFuture<V> create(Throwable t) throws Exception {
|
|
|
f20be41 |
- return fallback.apply(t);
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
- });
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
-
|
|
|
f20be41 |
- @Override
|
|
|
f20be41 |
- public <V> ListenableFuture<V> withFallback(ListenableFuture input,
|
|
|
f20be41 |
- final AsyncFunction<Throwable, V> fallback,
|
|
|
f20be41 |
- Executor executor) {
|
|
|
f20be41 |
- return Futures.withFallback(input, new FutureFallback<V>() {
|
|
|
f20be41 |
- @Override
|
|
|
f20be41 |
- public ListenableFuture<V> create(Throwable t) throws Exception {
|
|
|
f20be41 |
- return fallback.apply(t);
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
- }, executor);
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
-
|
|
|
f20be41 |
- @Override
|
|
|
f20be41 |
- public <I, O> ListenableFuture<O> transformAsync(ListenableFuture input, AsyncFunction function) {
|
|
|
f20be41 |
- return Futures.transform(input, function);
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
-
|
|
|
f20be41 |
- @Override
|
|
|
f20be41 |
- public <I, O> ListenableFuture<O> transformAsync(ListenableFuture input, AsyncFunction function, Executor executor) {
|
|
|
f20be41 |
- return Futures.transform(input, function, executor);
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
-
|
|
|
f20be41 |
- @Override
|
|
|
f20be41 |
- public boolean isSupertypeOf(TypeToken target, TypeToken argument) {
|
|
|
f20be41 |
- return target.isAssignableFrom(argument);
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
-
|
|
|
f20be41 |
- @Override
|
|
|
f20be41 |
- public Executor sameThreadExecutor() {
|
|
|
f20be41 |
- return MoreExecutors.sameThreadExecutor();
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
- }
|
|
|
f20be41 |
-
|
|
|
f20be41 |
private static class Version19OrHigher extends GuavaCompatibility {
|
|
|
f20be41 |
|
|
|
f20be41 |
@Override
|
|
|
f20be41 |
diff --git a/pom.xml b/pom.xml
|
|
|
f20be41 |
index 735005db3..e9647bcde 100644
|
|
|
f20be41 |
--- a/pom.xml
|
|
|
f20be41 |
+++ b/pom.xml
|
|
|
f20be41 |
@@ -50,7 +50,7 @@
|
|
|
f20be41 |
<log4j.version>1.2.17</log4j.version>
|
|
|
f20be41 |
<slf4j.version>1.7.25</slf4j.version>
|
|
|
f20be41 |
<slf4j-log4j12.version>1.7.25</slf4j-log4j12.version>
|
|
|
f20be41 |
- <guava.version>19.0</guava.version>
|
|
|
f20be41 |
+ <guava.version>20.0</guava.version>
|
|
|
f20be41 |
<netty.version>4.0.47.Final</netty.version>
|
|
|
f20be41 |
<metrics.version>3.2.2</metrics.version>
|
|
|
f20be41 |
<snappy.version>1.1.2.6</snappy.version>
|
|
|
f20be41 |
--
|
|
|
f20be41 |
2.14.3
|
|
|
f20be41 |
|