diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamContinuationToken.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamContinuationToken.java
index f499a94e45..bb5363a3a5 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamContinuationToken.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamContinuationToken.java
@@ -15,6 +15,7 @@
  */
 package com.google.cloud.bigtable.data.v2.models;
 
+import com.google.api.core.InternalApi;
 import com.google.bigtable.v2.RowRange;
 import com.google.bigtable.v2.StreamContinuationToken;
 import com.google.common.base.MoreObjects;
@@ -57,12 +58,14 @@ public String getToken() {
    * Creates the protobuf. This method is considered an internal implementation detail and not meant
    * to be used by applications.
    */
-  StreamContinuationToken toProto() {
+  @InternalApi("Used in Changestream beam pipeline.")
+  public StreamContinuationToken toProto() {
     return builder.build();
   }
 
   /** Wraps the protobuf {@link StreamContinuationToken}. */
-  static ChangeStreamContinuationToken fromProto(
+  @InternalApi("Used in Changestream beam pipeline.")
+  public static ChangeStreamContinuationToken fromProto(
       @Nonnull StreamContinuationToken streamContinuationToken) {
     return new ChangeStreamContinuationToken(streamContinuationToken.toBuilder());
   }
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamMutation.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamMutation.java
index db0891fda1..f9107220b3 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamMutation.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/ChangeStreamMutation.java
@@ -15,6 +15,7 @@
  */
 package com.google.cloud.bigtable.data.v2.models;
 
+import com.google.api.core.InternalApi;
 import com.google.bigtable.v2.ReadChangeStreamResponse.DataChange.Type;
 import com.google.cloud.bigtable.data.v2.models.Range.TimestampRange;
 import com.google.cloud.bigtable.data.v2.stub.changestream.ChangeStreamRecordMerger;
@@ -99,7 +100,8 @@ private ChangeStreamMutation(Builder builder) {
    * ChangeStreamMutation because `token` and `loWatermark` must be set later when we finish
    * building the logical mutation.
    */
-  static Builder createUserMutation(
+  @InternalApi("Used in Changestream beam pipeline.")
+  public static Builder createUserMutation(
       @Nonnull ByteString rowKey,
       @Nonnull String sourceClusterId,
       @Nonnull Timestamp commitTimestamp,
@@ -112,7 +114,8 @@ static Builder createUserMutation(
    * because `token` and `loWatermark` must be set later when we finish building the logical
    * mutation.
    */
-  static Builder createGcMutation(
+  @InternalApi("Used in Changestream beam pipeline.")
+  public static Builder createGcMutation(
       @Nonnull ByteString rowKey, @Nonnull Timestamp commitTimestamp, int tieBreaker) {
     return new Builder(rowKey, Type.GARBAGE_COLLECTION, null, commitTimestamp, tieBreaker);
   }
@@ -224,7 +227,8 @@ private Builder(ChangeStreamMutation changeStreamMutation) {
       this.lowWatermark = changeStreamMutation.lowWatermark;
     }
 
-    Builder setCell(
+    @InternalApi("Used in Changestream beam pipeline.")
+    public Builder setCell(
         @Nonnull String familyName,
         @Nonnull ByteString qualifier,
         long timestamp,
@@ -233,7 +237,8 @@ Builder setCell(
       return this;
     }
 
-    Builder deleteCells(
+    @InternalApi("Used in Changestream beam pipeline.")
+    public Builder deleteCells(
         @Nonnull String familyName,
         @Nonnull ByteString qualifier,
         @Nonnull TimestampRange timestampRange) {
@@ -241,22 +246,26 @@ Builder deleteCells(
       return this;
     }
 
-    Builder deleteFamily(@Nonnull String familyName) {
+    @InternalApi("Used in Changestream beam pipeline.")
+    public Builder deleteFamily(@Nonnull String familyName) {
       this.entries.add(DeleteFamily.create(familyName));
       return this;
     }
 
-    Builder setToken(@Nonnull String token) {
+    @InternalApi("Used in Changestream beam pipeline.")
+    public Builder setToken(@Nonnull String token) {
       this.token = token;
       return this;
     }
 
-    Builder setLowWatermark(@Nonnull Timestamp lowWatermark) {
+    @InternalApi("Used in Changestream beam pipeline.")
+    public Builder setLowWatermark(@Nonnull Timestamp lowWatermark) {
       this.lowWatermark = lowWatermark;
       return this;
     }
 
-    ChangeStreamMutation build() {
+    @InternalApi("Used in Changestream beam pipeline.")
+    public ChangeStreamMutation build() {
       Preconditions.checkArgument(
           token != null && lowWatermark != null,
           "ChangeStreamMutation must have a continuation token and low watermark.");
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/CloseStream.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/CloseStream.java
index 403705f676..e871c86697 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/CloseStream.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/CloseStream.java
@@ -69,7 +69,8 @@ private void writeObject(ObjectOutputStream output) throws IOException {
   }
 
   /** Wraps the protobuf {@link ReadChangeStreamResponse.CloseStream}. */
-  static CloseStream fromProto(@Nonnull ReadChangeStreamResponse.CloseStream closeStream) {
+  @InternalApi("Used in Changestream beam pipeline.")
+  public static CloseStream fromProto(@Nonnull ReadChangeStreamResponse.CloseStream closeStream) {
     return new CloseStream(closeStream.getStatus(), closeStream.getContinuationTokensList());
   }
 
diff --git a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/Heartbeat.java b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/Heartbeat.java
index f2371c8507..63c23525f3 100644
--- a/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/Heartbeat.java
+++ b/google-cloud-bigtable/src/main/java/com/google/cloud/bigtable/data/v2/models/Heartbeat.java
@@ -32,7 +32,8 @@ private static Heartbeat create(
   }
 
   /** Wraps the protobuf {@link ReadChangeStreamResponse.Heartbeat}. */
-  static Heartbeat fromProto(@Nonnull ReadChangeStreamResponse.Heartbeat heartbeat) {
+  @InternalApi("Used in Changestream beam pipeline.")
+  public static Heartbeat fromProto(@Nonnull ReadChangeStreamResponse.Heartbeat heartbeat) {
     return create(
         ChangeStreamContinuationToken.fromProto(heartbeat.getContinuationToken()),
         heartbeat.getLowWatermark());