diff --git a/sdks/java/io/rrio/build.gradle b/sdks/java/io/rrio/build.gradle index d65df370e0ca..d7d5c8817d06 100644 --- a/sdks/java/io/rrio/build.gradle +++ b/sdks/java/io/rrio/build.gradle @@ -18,7 +18,7 @@ plugins { id 'org.apache.beam.module' } applyJavaNature( - automaticModuleName: 'org.apache.beam.sdk.io.rrio' + automaticModuleName: 'org.apache.beam.sdk.io.requestresponse' ) description = "Apache Beam :: SDKS :: Java :: IO :: RequestResponseIO (RRIO)" diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/ApiIOError.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ApiIOError.java similarity index 97% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/ApiIOError.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ApiIOError.java index b7c5524e8237..5936c5dd84b0 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/ApiIOError.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/ApiIOError.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import com.google.auto.value.AutoValue; import org.apache.beam.sdk.schemas.AutoValueSchema; diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CacheRead.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CacheRead.java similarity index 97% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CacheRead.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CacheRead.java index 6154873e506d..3765d25370a6 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CacheRead.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CacheRead.java @@ -15,11 +15,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import com.google.auto.value.AutoValue; import java.util.Map; -import org.apache.beam.io.requestresponseio.CacheRead.Result; +import org.apache.beam.io.requestresponse.CacheRead.Result; import org.apache.beam.sdk.Pipeline; import org.apache.beam.sdk.transforms.PTransform; import org.apache.beam.sdk.values.KV; diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CacheWrite.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CacheWrite.java similarity index 97% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CacheWrite.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CacheWrite.java index 0fb14af67c35..25249c3e41b4 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CacheWrite.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CacheWrite.java @@ -15,11 +15,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import com.google.auto.value.AutoValue; import java.util.Map; -import org.apache.beam.io.requestresponseio.CacheWrite.Result; +import org.apache.beam.io.requestresponse.CacheWrite.Result; import org.apache.beam.sdk.Pipeline; import org.apache.beam.sdk.transforms.PTransform; import org.apache.beam.sdk.values.KV; diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CallShouldBackoff.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CallShouldBackoff.java similarity index 96% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CallShouldBackoff.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CallShouldBackoff.java index 9a0c42de5b1f..1d093f2efb12 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CallShouldBackoff.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CallShouldBackoff.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import java.io.Serializable; diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CallShouldBackoffBasedOnRejectionProbability.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CallShouldBackoffBasedOnRejectionProbability.java similarity index 98% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CallShouldBackoffBasedOnRejectionProbability.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CallShouldBackoffBasedOnRejectionProbability.java index 8298809fca8d..62a7990d21ee 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/CallShouldBackoffBasedOnRejectionProbability.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/CallShouldBackoffBasedOnRejectionProbability.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import org.checkerframework.checker.nullness.qual.Nullable; diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/Caller.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Caller.java similarity index 96% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/Caller.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Caller.java index 32b514c43a15..da636c863740 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/Caller.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/Caller.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import java.io.Serializable; diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/RequestResponseIO.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/RequestResponseIO.java similarity index 98% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/RequestResponseIO.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/RequestResponseIO.java index 2ff0d50f68d5..de7d26aab4bd 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/RequestResponseIO.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/RequestResponseIO.java @@ -15,11 +15,11 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import com.google.auto.value.AutoValue; import java.util.Map; -import org.apache.beam.io.requestresponseio.RequestResponseIO.Result; +import org.apache.beam.io.requestresponse.RequestResponseIO.Result; import org.apache.beam.sdk.Pipeline; import org.apache.beam.sdk.transforms.PTransform; import org.apache.beam.sdk.values.PCollection; diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/SetupTeardown.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/SetupTeardown.java similarity index 96% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/SetupTeardown.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/SetupTeardown.java index 2bdc8113d98e..be1b03105c3d 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/SetupTeardown.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/SetupTeardown.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import java.io.Serializable; diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeExecutionException.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeExecutionException.java similarity index 96% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeExecutionException.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeExecutionException.java index 3a4c002f52e8..be545b6da66a 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeExecutionException.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeExecutionException.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; /** Base {@link Exception} for signaling errors in user custom code. */ public class UserCodeExecutionException extends Exception { diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeQuotaException.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeQuotaException.java similarity index 96% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeQuotaException.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeQuotaException.java index f16f078927f8..c513a5371da7 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeQuotaException.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeQuotaException.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; /** * Extends {@link UserCodeQuotaException} to allow the user custom code to specifically signal a diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeTimeoutException.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeTimeoutException.java similarity index 96% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeTimeoutException.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeTimeoutException.java index 22b067449858..869b8a51b73f 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/UserCodeTimeoutException.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/UserCodeTimeoutException.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; /** An extension of {@link UserCodeQuotaException} to specifically signal a user code timeout. */ public class UserCodeTimeoutException extends UserCodeExecutionException { diff --git a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/package-info.java b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/package-info.java similarity index 95% rename from sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/package-info.java rename to sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/package-info.java index cd9c11c13f86..abaea0a58b32 100644 --- a/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponseio/package-info.java +++ b/sdks/java/io/rrio/src/main/java/org/apache/beam/io/requestresponse/package-info.java @@ -17,4 +17,4 @@ */ /** Package provides Beam I/O transform support for safely reading from and writing to Web APIs. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; diff --git a/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/CallShouldBackoffBasedOnRejectionProbabilityTest.java b/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallShouldBackoffBasedOnRejectionProbabilityTest.java similarity index 98% rename from sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/CallShouldBackoffBasedOnRejectionProbabilityTest.java rename to sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallShouldBackoffBasedOnRejectionProbabilityTest.java index b1e8347a25cf..40aaa48c2692 100644 --- a/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/CallShouldBackoffBasedOnRejectionProbabilityTest.java +++ b/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallShouldBackoffBasedOnRejectionProbabilityTest.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import static org.junit.Assert.assertEquals; diff --git a/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/CallerTest.java b/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallerTest.java similarity index 98% rename from sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/CallerTest.java rename to sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallerTest.java index 0ba2d93c5411..93f3de474c58 100644 --- a/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/CallerTest.java +++ b/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/CallerTest.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import static org.apache.beam.sdk.util.Preconditions.checkStateNotNull; import static org.junit.Assert.assertEquals; diff --git a/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/SetupTeardownTest.java b/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/SetupTeardownTest.java similarity index 98% rename from sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/SetupTeardownTest.java rename to sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/SetupTeardownTest.java index 9ef2f88a29c5..eade6588955d 100644 --- a/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponseio/SetupTeardownTest.java +++ b/sdks/java/io/rrio/src/test/java/org/apache/beam/io/requestresponse/SetupTeardownTest.java @@ -15,7 +15,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.apache.beam.io.requestresponseio; +package org.apache.beam.io.requestresponse; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertThrows;