diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2021-12-09 09:03:42 +0000 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2021-12-09 09:03:42 +0000 |
| commit | cdf021719de896b5e1ca347ad518e79067bb8ca5 (patch) | |
| tree | f029980131c02c4cecebb6e5b956f369e8cb6c0e /internal/mapr | |
| parent | 1bdd53a9646b4e31bd5c22a3a262e734cb2aae51 (diff) | |
Refactor WriteResult method.
Diffstat (limited to 'internal/mapr')
| -rw-r--r-- | internal/mapr/groupset.go | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/internal/mapr/groupset.go b/internal/mapr/groupset.go index 6ffc8b9..39b0b17 100644 --- a/internal/mapr/groupset.go +++ b/internal/mapr/groupset.go @@ -218,6 +218,12 @@ func (g *GroupSet) WriteResult(query *Query) error { } defer fd.Close() + return g.writeResult(query, rows, tmpOutfile, fd) +} + +func (g *GroupSet) writeResult(query *Query, rows []result, tmpOutfile string, + fd *os.File) error { + // Generate header now lastIndex := len(query.Select) - 1 for i, sc := range query.Select { |