()
| 2747 | } |
| 2748 | |
| 2749 | pub fn api_behavior_schema() -> Arc<Schema> { |
| 2750 | Arc::new(Schema::new(vec![ |
| 2751 | Field::new("event_id", DataType::Utf8, false), |
| 2752 | Field::new("occurred_at", DataType::Timestamp(TimeUnit::Millisecond, None), false), |
| 2753 | low_cardinality_utf8_field("client_source", false), |
| 2754 | low_cardinality_utf8_field("method", false), |
| 2755 | low_cardinality_utf8_field("path", false), |
| 2756 | Field::new("query", DataType::Utf8, false), |
| 2757 | low_cardinality_utf8_field("page_path", false), |
| 2758 | low_cardinality_utf8_field("referrer", true), |
| 2759 | Field::new("status_code", DataType::Int32, false), |
| 2760 | Field::new("latency_ms", DataType::Int32, false), |
| 2761 | low_cardinality_utf8_field("client_ip", false), |
| 2762 | low_cardinality_utf8_field("ip_region", false), |
| 2763 | low_cardinality_utf8_field("ua_raw", true), |
| 2764 | low_cardinality_utf8_field("device_type", false), |
| 2765 | low_cardinality_utf8_field("os_family", false), |
| 2766 | low_cardinality_utf8_field("browser_family", false), |
| 2767 | Field::new("request_id", DataType::Utf8, false), |
| 2768 | Field::new("trace_id", DataType::Utf8, false), |
| 2769 | Field::new("created_at", DataType::Timestamp(TimeUnit::Millisecond, None), false), |
| 2770 | Field::new("updated_at", DataType::Timestamp(TimeUnit::Millisecond, None), false), |
| 2771 | ])) |
| 2772 | } |
| 2773 | |
| 2774 | fn build_article_view_batch(record: &ArticleViewRecord) -> Result<RecordBatch> { |
| 2775 | let mut id_builder = StringBuilder::new(); |
no outgoing calls