fix: MirroringConnection in 2.x failed to compile (#139)

Unoperate · Nov 9, 2021 · f09cc3a · f09cc3a
1 parent 4977b40
commit f09cc3a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 1 deletion.
diff --git a/...t-1.x/src/main/java/com/google/cloud/bigtable/mirroring/hbase1_x/MirroringConnection.java b/...t-1.x/src/main/java/com/google/cloud/bigtable/mirroring/hbase1_x/MirroringConnection.java
@@ -66,7 +66,7 @@ public class MirroringConnection implements Connection {
   private final AtomicBoolean closed = new AtomicBoolean(false);
   private final AtomicBoolean aborted = new AtomicBoolean(false);
   protected final boolean performWritesConcurrently;
-  private final boolean waitForSecondaryWrites;
+  protected final boolean waitForSecondaryWrites;
 
   /**
    * The constructor called from {@link

diff --git a/...t-2.x/src/main/java/com/google/cloud/bigtable/mirroring/hbase2_x/MirroringConnection.java b/...t-2.x/src/main/java/com/google/cloud/bigtable/mirroring/hbase2_x/MirroringConnection.java
@@ -88,6 +88,7 @@ public Table build() {
                 secondaryWriteErrorConsumer,
                 readSampler,
                 performWritesConcurrently,
+                waitForSecondaryWrites,
                 mirroringTracer);
         referenceCounter.holdReferenceUntilClosing(table);
         return table;

diff --git a/...client-2.x/src/main/java/com/google/cloud/bigtable/mirroring/hbase2_x/MirroringTable.java b/...client-2.x/src/main/java/com/google/cloud/bigtable/mirroring/hbase2_x/MirroringTable.java
@@ -38,6 +38,7 @@ public MirroringTable(
       SecondaryWriteErrorConsumer secondaryWriteErrorConsumer,
       ReadSampler readSampler,
       boolean performWritesConcurrently,
+      boolean waitForSecondaryWrites,
       MirroringTracer mirroringTracer) {
     super(
         primaryTable,
@@ -48,6 +49,7 @@ public MirroringTable(
         secondaryWriteErrorConsumer,
         readSampler,
         performWritesConcurrently,
+        waitForSecondaryWrites,
         mirroringTracer);
   }