liquid-cache-client 0.1.10

10x lower latency for cloud-native DataFusion
Documentation
---
source: src/client/src/tests/mod.rs
expression: displayable.tree_render().to_string()
---
┌───────────────────────────┐
│  SortPreservingMergeExec  │
│    --------------------   │
│   l_returnflag ASC NULLS  │
│     LAST, l_linestatus    │
│       ASC NULLS LAST      │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│          SortExec         │
│    --------------------   │
│  l_returnflag@0 ASC NULLS │
│    LAST, l_linestatus@1   │
│       ASC NULLS LAST      │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│       ProjectionExec      │
│    --------------------   │
│         avg_disc:         │
│  avg(lineitem.l_discount) │
│                           │
│         avg_price:        │
│        avg(lineitem       │
│        .l_extendedp       │
│           rice)           │
│                           │
│          avg_qty:         │
│  avg(lineitem.l_quantity) │
│                           │
│        count_order:       │
│      count(Int64(1))      │
│                           │
│       l_linestatus:       │
│        l_linestatus       │
│                           │
│       l_returnflag:       │
│        l_returnflag       │
│                           │
│      sum_base_price:      │
│        sum(lineitem       │
│        .l_extendedp       │
│           rice)           │
│                           │
│        sum_charge:        │
│        sum(lineitem       │
│        .l_extendedp       │
│ rice * Int64(1) - lineitem│
│            ...            │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│       AggregateExec       │
│    --------------------   │
│           aggr:           │
│ sum(lineitem.l_quantity), │
│        sum(lineitem       │
│      .l_extendedpric      │
│      e), sum(lineitem     │
│      .l_extendedprice     │
│    * Int64(1) - lineitem  │
│     .l_discount), sum     │
│         (lineitem         │
│       .l_extendedpri      │
│  ce * Int64(1) - lineitem │
│  .l_discount * Int64(1)   │
│   + lineitem.l_tax), avg  │
│   (lineitem.l_quantity),  │
│        avg(lineitem       │
│       .l_extendedpri      │
│     ce), avg(lineitem     │
│       .l_discount),       │
│          count(1)         │
│                           │
│         group_by:         │
│ l_returnflag, l_linestatus│
│                           │
│           mode:           │
│      FinalPartitioned     │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│    CoalesceBatchesExec    │
│    --------------------   │
│     target_batch_size:    │
│           16384           │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│      RepartitionExec      │
│    --------------------   │
│ partition_count(in->out): │
│           8 -> 8          │
│                           │
│    partitioning_scheme:   │
│   Hash([l_returnflag@0,   │
│     l_linestatus@1], 8)   │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│       AggregateExec       │
│    --------------------   │
│           aggr:           │
│ sum(lineitem.l_quantity), │
│        sum(lineitem       │
│      .l_extendedpric      │
│      e), sum(lineitem     │
│      .l_extendedprice     │
│    * Int64(1) - lineitem  │
│     .l_discount), sum     │
│         (lineitem         │
│       .l_extendedpri      │
│  ce * Int64(1) - lineitem │
│  .l_discount * Int64(1)   │
│   + lineitem.l_tax), avg  │
│   (lineitem.l_quantity),  │
│        avg(lineitem       │
│       .l_extendedpri      │
│     ce), avg(lineitem     │
│       .l_discount),       │
│          count(1)         │
│                           │
│         group_by:         │
│ l_returnflag, l_linestatus│
│                           │
│       mode: Partial       │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│       ProjectionExec      │
│    --------------------   │
│      __common_expr_1:     │
│ l_extendedprice * (Some(1)│
│    ,20,0 - l_discount)    │
│                           │
│        l_discount:        │
│         l_discount        │
│                           │
│      l_extendedprice:     │
│      l_extendedprice      │
│                           │
│       l_linestatus:       │
│        l_linestatus       │
│                           │
│        l_quantity:        │
│         l_quantity        │
│                           │
│       l_returnflag:       │
│        l_returnflag       │
│                           │
│        l_tax: l_tax       │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│   LiquidCacheClientExec   │
│    --------------------   │
│          server:          │
│  http://localhost:50051,  │
│      object_stores=[]     │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│      RepartitionExec      │
│    --------------------   │
│ partition_count(in->out): │
│           1 -> 8          │
│                           │
│    partitioning_scheme:   │
│     RoundRobinBatch(8)    │
└─────────────┬─────────────┘
┌─────────────┴─────────────┐
│       DataSourceExec      │
│    --------------------   │
│          files: 1         │
│      format: parquet      │
│                           │
│         predicate:        │
│  l_shipdate <= 1998-09-02 │
└───────────────────────────┘