Skip to content

Commit 039ae91

Browse files
author
James Cor
committed
clean up
1 parent fd6fc8f commit 039ae91

File tree

5 files changed

+7
-1
lines changed

5 files changed

+7
-1
lines changed

sql/core.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -465,7 +465,7 @@ type ValueExpression interface {
465465
Expression
466466
// EvalValue evaluates the given row frame and returns a result.
467467
EvalValue(ctx *Context, row ValueRow) (Value, error)
468-
// CanSupport indicates whether this expression and all it's children support ValueExpression.
468+
// CanSupport indicates whether this expression and all its children support ValueExpression.
469469
CanSupport() bool
470470
}
471471

sql/plan/filter.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -136,6 +136,7 @@ func (i *FilterIter) Next(ctx *sql.Context) (sql.Row, error) {
136136
}
137137
}
138138

139+
// NextValueRow implements the sql.ValueRowIter interface.
139140
func (i *FilterIter) NextValueRow(ctx *sql.Context) (sql.ValueRow, error) {
140141
for {
141142
row, err := i.childIter.(sql.ValueRowIter).NextValueRow(ctx)

sql/plan/process.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -317,6 +317,7 @@ func (i *TrackedRowIter) Next(ctx *sql.Context) (sql.Row, error) {
317317
return row, nil
318318
}
319319

320+
// NextValueRow implements the sql.ValueRowIter interface.
320321
func (i *TrackedRowIter) NextValueRow(ctx *sql.Context) (sql.ValueRow, error) {
321322
row, err := i.iter.(sql.ValueRowIter).NextValueRow(ctx)
322323
if err != nil {
@@ -329,6 +330,7 @@ func (i *TrackedRowIter) NextValueRow(ctx *sql.Context) (sql.ValueRow, error) {
329330
return row, nil
330331
}
331332

333+
// CanSupport implements the sql.ValueRowIter interface.
332334
func (i *TrackedRowIter) CanSupport(ctx *sql.Context) bool {
333335
iter, ok := i.iter.(sql.ValueRowIter)
334336
return ok && iter.CanSupport(ctx)

sql/rowexec/transaction_iters.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -99,10 +99,12 @@ func (t *TransactionCommittingIter) Next(ctx *sql.Context) (sql.Row, error) {
9999
return t.childIter.Next(ctx)
100100
}
101101

102+
// NextValueRow implements the sql.ValueRowIter interface.
102103
func (t *TransactionCommittingIter) NextValueRow(ctx *sql.Context) (sql.ValueRow, error) {
103104
return t.childIter.(sql.ValueRowIter).NextValueRow(ctx)
104105
}
105106

107+
// CanSupport implements the sql.ValueRowIter interface.
106108
func (t *TransactionCommittingIter) CanSupport(ctx *sql.Context) bool {
107109
childIter, ok := t.childIter.(sql.ValueRowIter)
108110
return ok && childIter.CanSupport(ctx)

sql/table_iter.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,6 +116,7 @@ func (i *TableRowIter) NextValueRow(ctx *Context) (ValueRow, error) {
116116
return row, err
117117
}
118118

119+
// CanSupport implements the sql.ValueRowIter interface.
119120
func (i *TableRowIter) CanSupport(ctx *Context) bool {
120121
if i.partition == nil {
121122
partition, err := i.partitions.Next(ctx)

0 commit comments

Comments
 (0)