This is an automated email from the ASF dual-hosted git repository. mblow pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit 0df6cfb5e1e243c7a380243c1523cf4420caeef2 Author: Michael Blow <[email protected]> AuthorDate: Sat Jun 20 16:54:11 2020 -0400 [NO ISSUE][HYR] +=ThrowingIntConsumer, unchecked wrapper helpers Change-Id: I43915b87f5a10dd024f5618c9e8da26c5ad5c496 Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/6903 Integration-Tests: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Reviewed-by: Michael Blow <[email protected]> Reviewed-by: Hussain Towaileb <[email protected]> --- hyracks-fullstack/hyracks/hyracks-util/pom.xml | 4 ++++ .../org/apache/hyracks/util/ThrowingConsumer.java | 19 ++++++++++++++++++ ...owingConsumer.java => ThrowingIntConsumer.java} | 23 ++++++++++++++++++++-- 3 files changed, 44 insertions(+), 2 deletions(-) diff --git a/hyracks-fullstack/hyracks/hyracks-util/pom.xml b/hyracks-fullstack/hyracks/hyracks-util/pom.xml index e2da20a..621e6f6 100644 --- a/hyracks-fullstack/hyracks/hyracks-util/pom.xml +++ b/hyracks-fullstack/hyracks/hyracks-util/pom.xml @@ -95,6 +95,10 @@ <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> </dependency> + <dependency> + <groupId>com.google.guava</groupId> + <artifactId>guava</artifactId> + </dependency> </dependencies> </project> diff --git a/hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingConsumer.java b/hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingConsumer.java index bfc5fdd..be9874a 100644 --- a/hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingConsumer.java +++ b/hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingConsumer.java @@ -18,7 +18,26 @@ */ package org.apache.hyracks.util; +import java.util.function.Consumer; + +import com.google.common.util.concurrent.UncheckedExecutionException; + @FunctionalInterface public interface ThrowingConsumer<V> { void process(V value) throws Exception; + + @SuppressWarnings("Duplicates") + static <T> Consumer<T> asUnchecked(ThrowingConsumer<T> consumer) { + return input -> { + try { + consumer.process(input); + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + throw new UncheckedExecutionException(e); + } catch (Exception e) { + throw new UncheckedExecutionException(e); + } + }; + } + } diff --git a/hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingConsumer.java b/hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingIntConsumer.java similarity index 56% copy from hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingConsumer.java copy to hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingIntConsumer.java index bfc5fdd..07575bb 100644 --- a/hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingConsumer.java +++ b/hyracks-fullstack/hyracks/hyracks-util/src/main/java/org/apache/hyracks/util/ThrowingIntConsumer.java @@ -18,7 +18,26 @@ */ package org.apache.hyracks.util; +import java.util.function.IntConsumer; + +import com.google.common.util.concurrent.UncheckedExecutionException; + @FunctionalInterface -public interface ThrowingConsumer<V> { - void process(V value) throws Exception; +public interface ThrowingIntConsumer { + void process(int value) throws Exception; + + @SuppressWarnings("Duplicates") + static IntConsumer asUnchecked(ThrowingIntConsumer consumer) { + return input -> { + try { + consumer.process(input); + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + throw new UncheckedExecutionException(e); + } catch (Exception e) { + throw new UncheckedExecutionException(e); + } + }; + } + }
