Searched defs:JoinBucketKeeper (Results 1 – 1 of 1) sorted by relevance
124 type JoinBucketKeeper struct { struct126 recordReader input.IRecordReader127 context *types.Context128 inputChannel <-chan *types.RecordAndContext129 errorChannel chan error131 recordReaderDone bool133 leftJoinFieldNames []string152 JoinBucket *JoinBucket153 leftUnpaireds *list.List155 leof bool[all …]