Rename --host to --fireStoreHost (#29201)

* Rename --host to --fireStoreHost

CHANGES.md

@@ -82,6 +82,7 @@ should handle this. ([#25252](https://github.com/apache/beam/issues/25252)).
 classes finally moved to `extensions/avro`. In case if it's still required to use `AvroCoder` for `CounterMark`, then,
 as a workaround, a copy of "old" `CountingSource` class should be placed into a project code and used directly
 ([#25252](https://github.com/apache/beam/issues/25252)).
+* Renamed `host` to `firestoreHost` in `FirestoreOptions` to avoid potential conflict of command line arguments (Java) ([#29201](https://github.com/apache/beam/pull/29201)).
 
 ## Deprecations
 

sdks/java/io/google-cloud-platform/build.gradle

@@ -186,13 +186,13 @@ task integrationTest(type: Test, dependsOn: processTestResources) {
   def gcpProject = project.findProperty('gcpProject') ?: 'apache-beam-testing'
   def gcpTempRoot = project.findProperty('gcpTempRoot') ?: 'gs://temp-storage-for-end-to-end-tests'
   def firestoreDb = project.findProperty('firestoreDb') ?: 'firestoredb'
-  def host = project.findProperty('host') ?: 'batch-firestore.googleapis.com:443'
+  def firestoreHost = project.findProperty('firestoreHost') ?: 'batch-firestore.googleapis.com:443'
   systemProperty "beamTestPipelineOptions", JsonOutput.toJson([
           "--runner=DirectRunner",
           "--project=${gcpProject}",
           "--tempRoot=${gcpTempRoot}",
           "--firestoreDb=${firestoreDb}",
-          "--host=${host}",
+          "--firestoreHost=${firestoreHost}",
   ])
 
   // Disable Gradle cache: these ITs interact with live service that should always be considered "out of date"
@@ -220,14 +220,14 @@ task integrationTestKms(type: Test) {
   def gcpTempRoot = project.findProperty('gcpTempRootKms') ?: 'gs://temp-storage-for-end-to-end-tests-cmek'
   def dataflowKmsKey = project.findProperty('dataflowKmsKey') ?: "projects/apache-beam-testing/locations/global/keyRings/beam-it/cryptoKeys/test"
   def firestoreDb = project.findProperty('firestoreDb') ?: 'firestoredb'
-  def host = project.findProperty('host') ?: 'batch-firestore.googleapis.com:443'
+  def firestoreHost = project.findProperty('firestoreHost') ?: 'batch-firestore.googleapis.com:443'
   systemProperty "beamTestPipelineOptions", JsonOutput.toJson([
           "--runner=DirectRunner",
           "--project=${gcpProject}",
           "--tempRoot=${gcpTempRoot}",
           "--dataflowKmsKey=${dataflowKmsKey}",
           "--firestoreDb=${firestoreDb}",
-          "--host=${host}",
+          "--firestoreHost=${firestoreHost}",
   ])
 
   // Disable Gradle cache: these ITs interact with live service that should always be considered "out of date"

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreOptions.java

@@ -66,13 +66,13 @@ public interface FirestoreOptions extends PipelineOptions {
    */
   @Description("Firestore endpoint (host and port)")
   @Default.String("batch-firestore.googleapis.com:443")
-  String getHost();
+  String getFirestoreHost();
 
   /**
    * Define a host port pair to allow connecting to a Cloud Firestore instead of the default live
    * service.
    *
    * @param host the host and port to connect to
    */
-  void setHost(String host);
+  void setFirestoreHost(String host);
 }

sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/firestore/FirestoreStatefulComponentFactory.java

@@ -93,7 +93,7 @@ FirestoreStub getFirestoreStub(PipelineOptions options) {
         GcpOptions gcpOptions = options.as(GcpOptions.class);
         builder
             .setCredentialsProvider(FixedCredentialsProvider.create(gcpOptions.getGcpCredential()))
-            .setEndpoint(firestoreOptions.getHost());
+            .setEndpoint(firestoreOptions.getFirestoreHost());
         headers.put(
             "x-goog-request-params",
             "project_id="

sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/firestore/it/FirestoreTestingHelper.java

@@ -134,7 +134,7 @@ public FirestoreTestingHelper(CleanupMode cleanupMode) {
             .setCredentials(gcpOptions.getGcpCredential())
             .setProjectId(gcpOptions.getProject())
             .setDatabaseId(firestoreBeamOptions.getFirestoreDb())
-            .setHost(firestoreBeamOptions.getHost())
+            .setHost(firestoreBeamOptions.getFirestoreHost())
             .build();
     fs = firestoreOptions.getService();
     rpc = (FirestoreRpc) firestoreOptions.getRpc();