@@ -68,8 +68,10 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
68
68
String sql = "select \" tinyIntField\" from arrowdatatype" ;
69
69
String plan = "PLAN=ArrowToEnumerableConverter\n "
70
70
+ " ArrowProject(tinyIntField=[$0])\n "
71
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
72
- String result = "tinyIntField=0\n tinyIntField=1\n " ;
71
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
72
+ + "\n " ;
73
+ String result = "tinyIntField=0\n "
74
+ + "tinyIntField=1\n " ;
73
75
CalciteAssert .that ()
74
76
.with (arrow )
75
77
.query (sql )
@@ -82,8 +84,10 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
82
84
String sql = "select \" smallIntField\" from arrowdatatype" ;
83
85
String plan = "PLAN=ArrowToEnumerableConverter\n "
84
86
+ " ArrowProject(smallIntField=[$1])\n "
85
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
86
- String result = "smallIntField=0\n smallIntField=1\n " ;
87
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
88
+ + "\n " ;
89
+ String result = "smallIntField=0\n "
90
+ + "smallIntField=1\n " ;
87
91
CalciteAssert .that ()
88
92
.with (arrow )
89
93
.query (sql )
@@ -96,8 +100,10 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
96
100
String sql = "select \" intField\" from arrowdatatype" ;
97
101
String plan = "PLAN=ArrowToEnumerableConverter\n "
98
102
+ " ArrowProject(intField=[$2])\n "
99
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
100
- String result = "intField=0\n intField=1\n " ;
103
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
104
+ + "\n " ;
105
+ String result = "intField=0\n "
106
+ + "intField=1\n " ;
101
107
CalciteAssert .that ()
102
108
.with (arrow )
103
109
.query (sql )
@@ -110,8 +116,10 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
110
116
String sql = "select \" longField\" from arrowdatatype" ;
111
117
String plan = "PLAN=ArrowToEnumerableConverter\n "
112
118
+ " ArrowProject(longField=[$5])\n "
113
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
114
- String result = "longField=0\n longField=1\n " ;
119
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
120
+ + "\n " ;
121
+ String result = "longField=0\n "
122
+ + "longField=1\n " ;
115
123
CalciteAssert .that ()
116
124
.with (arrow )
117
125
.query (sql )
@@ -124,8 +132,10 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
124
132
String sql = "select \" floatField\" from arrowdatatype" ;
125
133
String plan = "PLAN=ArrowToEnumerableConverter\n "
126
134
+ " ArrowProject(floatField=[$4])\n "
127
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
128
- String result = "floatField=0.0\n floatField=1.0\n " ;
135
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
136
+ + "\n " ;
137
+ String result = "floatField=0.0\n "
138
+ + "floatField=1.0\n " ;
129
139
CalciteAssert .that ()
130
140
.with (arrow )
131
141
.query (sql )
@@ -138,8 +148,10 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
138
148
String sql = "select \" doubleField\" from arrowdatatype" ;
139
149
String plan = "PLAN=ArrowToEnumerableConverter\n "
140
150
+ " ArrowProject(doubleField=[$6])\n "
141
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
142
- String result = "doubleField=0.0\n doubleField=1.0\n " ;
151
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
152
+ + "\n " ;
153
+ String result = "doubleField=0.0\n "
154
+ + "doubleField=1.0\n " ;
143
155
CalciteAssert .that ()
144
156
.with (arrow )
145
157
.query (sql )
@@ -152,8 +164,10 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
152
164
String sql = "select \" decimalField\" from arrowdatatype" ;
153
165
String plan = "PLAN=ArrowToEnumerableConverter\n "
154
166
+ " ArrowProject(decimalField=[$8])\n "
155
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
156
- String result = "decimalField=0.00\n decimalField=1.00\n " ;
167
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
168
+ + "\n " ;
169
+ String result = "decimalField=0.00\n "
170
+ + "decimalField=1.00\n " ;
157
171
CalciteAssert .that ()
158
172
.with (arrow )
159
173
.query (sql )
@@ -166,7 +180,8 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
166
180
String sql = "select \" dateField\" from arrowdatatype" ;
167
181
String plan = "PLAN=ArrowToEnumerableConverter\n "
168
182
+ " ArrowProject(dateField=[$9])\n "
169
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
183
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
184
+ + "\n " ;
170
185
String result = "dateField=1970-01-01\n "
171
186
+ "dateField=1970-01-02\n " ;
172
187
CalciteAssert .that ()
@@ -181,8 +196,11 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
181
196
String sql = "select \" booleanField\" from arrowdatatype" ;
182
197
String plan = "PLAN=ArrowToEnumerableConverter\n "
183
198
+ " ArrowProject(booleanField=[$7])\n "
184
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
185
- String result = "booleanField=null\n booleanField=true\n booleanField=false\n " ;
199
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
200
+ + "\n " ;
201
+ String result = "booleanField=null\n "
202
+ + "booleanField=true\n "
203
+ + "booleanField=false\n " ;
186
204
CalciteAssert .that ()
187
205
.with (arrow )
188
206
.query (sql )
@@ -198,8 +216,10 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
198
216
String sql = "select \" decimalField2\" from arrowdatatype" ;
199
217
String plan = "PLAN=ArrowToEnumerableConverter\n "
200
218
+ " ArrowProject(decimalField2=[$10])\n "
201
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
202
- String result = "decimalField2=20.000\n decimalField2=21.000\n " ;
219
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
220
+ + "\n " ;
221
+ String result = "decimalField2=20.000\n "
222
+ + "decimalField2=21.000\n " ;
203
223
CalciteAssert .that ()
204
224
.with (arrow )
205
225
.query (sql )
@@ -212,7 +232,8 @@ static void initializeArrowState(@TempDir Path sharedTempDir)
212
232
String sql = "select \" timeField\" from arrowdatatype" ;
213
233
String plan = "PLAN=ArrowToEnumerableConverter\n "
214
234
+ " ArrowProject(timeField=[$11])\n "
215
- + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n \n " ;
235
+ + " ArrowTableScan(table=[[ARROW, ARROWDATATYPE]], fields=[[0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]])\n "
236
+ + "\n " ;
216
237
String result = "timeField=00:00:00\n "
217
238
+ "timeField=00:00:01\n " ;
218
239
CalciteAssert .that ()
0 commit comments