From cf3e890e4a8c2ffc7167e326eef584d702503ba3 Mon Sep 17 00:00:00 2001
From: Stephane Geneix <stephane@airbyte.io>
Date: Mon, 25 Mar 2024 08:05:44 -0700
Subject: [PATCH] use appache commons classes in our Checked functional
 interfaces

---
 .../airbyte-cdk/core/src/main/resources/version.properties  | 2 +-
 .../io/airbyte/commons/functional/CheckedBiConsumer.java    | 6 +++---
 .../io/airbyte/commons/functional/CheckedBiFunction.java    | 4 ++--
 .../java/io/airbyte/commons/functional/CheckedConsumer.java | 6 +++---
 .../java/io/airbyte/commons/functional/CheckedFunction.java | 6 +++---
 .../java/io/airbyte/commons/functional/CheckedSupplier.java | 6 +++---
 6 files changed, 15 insertions(+), 15 deletions(-)

diff --git a/airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties b/airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties
index fa134d9b963aa1..46f595906d61b2 100644
--- a/airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties
+++ b/airbyte-cdk/java/airbyte-cdk/core/src/main/resources/version.properties
@@ -1 +1 @@
-version=0.28.14
+version=0.28.15
diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java
index d2c1d08aaf29b6..7afd5b96152e4c 100644
--- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java
+++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiConsumer.java
@@ -4,9 +4,9 @@
 
 package io.airbyte.commons.functional;
 
-@FunctionalInterface
-public interface CheckedBiConsumer<T, R, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableBiConsumer;
 
-  void accept(T t, R r) throws E;
+@FunctionalInterface
+public interface CheckedBiConsumer<T, R, E extends Throwable> extends FailableBiConsumer<T, R, E> {
 
 }
diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java
index b23857d85eea0e..c941435b0589e0 100644
--- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java
+++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedBiFunction.java
@@ -4,8 +4,8 @@
 
 package io.airbyte.commons.functional;
 
-public interface CheckedBiFunction<First, Second, Result, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableBiFunction;
 
-  Result apply(First first, Second second) throws E;
+public interface CheckedBiFunction<First, Second, Result, E extends Throwable> extends FailableBiFunction<First, Second, Result, E> {
 
 }
diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java
index 5e3fe89652effb..6905bd9e5d1d1e 100644
--- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java
+++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedConsumer.java
@@ -4,9 +4,9 @@
 
 package io.airbyte.commons.functional;
 
-@FunctionalInterface
-public interface CheckedConsumer<T, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableConsumer;
 
-  void accept(T t) throws E;
+@FunctionalInterface
+public interface CheckedConsumer<T, E extends Throwable> extends FailableConsumer<T, E> {
 
 }
diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java
index cb3d85917eefc1..cf32b71e294b1f 100644
--- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java
+++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedFunction.java
@@ -4,9 +4,9 @@
 
 package io.airbyte.commons.functional;
 
-@FunctionalInterface
-public interface CheckedFunction<T, R, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableFunction;
 
-  R apply(T t) throws E;
+@FunctionalInterface
+public interface CheckedFunction<T, R, E extends Throwable> extends FailableFunction<T, R, E> {
 
 }
diff --git a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java
index 57be08def307d8..e15a9cf5b8fc77 100644
--- a/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java
+++ b/airbyte-cdk/java/airbyte-cdk/dependencies/src/main/java/io/airbyte/commons/functional/CheckedSupplier.java
@@ -4,9 +4,9 @@
 
 package io.airbyte.commons.functional;
 
-@FunctionalInterface
-public interface CheckedSupplier<T, E extends Throwable> {
+import org.apache.commons.lang3.function.FailableSupplier;
 
-  T get() throws E;
+@FunctionalInterface
+public interface CheckedSupplier<T, E extends Throwable> extends FailableSupplier<T, E> {
 
 }