From 5be636a41a24829b5f6e717f3e6db960ecb06786 Mon Sep 17 00:00:00 2001 From: sixcorners Date: Sat, 9 May 2026 22:11:40 -0500 Subject: [PATCH] [CALCITE-7516] Add STREAMABLE_SCANNABLE so that CsvSchema can use CsvStreamScannableTable --- .../src/main/java/org/apache/calcite/adapter/csv/CsvSchema.java | 2 ++ .../src/main/java/org/apache/calcite/adapter/csv/CsvTable.java | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) 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 } }