diff --git a/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvSchema.java b/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvSchema.java
index e612aa83e4a5..f1e2a3f7a65f 100644
--- a/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvSchema.java
+++ b/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvSchema.java
@@ -116,6 +116,8 @@ private Table createTable(Source source) {
       return new CsvScannableTable(source, null);
     case FILTERABLE:
       return new CsvFilterableTable(source, null);
+    case STREAMABLE_SCANNABLE:
+      return new CsvStreamScannableTable(source, null);
     default:
       throw new AssertionError("Unknown flavor " + this.flavor);
     }
diff --git a/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvTable.java b/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvTable.java
index a882e5c8247c..189601f6ad84 100644
--- a/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvTable.java
+++ b/example/csv/src/main/java/org/apache/calcite/adapter/csv/CsvTable.java
@@ -73,6 +73,6 @@ protected boolean isStream() {
 
   /** Various degrees of table "intelligence". */
   public enum Flavor {
-    SCANNABLE, FILTERABLE, TRANSLATABLE
+    SCANNABLE, FILTERABLE, TRANSLATABLE, STREAMABLE_SCANNABLE
   }
 }