From 912dd621a6ac66f86b2ad32df8db6ebc1570c0f3 Mon Sep 17 00:00:00 2001 From: Martin Czygan Date: Thu, 22 Jul 2021 00:23:00 +0200 Subject: cleanup (old) clustering related code --- skate/zipkey/zipkey.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'skate/zipkey') diff --git a/skate/zipkey/zipkey.go b/skate/zipkey/zipkey.go index ffd33fe..e5e9f07 100644 --- a/skate/zipkey/zipkey.go +++ b/skate/zipkey/zipkey.go @@ -21,10 +21,10 @@ type ( ) // ZipRun reads records (separated by sep) from two readers, extracts a key -// from each record with a keyFunc and collects records from the two streams -// into a Group. A callback groupFunc can be registered, which allows to -// customize the processing of the group. Current limitation: both streams need -// to use the same keyFunc. +// from each record with a keyFunc and collects records with the same key from +// the two streams into a Group. A callback groupFunc can be registered, which +// allows to customize the processing of the group. Current limitation: both +// streams need to use the same keyFunc. type ZipRun struct { r0, r1 *bufio.Reader kf keyFunc @@ -44,7 +44,7 @@ func New(r0, r1 io.Reader, kf keyFunc, gf groupFunc) *ZipRun { } // Run starts reading from both readers. The process stops, if one reader is -// exhausted or reads from any reader fail. +// exhausted or a read from any reader fails. func (z *ZipRun) Run() error { var ( k0, k1, c0, c1 string // key: k0, k1; current line: c0, c1 -- cgit v1.2.3