Commit Graph

13 Commits (7237323c5dfb2bac5e55cdf183e27f631d4c1d3d)

Author SHA1 Message Date
fengjiayi 304b6b7138 Follow comments
7 years ago
fengjiayi a786611314 Replace Channel in MultiFileReader with BlockingQueue
7 years ago
fengjiayi 7a78294666 Remove Readers' HasNext()
7 years ago
fengjiayi a84b81502c Remove Readers' HasNext()
7 years ago
fengjiayi 49ab52d64d Modify MultipleReader
7 years ago
fengjiayi af24290123 Add 'buffer_size' api for open_files op
7 years ago
fengjiayi 2945a98eb3 Make MultipleReader thread-safe
7 years ago
Abhinav Arora 65534c4762
Fluid channels should match the semantics of Go Channels (#9265)
7 years ago
fengjiayi 2532b922dc Add more unittests and fix bugs
7 years ago
fengjiayi f863866471 Add an unitest
7 years ago
fengjiayi a2981f5c50 fix a bug
7 years ago
fengjiayi 3d677b1eca fix compile errors and make OpenFilesOpMaker derived from FileReaderMakerBase
7 years ago
fengjiayi 550622529c Add MultipleReader and open_files_op
7 years ago