source-bigquery-batch: Update test snapshots

estuary · Feb 26, 2025 · c381b6a · c381b6a
1 parent 61b837d
commit c381b6a
Show file tree

Hide file tree

Showing 35 changed files with 452 additions and 175 deletions.
diff --git a/source-bigquery-batch/.snapshots/TestBinaryTypes-Capture b/source-bigquery-batch/.snapshots/TestBinaryTypes-Capture
@@ -1,14 +1,14 @@
 # ================================
 # Collection "acmeCo/test/binarytypes_537491": 6 Documents
 # ================================
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"bool_val":true,"bytes_val":"aGVsbG8gd29ybGQ=","id":1}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"bool_val":false,"bytes_val":"AAECAw==","id":2}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"bool_val":null,"bytes_val":null,"id":3}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"bool_val":true,"bytes_val":null,"id":4}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"bool_val":false,"bytes_val":"qqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqg==","id":5}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"bool_val":true,"bytes_val":"SGVsbG8sIOS4lueVjCE=","id":6}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":0},"bool_val":true,"bytes_val":"aGVsbG8gd29ybGQ=","id":1}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":1},"bool_val":false,"bytes_val":"AAECAw==","id":2}
+{"_meta":{"polled":"<TIMESTAMP>","index":2,"row_id":2},"bool_val":null,"bytes_val":null,"id":3}
+{"_meta":{"polled":"<TIMESTAMP>","index":3,"row_id":3},"bool_val":true,"bytes_val":null,"id":4}
+{"_meta":{"polled":"<TIMESTAMP>","index":4,"row_id":4},"bool_val":false,"bytes_val":"qqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqqg==","id":5}
+{"_meta":{"polled":"<TIMESTAMP>","index":5,"row_id":5},"bool_val":true,"bytes_val":"SGVsbG8sIOS4lueVjCE=","id":6}
 # ================================
 # Final State Checkpoint
 # ================================
-{"bindingStateV1":{"binarytypes_537491":{"CursorNames":["id"],"CursorValues":[6],"LastPolled":"<TIMESTAMP>"}}}
+{"bindingStateV1":{"binarytypes_537491":{"CursorNames":["id"],"CursorValues":[6],"LastPolled":"<TIMESTAMP>","DocumentCount":6}}}
 
diff --git a/source-bigquery-batch/.snapshots/TestBinaryTypes-Discovery b/source-bigquery-batch/.snapshots/TestBinaryTypes-Discovery
@@ -21,7 +21,7 @@ Binding 0:
         ],
         "properties": {
           "_meta": {
-            "$schema": "http://json-schema.org/draft/2020-12/schema",
+            "$schema": "https://json-schema.org/draft/2020-12/schema",
             "$id": "https://github.com/estuary/connectors/source-bigquery-batch/document-metadata",
             "properties": {
               "polled": {
@@ -34,12 +34,29 @@ Binding 0:
                 "type": "integer",
                 "title": "Result Index",
                 "description": "The index of this document within the query execution which produced it."
+              },
+              "row_id": {
+                "type": "integer",
+                "title": "Row ID",
+                "description": "Row ID of the Document"
+              },
+              "op": {
+                "type": "string",
+                "enum": [
+                  "c",
+                  "u",
+                  "d"
+                ],
+                "title": "Change Operation",
+                "description": "Operation type (c: Create / u: Update / d: Delete)",
+                "default": "u"
               }
             },
             "type": "object",
             "required": [
               "polled",
-              "index"
+              "index",
+              "row_id"
             ]
           },
           "id": {

diff --git a/source-bigquery-batch/.snapshots/TestCaptureWithDatetimeCursor-Capture b/source-bigquery-batch/.snapshots/TestCaptureWithDatetimeCursor-Capture
@@ -1,18 +1,18 @@
 # ================================
 # Collection "acmeCo/test/capturewithdatetimecursor_877736": 10 Documents
 # ================================
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 0","id":0,"updated_at":"2025-02-13T12:00:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 1","id":1,"updated_at":"2025-02-13T12:01:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 2","id":2,"updated_at":"2025-02-13T12:02:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 3","id":3,"updated_at":"2025-02-13T12:03:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 4","id":4,"updated_at":"2025-02-13T12:04:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 5","id":5,"updated_at":"2025-02-13T12:10:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 6","id":6,"updated_at":"2025-02-13T12:11:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 7","id":7,"updated_at":"2025-02-13T12:12:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 8","id":8,"updated_at":"2025-02-13T12:13:00.000000"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 9","id":9,"updated_at":"2025-02-13T12:14:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":0},"data":"Value for row 0","id":0,"updated_at":"2025-02-13T12:00:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":1},"data":"Value for row 1","id":1,"updated_at":"2025-02-13T12:01:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":2,"row_id":2},"data":"Value for row 2","id":2,"updated_at":"2025-02-13T12:02:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":3,"row_id":3},"data":"Value for row 3","id":3,"updated_at":"2025-02-13T12:03:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":4,"row_id":4},"data":"Value for row 4","id":4,"updated_at":"2025-02-13T12:04:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":5},"data":"Value for row 5","id":5,"updated_at":"2025-02-13T12:10:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":6},"data":"Value for row 6","id":6,"updated_at":"2025-02-13T12:11:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":2,"row_id":7},"data":"Value for row 7","id":7,"updated_at":"2025-02-13T12:12:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":3,"row_id":8},"data":"Value for row 8","id":8,"updated_at":"2025-02-13T12:13:00.000000"}
+{"_meta":{"polled":"<TIMESTAMP>","index":4,"row_id":9},"data":"Value for row 9","id":9,"updated_at":"2025-02-13T12:14:00.000000"}
 # ================================
 # Final State Checkpoint
 # ================================
-{"bindingStateV1":{"capturewithdatetimecursor_877736":{"CursorNames":["updated_at"],"CursorValues":["2025-02-13T12:14:00.000000"],"LastPolled":"<TIMESTAMP>"}}}
+{"bindingStateV1":{"capturewithdatetimecursor_877736":{"CursorNames":["updated_at"],"CursorValues":["2025-02-13T12:14:00.000000"],"DocumentCount":10,"LastPolled":"<TIMESTAMP>"}}}
 
diff --git a/source-bigquery-batch/.snapshots/TestCaptureWithDatetimeCursor-Discovery b/source-bigquery-batch/.snapshots/TestCaptureWithDatetimeCursor-Discovery
@@ -21,7 +21,7 @@ Binding 0:
         ],
         "properties": {
           "_meta": {
-            "$schema": "http://json-schema.org/draft/2020-12/schema",
+            "$schema": "https://json-schema.org/draft/2020-12/schema",
             "$id": "https://github.com/estuary/connectors/source-bigquery-batch/document-metadata",
             "properties": {
               "polled": {
@@ -34,12 +34,29 @@ Binding 0:
                 "type": "integer",
                 "title": "Result Index",
                 "description": "The index of this document within the query execution which produced it."
+              },
+              "row_id": {
+                "type": "integer",
+                "title": "Row ID",
+                "description": "Row ID of the Document"
+              },
+              "op": {
+                "type": "string",
+                "enum": [
+                  "c",
+                  "u",
+                  "d"
+                ],
+                "title": "Change Operation",
+                "description": "Operation type (c: Create / u: Update / d: Delete)",
+                "default": "u"
               }
             },
             "type": "object",
             "required": [
               "polled",
-              "index"
+              "index",
+              "row_id"
             ]
           },
           "id": {

diff --git a/source-bigquery-batch/.snapshots/TestCaptureWithEmptyPoll-Capture b/source-bigquery-batch/.snapshots/TestCaptureWithEmptyPoll-Capture
@@ -1,18 +1,18 @@
 # ================================
 # Collection "acmeCo/test/capturewithemptypoll_890703": 10 Documents
 # ================================
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 0","id":0,"updated_at":"2025-02-13T12:00:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 1","id":1,"updated_at":"2025-02-13T12:01:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 2","id":2,"updated_at":"2025-02-13T12:02:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 3","id":3,"updated_at":"2025-02-13T12:03:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 4","id":4,"updated_at":"2025-02-13T12:04:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 5","id":5,"updated_at":"2025-02-13T12:10:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 6","id":6,"updated_at":"2025-02-13T12:11:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 7","id":7,"updated_at":"2025-02-13T12:12:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 8","id":8,"updated_at":"2025-02-13T12:13:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 9","id":9,"updated_at":"2025-02-13T12:14:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":0},"data":"Value for row 0","id":0,"updated_at":"2025-02-13T12:00:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":1},"data":"Value for row 1","id":1,"updated_at":"2025-02-13T12:01:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":2,"row_id":2},"data":"Value for row 2","id":2,"updated_at":"2025-02-13T12:02:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":3,"row_id":3},"data":"Value for row 3","id":3,"updated_at":"2025-02-13T12:03:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":4,"row_id":4},"data":"Value for row 4","id":4,"updated_at":"2025-02-13T12:04:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":5},"data":"Value for row 5","id":5,"updated_at":"2025-02-13T12:10:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":6},"data":"Value for row 6","id":6,"updated_at":"2025-02-13T12:11:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":2,"row_id":7},"data":"Value for row 7","id":7,"updated_at":"2025-02-13T12:12:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":3,"row_id":8},"data":"Value for row 8","id":8,"updated_at":"2025-02-13T12:13:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":4,"row_id":9},"data":"Value for row 9","id":9,"updated_at":"2025-02-13T12:14:00Z"}
 # ================================
 # Final State Checkpoint
 # ================================
-{"bindingStateV1":{"capturewithemptypoll_890703":{"CursorNames":["updated_at"],"CursorValues":["2025-02-13T12:14:00Z"],"LastPolled":"<TIMESTAMP>"}}}
+{"bindingStateV1":{"capturewithemptypoll_890703":{"CursorNames":["updated_at"],"CursorValues":["2025-02-13T12:14:00Z"],"DocumentCount":10,"LastPolled":"<TIMESTAMP>"}}}
 
diff --git a/source-bigquery-batch/.snapshots/TestCaptureWithEmptyPoll-Discovery b/source-bigquery-batch/.snapshots/TestCaptureWithEmptyPoll-Discovery
@@ -21,7 +21,7 @@ Binding 0:
         ],
         "properties": {
           "_meta": {
-            "$schema": "http://json-schema.org/draft/2020-12/schema",
+            "$schema": "https://json-schema.org/draft/2020-12/schema",
             "$id": "https://github.com/estuary/connectors/source-bigquery-batch/document-metadata",
             "properties": {
               "polled": {
@@ -34,12 +34,29 @@ Binding 0:
                 "type": "integer",
                 "title": "Result Index",
                 "description": "The index of this document within the query execution which produced it."
+              },
+              "row_id": {
+                "type": "integer",
+                "title": "Row ID",
+                "description": "Row ID of the Document"
+              },
+              "op": {
+                "type": "string",
+                "enum": [
+                  "c",
+                  "u",
+                  "d"
+                ],
+                "title": "Change Operation",
+                "description": "Operation type (c: Create / u: Update / d: Delete)",
+                "default": "u"
               }
             },
             "type": "object",
             "required": [
               "polled",
-              "index"
+              "index",
+              "row_id"
             ]
           },
           "id": {

diff --git a/source-bigquery-batch/.snapshots/TestCaptureWithModifications-Capture b/source-bigquery-batch/.snapshots/TestCaptureWithModifications-Capture
@@ -1,18 +1,18 @@
 # ================================
 # Collection "acmeCo/test/capturewithmodifications_786099": 10 Documents
 # ================================
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Initial value for row 0","id":0,"updated_at":"2025-02-13T12:00:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Initial value for row 1","id":1,"updated_at":"2025-02-13T12:01:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Initial value for row 2","id":2,"updated_at":"2025-02-13T12:02:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Initial value for row 3","id":3,"updated_at":"2025-02-13T12:03:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Initial value for row 4","id":4,"updated_at":"2025-02-13T12:04:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Modified value for row 3","id":3,"updated_at":"2025-02-13T12:15:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Modified value for row 4","id":4,"updated_at":"2025-02-13T12:16:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 5","id":5,"updated_at":"2025-02-13T12:20:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 6","id":6,"updated_at":"2025-02-13T12:21:00Z"}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value for row 7","id":7,"updated_at":"2025-02-13T12:22:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":0},"data":"Initial value for row 0","id":0,"updated_at":"2025-02-13T12:00:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":1},"data":"Initial value for row 1","id":1,"updated_at":"2025-02-13T12:01:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":2,"row_id":2},"data":"Initial value for row 2","id":2,"updated_at":"2025-02-13T12:02:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":3,"row_id":3},"data":"Initial value for row 3","id":3,"updated_at":"2025-02-13T12:03:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":4,"row_id":4},"data":"Initial value for row 4","id":4,"updated_at":"2025-02-13T12:04:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":5},"data":"Modified value for row 3","id":3,"updated_at":"2025-02-13T12:15:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":6},"data":"Modified value for row 4","id":4,"updated_at":"2025-02-13T12:16:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":2,"row_id":7},"data":"Value for row 5","id":5,"updated_at":"2025-02-13T12:20:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":3,"row_id":8},"data":"Value for row 6","id":6,"updated_at":"2025-02-13T12:21:00Z"}
+{"_meta":{"polled":"<TIMESTAMP>","index":4,"row_id":9},"data":"Value for row 7","id":7,"updated_at":"2025-02-13T12:22:00Z"}
 # ================================
 # Final State Checkpoint
 # ================================
-{"bindingStateV1":{"capturewithmodifications_786099":{"CursorNames":["updated_at"],"CursorValues":["2025-02-13T12:22:00Z"],"LastPolled":"<TIMESTAMP>"}}}
+{"bindingStateV1":{"capturewithmodifications_786099":{"CursorNames":["updated_at"],"CursorValues":["2025-02-13T12:22:00Z"],"DocumentCount":10,"LastPolled":"<TIMESTAMP>"}}}
 
diff --git a/source-bigquery-batch/.snapshots/TestCaptureWithModifications-Discovery b/source-bigquery-batch/.snapshots/TestCaptureWithModifications-Discovery
@@ -21,7 +21,7 @@ Binding 0:
         ],
         "properties": {
           "_meta": {
-            "$schema": "http://json-schema.org/draft/2020-12/schema",
+            "$schema": "https://json-schema.org/draft/2020-12/schema",
             "$id": "https://github.com/estuary/connectors/source-bigquery-batch/document-metadata",
             "properties": {
               "polled": {
@@ -34,12 +34,29 @@ Binding 0:
                 "type": "integer",
                 "title": "Result Index",
                 "description": "The index of this document within the query execution which produced it."
+              },
+              "row_id": {
+                "type": "integer",
+                "title": "Row ID",
+                "description": "Row ID of the Document"
+              },
+              "op": {
+                "type": "string",
+                "enum": [
+                  "c",
+                  "u",
+                  "d"
+                ],
+                "title": "Change Operation",
+                "description": "Operation type (c: Create / u: Update / d: Delete)",
+                "default": "u"
               }
             },
             "type": "object",
             "required": [
               "polled",
-              "index"
+              "index",
+              "row_id"
             ]
           },
           "id": {

diff --git a/source-bigquery-batch/.snapshots/TestCaptureWithNullCursor-Capture1 b/source-bigquery-batch/.snapshots/TestCaptureWithNullCursor-Capture1
@@ -1,13 +1,13 @@
 # ================================
 # Collection "acmeCo/test/capturewithnullcursor_662607": 5 Documents
 # ================================
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Another NULL cursor","id":2,"sort_col":null}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Third NULL cursor","id":4,"sort_col":null}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value with NULL cursor","id":0,"sort_col":null}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value with cursor 10","id":1,"sort_col":10}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value with cursor 20","id":3,"sort_col":20}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":0},"data":"Another NULL cursor","id":2,"sort_col":null}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":1},"data":"Value with NULL cursor","id":0,"sort_col":null}
+{"_meta":{"polled":"<TIMESTAMP>","index":2,"row_id":2},"data":"Third NULL cursor","id":4,"sort_col":null}
+{"_meta":{"polled":"<TIMESTAMP>","index":3,"row_id":3},"data":"Value with cursor 10","id":1,"sort_col":10}
+{"_meta":{"polled":"<TIMESTAMP>","index":4,"row_id":4},"data":"Value with cursor 20","id":3,"sort_col":20}
 # ================================
 # Final State Checkpoint
 # ================================
-{"bindingStateV1":{"capturewithnullcursor_662607":{"CursorNames":["sort_col"],"CursorValues":[20],"LastPolled":"<TIMESTAMP>"}}}
+{"bindingStateV1":{"capturewithnullcursor_662607":{"CursorNames":["sort_col"],"CursorValues":[20],"LastPolled":"<TIMESTAMP>","DocumentCount":5}}}
 
diff --git a/source-bigquery-batch/.snapshots/TestCaptureWithNullCursor-Capture2 b/source-bigquery-batch/.snapshots/TestCaptureWithNullCursor-Capture2
@@ -1,10 +1,10 @@
 # ================================
 # Collection "acmeCo/test/capturewithnullcursor_662607": 2 Documents
 # ================================
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Final value cursor 30","id":9,"sort_col":30}
-{"_meta":{"polled":"<TIMESTAMP>","index":999},"data":"Value with cursor 25","id":7,"sort_col":25}
+{"_meta":{"polled":"<TIMESTAMP>","index":0,"row_id":5},"data":"Value with cursor 25","id":7,"sort_col":25}
+{"_meta":{"polled":"<TIMESTAMP>","index":1,"row_id":6},"data":"Final value cursor 30","id":9,"sort_col":30}
 # ================================
 # Final State Checkpoint
 # ================================
-{"bindingStateV1":{"capturewithnullcursor_662607":{"CursorNames":["sort_col"],"CursorValues":[30],"LastPolled":"<TIMESTAMP>"}}}
+{"bindingStateV1":{"capturewithnullcursor_662607":{"CursorNames":["sort_col"],"CursorValues":[30],"DocumentCount":7,"LastPolled":"<TIMESTAMP>"}}}