RecordStream is an implementation of the RecordReader interface which combines multiple underlying RecordReader and only expose records that are not from control batches.
| 330 | // combines multiple underlying RecordReader and only expose records that |
| 331 | // are not from control batches. |
| 332 | type RecordStream struct { |
| 333 | Records []RecordReader |
| 334 | index int |
| 335 | } |
| 336 | |
| 337 | func (s *RecordStream) ReadRecord() (*Record, error) { |
| 338 | for { |
nothing calls this directly
no outgoing calls
no test coverage detected