@@ -203,7 +203,7 @@ public static void main(String[] args) {
203203 // 2. Apply FirestoreIO to get partitions (as RunQueryRequests)
204204 PCollection <RunQueryRequest > partitionedQueries =
205205 partitionQueryRequests .apply (
206- "GetPartitions " ,
206+ "Get Partitions " ,
207207 FirestoreIO .v1 ()
208208 .read ()
209209 .partitionQuery ()
@@ -216,7 +216,7 @@ public static void main(String[] args) {
216216 // 3. Execute each partitioned query
217217 PCollection <RunQueryResponse > responses =
218218 partitionedQueries .apply (
219- "QueryDocumentsInPartitions " ,
219+ "Query Documents in Partitions " ,
220220 FirestoreIO .v1 ()
221221 .read ()
222222 .runQuery ()
@@ -228,7 +228,7 @@ public static void main(String[] args) {
228228
229229 // 4. Process the documents from the responses
230230 PCollection <Document > documents =
231- responses .apply ("ExtractDocuments " , ParDo .of (new RunQueryResponseToDocumentFn ()));
231+ responses .apply ("Extract Documents " , ParDo .of (new RunQueryResponseToDocumentFn ()));
232232
233233 // 5. Prepare documents for writing to the destination database
234234 PCollection <Write > writes =
@@ -237,7 +237,7 @@ public static void main(String[] args) {
237237
238238 // 6. Write documents to the destination Firestore database
239239 writes .apply (
240- "WriteDocumentsToDestination " ,
240+ "Write Documents to Destination " ,
241241 FirestoreIO .v1 ()
242242 .write ()
243243 .withProjectId (destinationProjectId )
@@ -276,14 +276,14 @@ private static PCollection<String> getCollectionGroupIds(Pipeline p, Options opt
276276 Query query =
277277 Query .newBuilder ().addKind (KindExpression .newBuilder ().setName ("__kind__" )).build ();
278278 return p .apply (
279- "FindAllCollectionGroups " ,
279+ "Find All Collection Groups " ,
280280 DatastoreIO .v1 ()
281281 .read ()
282282 .withProjectId (options .getSourceProjectId ())
283283 .withDatabaseId (options .getSourceDatabaseId ())
284284 .withQuery (query ))
285285 .apply (
286- "ExtractCollectionGroupNames " ,
286+ "Extract Collection Group Names " ,
287287 ParDo .of (
288288 new DoFn <Entity , String >() {
289289 @ ProcessElement
@@ -302,6 +302,6 @@ public void processElement(ProcessContext c) {
302302 Arrays .stream (options .getCollectionGroupIds ().split ("," ))
303303 .map (String ::trim )
304304 .collect (Collectors .toList ());
305- return p .apply ("CreateCollectionGroups " , Create .of (collectionGroupIdsList ));
305+ return p .apply ("Create Collection Groups " , Create .of (collectionGroupIdsList ));
306306 }
307307}
0 commit comments