liquid-cache-server 0.1.10

10x lower latency for cloud-native DataFusion
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110

use serde::{Deserialize, Serialize};

/// Parameters for the set_execution_stats endpoint
#[derive(Deserialize, Serialize, Clone)]
pub struct ExecutionStats {
    /// Plan ID for the execution plan
    pub plan_ids: Vec<String>,
    /// Display name for the execution plan
    pub display_name: String,
    /// Flamegraph SVG for the execution plan
    pub flamegraph_svg: Option<String>,
    /// Network traffic bytes for the execution plan
    pub network_traffic_bytes: u64,
    /// Execution time in milliseconds
    pub execution_time_ms: u64,
    /// User input SQL
    pub user_sql: Vec<String>,
}

/// Execution stats with plan
#[derive(Serialize)]
pub struct ExecutionStatsWithPlan {
    /// Execution stats
    pub execution_stats: ExecutionStats,
    /// Plan info
    pub plans: Vec<PlanInfo>,
}

/// Response for the admin server
#[derive(Serialize, Deserialize)]
pub struct ApiResponse {
    /// Message for the response
    pub message: String,
    /// Status for the response
    pub status: String,
}

/// Schema field
#[derive(Serialize)]
pub struct SchemaField {
    /// Field name
    pub name: String,
    /// Field data type
    pub data_type: String,
}

/// Column statistics
#[derive(Serialize)]
pub struct ColumnStatistics {
    /// Column name
    pub name: String,
    /// Null count
    pub null: Option<String>,
    /// Max value
    pub max: Option<String>,
    /// Min value
    pub min: Option<String>,
    /// Sum value
    pub sum: Option<String>,
    /// Distinct count
    pub distinct_count: Option<String>,
}

/// Statistics
#[derive(Serialize)]
pub struct Statistics {
    /// Number of rows
    pub num_rows: String,
    /// Total byte size
    pub total_byte_size: String,
    /// Column statistics
    pub column_statistics: Vec<ColumnStatistics>,
}

/// Metric
#[derive(Serialize)]
pub struct MetricValues {
    /// Metric name
    pub name: String,
    /// Metric value
    pub value: String,
}

/// Execution plan with stats
#[derive(Serialize)]
pub struct ExecutionPlanWithStats {
    /// Execution plan name
    pub name: String,
    /// Schema fields
    pub schema: Vec<SchemaField>,
    /// Statistics
    pub statistics: Statistics,
    /// Metrics
    pub metrics: Vec<MetricValues>,
    /// Children
    pub children: Vec<ExecutionPlanWithStats>,
}

/// Plan info
#[derive(Serialize)]
pub struct PlanInfo {
    /// Created at
    pub created_at: u64,
    /// Execution plan
    pub plan: ExecutionPlanWithStats,
    /// ID
    pub id: String,
    /// Predicate
    pub predicate: Option<String>,
}