File tree Expand file tree Collapse file tree 1 file changed +0
-49
lines changed Expand file tree Collapse file tree 1 file changed +0
-49
lines changed Original file line number Diff line number Diff line change @@ -2,7 +2,6 @@ package gitbase
2
2
3
3
import (
4
4
"fmt"
5
- "io"
6
5
"strings"
7
6
8
7
"gopkg.in/src-d/go-mysql-server.v0/sql"
@@ -181,51 +180,3 @@ func (i schemaMapperIter) Next() (sql.Row, error) {
181
180
return row , nil
182
181
}
183
182
func (i schemaMapperIter ) Close () error { return i .iter .Close () }
184
-
185
- type squashRowIter struct {
186
- ctx * sql.Context
187
- partitions sql.PartitionIter
188
- t sql.Table
189
- iter sql.RowIter
190
- }
191
-
192
- func (i * squashRowIter ) Next () (sql.Row , error ) {
193
- for {
194
- if i .iter == nil {
195
- p , err := i .partitions .Next ()
196
- if err != nil {
197
- return nil , err
198
- }
199
-
200
- i .iter , err = i .t .PartitionRows (i .ctx , p )
201
- if err != nil {
202
- return nil , err
203
- }
204
- }
205
-
206
- row , err := i .iter .Next ()
207
- if err != nil {
208
- if err == io .EOF {
209
- i .iter .Close ()
210
- i .iter = nil
211
- continue
212
- }
213
-
214
- i .iter .Close ()
215
- return nil , err
216
- }
217
-
218
- return row , nil
219
- }
220
- }
221
-
222
- func (i * squashRowIter ) Close () error {
223
- if i .iter != nil {
224
- if err := i .iter .Close (); err != nil {
225
- _ = i .partitions .Close ()
226
- return err
227
- }
228
- }
229
-
230
- return i .partitions .Close ()
231
- }
You can’t perform that action at this time.
0 commit comments