()
| 73 | |
| 74 | impl BatchBuilder { |
| 75 | fn schema() -> SchemaRef { |
| 76 | let utf8_dict = |
| 77 | || DataType::Dictionary(Box::new(DataType::Int32), Box::new(DataType::Utf8)); |
| 78 | |
| 79 | Arc::new(Schema::new(vec![ |
| 80 | Field::new("service", utf8_dict(), true), |
| 81 | Field::new("host", utf8_dict(), false), |
| 82 | Field::new("pod", utf8_dict(), false), |
| 83 | Field::new("container", utf8_dict(), false), |
| 84 | Field::new("image", utf8_dict(), false), |
| 85 | Field::new( |
| 86 | "time", |
| 87 | DataType::Timestamp(TimeUnit::Nanosecond, None), |
| 88 | false, |
| 89 | ), |
| 90 | Field::new("client_addr", DataType::Utf8, true), |
| 91 | Field::new("request_duration_ns", DataType::Int32, false), |
| 92 | Field::new("request_user_agent", DataType::Utf8, true), |
| 93 | Field::new("request_method", DataType::Utf8, true), |
| 94 | Field::new("request_host", DataType::Utf8, true), |
| 95 | Field::new("request_bytes", DataType::Int32, true), |
| 96 | Field::new("response_bytes", DataType::Int32, true), |
| 97 | Field::new("response_status", DataType::UInt16, false), |
| 98 | Field::new("decimal_price", DataType::Decimal128(38, 0), false), |
| 99 | ])) |
| 100 | } |
| 101 | |
| 102 | fn is_finished(&self) -> bool { |
| 103 | self.options.row_limit <= self.row_count |
no test coverage detected