| 193 | } |
| 194 | |
| 195 | Status HdfsJsonScanner::FindFirstTuple() { |
| 196 | DCHECK_EQ(scanner_state_, OPENED); |
| 197 | if (stream_->scan_range()->offset() == 0) { |
| 198 | scanner_state_ = SCANNING; |
| 199 | return Status::OK(); |
| 200 | } |
| 201 | SCOPED_TIMER(parse_json_timer_); |
| 202 | if (json_parser_->MoveToNextJson()) { |
| 203 | scanner_state_ = SCANNING; |
| 204 | DCHECK_OK(buffer_status_); |
| 205 | } |
| 206 | return buffer_status_; |
| 207 | } |
| 208 | |
| 209 | Status HdfsJsonScanner::ParseWrapper(int max_tuples, int* num_tuples) { |
| 210 | DCHECK(json_parser_->IsTidy()); |
nothing calls this directly
no test coverage detected