| 207 | } |
| 208 | |
| 209 | Status HdfsJsonScanner::ParseWrapper(int max_tuples, int* num_tuples) { |
| 210 | DCHECK(json_parser_->IsTidy()); |
| 211 | SCOPED_TIMER(parse_json_timer_); |
| 212 | Status status; |
| 213 | if (!state_->query_options().disable_optimized_json_count_star && |
| 214 | scan_node_->materialized_slots().size() == 0) { |
| 215 | status = json_parser_->CountJsonObjects(max_tuples, num_tuples); |
| 216 | RETURN_IF_ERROR(buffer_status_); |
| 217 | DCHECK(num_tuples_materialized_ == 0); |
| 218 | num_tuples_materialized_ = WriteTemplateTuples(tuple_row_, *num_tuples); |
| 219 | } else { |
| 220 | Status status = json_parser_->Parse(max_tuples, num_tuples); |
| 221 | RETURN_IF_ERROR(buffer_status_); |
| 222 | } |
| 223 | return status; |
| 224 | } |
| 225 | |
| 226 | bool HdfsJsonScanner::HandleConvertError(const SlotDescriptor* desc, const char* data, |
| 227 | int len) { |
nothing calls this directly
no test coverage detected