|
99 | 99 | 'SpannerUpdate', |
100 | 100 | 'TimestampBoundMode', |
101 | 101 | 'TimeUnit', |
| 102 | + 'ReadChangeStreamFromSpanner', |
102 | 103 | ] |
103 | 104 |
|
104 | 105 |
|
@@ -683,8 +684,7 @@ class ReadChangeStreamFromSpanner(ExternalTransform): |
683 | 684 | Example: |
684 | 685 |
|
685 | 686 | with beam.Pipeline(options=pipeline_options) as p: |
686 | | - p | |
687 | | - "ReadFromSpannerChangeStream" >> beam_spanner.ReadChangeStreamFromSpanner( |
| 687 | + p | "ReadSpannerChangeStream" >> beam_spanner.ReadChangeStreamFromSpanner( |
688 | 688 | project_id="spanner-project-id", |
689 | 689 | instance_id="spanner-instance-id", |
690 | 690 | database_id="spanner-database-id", |
@@ -714,32 +714,32 @@ def __init__( |
714 | 714 | expansion_service=None, |
715 | 715 | ): |
716 | 716 | """ |
717 | | - Reads Change Streams from Google Cloud Spanner. |
718 | | - |
719 | | - :param project_id: (Required) Specifies the Cloud Spanner project. |
720 | | - :param instance_id: (Required) Specifies the Cloud Spanner |
721 | | - instance. |
722 | | - :param database_id: (Required) Specifies the Cloud Spanner |
723 | | - database. |
724 | | - :param changeStreamName: (Required) The name of the Spanner |
725 | | - change stream to read. |
726 | | - :param metadataDatabase: (Required) The database where the |
727 | | - change stream metadata is stored. |
728 | | - :param metadataInstance: (Required) The instance where the |
729 | | - change stream metadata database resides. |
730 | | - :param inclusiveStartAt: (Required) An inclusive start timestamp |
731 | | - for reading the change stream. |
732 | | - :param inclusiveEndAt: (Optional) An inclusive end timestamp for |
733 | | - reading the change stream. If not specified, the stream will be |
734 | | - read indefinitely. |
735 | | - :param metadataTable: (Optional) The name of the metadata table used |
736 | | - by the change stream connector. If not specified, a default table |
737 | | - name will be used. |
738 | | - :param rpcPriority: (Optional) The RPC priority for Spanner operations. |
739 | | - Can be 'HIGH', 'MEDIUM', or 'LOW'. |
740 | | - :param watermarkRefreshRate: (Optional) The duration at which the |
741 | | - watermark is refreshed. |
742 | | - """ |
| 717 | + Reads Change Streams from Google Cloud Spanner. |
| 718 | + |
| 719 | + :param project_id: (Required) Specifies the Cloud Spanner project. |
| 720 | + :param instance_id: (Required) Specifies the Cloud Spanner |
| 721 | + instance. |
| 722 | + :param database_id: (Required) Specifies the Cloud Spanner |
| 723 | + database. |
| 724 | + :param changeStreamName: (Required) The name of the Spanner |
| 725 | + change stream to read. |
| 726 | + :param metadataDatabase: (Required) The database where the |
| 727 | + change stream metadata is stored. |
| 728 | + :param metadataInstance: (Required) The instance where the |
| 729 | + change stream metadata database resides. |
| 730 | + :param inclusiveStartAt: (Required) An inclusive start timestamp |
| 731 | + for reading the change stream. |
| 732 | + :param inclusiveEndAt: (Optional) An inclusive end timestamp for |
| 733 | + reading the change stream. If not specified, the stream will be |
| 734 | + read indefinitely. |
| 735 | + :param metadataTable: (Optional) The name of the metadata table used |
| 736 | + by the change stream connector. If not specified, a default table |
| 737 | + name will be used. |
| 738 | + :param rpcPriority: (Optional) The RPC priority for Spanner operations. |
| 739 | + Can be 'HIGH', 'MEDIUM', or 'LOW'. |
| 740 | + :param watermarkRefreshRate: (Optional) The duration at which the |
| 741 | + watermark is refreshed. |
| 742 | + """ |
743 | 743 |
|
744 | 744 | super().__init__( |
745 | 745 | self.URN, |
|
0 commit comments