Materialize — structured SELECT INTO

curl -sS -X POST "https://k3.dev.dodil.io/kb-prod/tables/events/materialize" \
  -H "Authorization: Bearer $DODIL_TOKEN" \
  -H "Content-Type: application/json" \
  -d '{
    "bucket": "kb-prod",
    "sourceTable": "events",
    "sql": "SELECT user_id, occurred_at, event_type, payload, occurred_at - LAG(occurred_at) OVER (PARTITION BY user_id ORDER BY occurred_at) AS gap_us FROM events",
    "targetTable": "events_sessionized",
    "partitionColumns": ["event_type"],
    "mode": "create"
  }'

rpc Materialize(MaterializeRequest) returns (MaterializeResponse);
 
message MaterializeRequest {
  string bucket = 1;
  string source_table = 2;
  string sql = 3;                             // SELECT statement (same dialect as Execute)
  string target_table = 4;
  repeated string partition_columns = 5;      // empty = unpartitioned
  string mode = 6;                            // "create" (default) | "replace" | "append"
  map<string, string> lookup_tables = 7;      // alias → table for broadcast JOINs in source SQL
}

grpcurl \
  -H "Authorization: Bearer $DODIL_TOKEN" \
  -d '{
    "bucket": "kb-prod",
    "source_table": "events",
    "sql": "SELECT user_id, occurred_at, event_type, payload, occurred_at - LAG(occurred_at) OVER (PARTITION BY user_id ORDER BY occurred_at) AS gap_us FROM events",
    "target_table": "events_sessionized",
    "partition_columns": ["event_type"],
    "mode": "create"
  }' \
  $K3_GRPC \
  dodil.k3.tables.v1.TableService/Materialize

{
  "targetTable": "events_sessionized",
  "targetLocation": "s3://kb-prod/.../events_sessionized",
  "rowsMaterialized": "12483",
  "version": "1"
}

message MaterializeResponse {
  string target_table = 1;
  string target_location = 2;                 // s3:// path
  int64 rows_materialized = 3;
  int64 version = 4;
}