Add option to adjust ReadChangeStream API timeout to allow longer timeout for...
Add option to adjust ReadChangeStream API timeout to allow longer timeout for longer checkpoint durations (#33001) * Add option to adjust ReadChangeStream API timeout to allow longer timeout for longer checkpoint durations Change-Id: Ia61388bed5997b7138b15a014d6370d49cbf5277 * Update comment to clarify timeout padding Change-Id: If34866637045314dfeef1807122cc34b97cc5ddc * Move default change stream timeout into the accessor to avoid confusion about where default is set Change-Id: Ia76ff2e3ba4f6a91299e907ec404b720e900c76f * fix format issue Change-Id: I89ba1d48742d5204168249d632accf86d68e140c
显示
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java 21 个添加, 0 个删除.../java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIO.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/dao/BigtableChangeStreamAccessor.java 8 个添加, 3 个删除...table/changestreams/dao/BigtableChangeStreamAccessor.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/bigtable/changestreams/dao/DaoFactory.java 13 个添加, 1 个删除...eam/sdk/io/gcp/bigtable/changestreams/dao/DaoFactory.java
- sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java 2 个添加, 0 个删除...a/org/apache/beam/sdk/io/gcp/bigtable/BigtableIOTest.java
加载中
想要评论请 注册 或 登录