diff --git a/api/src/main/java/org/apache/iceberg/TableScan.java b/api/src/main/java/org/apache/iceberg/TableScan.java
index 56f7f11d3ccd..fd0eac238511 100644
--- a/api/src/main/java/org/apache/iceberg/TableScan.java
+++ b/api/src/main/java/org/apache/iceberg/TableScan.java
@@ -49,6 +49,18 @@ public interface TableScan extends Scan<TableScan, FileScanTask, CombinedScanTas
    */
   TableScan asOfTime(long timestampMillis);
 
+  /**
+   * Create a new {@link TableScan} from this scan's configuration that will use the snapshot
+   * referenced by a tag.
+   *
+   * @param tag a snapshot ref of type tag.
+   * @return a new scan based on this with the given snapshot ref tag
+   * @throws IllegalArgumentException if the tag cannot be found
+   */
+  default TableScan useTag(String tag) {
+    throw new UnsupportedOperationException("Scanning from a tag is not supported");
+  }
+
   /**
    * Create a new {@link TableScan} from this that will read the given data columns. This produces
    * an expected schema that includes all fields that are either selected or used by this scan's
diff --git a/core/src/main/java/org/apache/iceberg/DataTableScan.java b/core/src/main/java/org/apache/iceberg/DataTableScan.java
index 2d125ae79b9d..a1538b93b24b 100644
--- a/core/src/main/java/org/apache/iceberg/DataTableScan.java
+++ b/core/src/main/java/org/apache/iceberg/DataTableScan.java
@@ -68,6 +68,14 @@ public TableScan useSnapshot(long scanSnapshotId) {
         tableOps(), table(), snapshotSchema, context().useSnapshotId(scanSnapshotId));
   }
 
+  @Override
+  public TableScan useTag(String tag) {
+    Preconditions.checkArgument(tag != null, "Tag does not exist: %s", tag);
+    Preconditions.checkArgument(
+        table().refs().get(tag).isTag(), "Ref %s is a branch, not a tag", tag);
+    return useSnapshot(table().snapshot(tag).snapshotId());
+  }
+
   @Override
   protected TableScan newRefinedScan(
       TableOperations ops, Table table, Schema schema, TableScanContext context) {