Polars

curl --request POST \
  --url https://oleander.dev/api/v1/warehouse/polars \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data @- <<EOF
{
  "query": "SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC",
  "tables": [
    "flowers=default.flowers"
  ],
  "script": "table = params.get('table', 'default.flowers')\nlimit = int(params.get('limit', 50))\n\nflowers = scan(table)\n\nresult = (\n    flowers.group_by('species')\n    .agg(\n        pl.len().alias('count'),\n        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\n        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\n    )\n    .sort('avg_sepal_length', descending=True)\n    .head(limit)\n)",
  "params": {
    "table": "default.flowers",
    "limit": "25"
  },
  "distributed": false,
  "instanceType": "t4g.medium",
  "clusterSize": 4,
  "vcpus": 2,
  "catalog": "oleander",
  "destination": "default.flower_summary",
  "saveMode": "overwrite"
}
EOF

import requests

url = "https://oleander.dev/api/v1/warehouse/polars"

payload = {
    "query": "SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC",
    "tables": ["flowers=default.flowers"],
    "script": "table = params.get('table', 'default.flowers')
limit = int(params.get('limit', 50))

flowers = scan(table)

result = (
    flowers.group_by('species')
    .agg(
        pl.len().alias('count'),
        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),
        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),
    )
    .sort('avg_sepal_length', descending=True)
    .head(limit)
)",
    "params": {
        "table": "default.flowers",
        "limit": "25"
    },
    "distributed": False,
    "instanceType": "t4g.medium",
    "clusterSize": 4,
    "vcpus": 2,
    "catalog": "oleander",
    "destination": "default.flower_summary",
    "saveMode": "overwrite"
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    query: 'SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC',
    tables: ['flowers=default.flowers'],
    script: 'table = params.get(\'table\', \'default.flowers\')\nlimit = int(params.get(\'limit\', 50))\n\nflowers = scan(table)\n\nresult = (\n    flowers.group_by(\'species\')\n    .agg(\n        pl.len().alias(\'count\'),\n        pl.col(\'sepal_length\').mean().round(2).alias(\'avg_sepal_length\'),\n        pl.col(\'petal_length\').mean().round(2).alias(\'avg_petal_length\'),\n    )\n    .sort(\'avg_sepal_length\', descending=True)\n    .head(limit)\n)',
    params: {table: 'default.flowers', limit: '25'},
    distributed: false,
    instanceType: 't4g.medium',
    clusterSize: 4,
    vcpus: 2,
    catalog: 'oleander',
    destination: 'default.flower_summary',
    saveMode: 'overwrite'
  })
};

fetch('https://oleander.dev/api/v1/warehouse/polars', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://oleander.dev/api/v1/warehouse/polars",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'query' => 'SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC',
    'tables' => [
        'flowers=default.flowers'
    ],
    'script' => 'table = params.get(\'table\', \'default.flowers\')
limit = int(params.get(\'limit\', 50))

flowers = scan(table)

result = (
    flowers.group_by(\'species\')
    .agg(
        pl.len().alias(\'count\'),
        pl.col(\'sepal_length\').mean().round(2).alias(\'avg_sepal_length\'),
        pl.col(\'petal_length\').mean().round(2).alias(\'avg_petal_length\'),
    )
    .sort(\'avg_sepal_length\', descending=True)
    .head(limit)
)',
    'params' => [
        'table' => 'default.flowers',
        'limit' => '25'
    ],
    'distributed' => false,
    'instanceType' => 't4g.medium',
    'clusterSize' => 4,
    'vcpus' => 2,
    'catalog' => 'oleander',
    'destination' => 'default.flower_summary',
    'saveMode' => 'overwrite'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://oleander.dev/api/v1/warehouse/polars"

	payload := strings.NewReader("{\n  \"query\": \"SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC\",\n  \"tables\": [\n    \"flowers=default.flowers\"\n  ],\n  \"script\": \"table = params.get('table', 'default.flowers')\\nlimit = int(params.get('limit', 50))\\n\\nflowers = scan(table)\\n\\nresult = (\\n    flowers.group_by('species')\\n    .agg(\\n        pl.len().alias('count'),\\n        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\\n        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\\n    )\\n    .sort('avg_sepal_length', descending=True)\\n    .head(limit)\\n)\",\n  \"params\": {\n    \"table\": \"default.flowers\",\n    \"limit\": \"25\"\n  },\n  \"distributed\": false,\n  \"instanceType\": \"t4g.medium\",\n  \"clusterSize\": 4,\n  \"vcpus\": 2,\n  \"catalog\": \"oleander\",\n  \"destination\": \"default.flower_summary\",\n  \"saveMode\": \"overwrite\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://oleander.dev/api/v1/warehouse/polars")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"query\": \"SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC\",\n  \"tables\": [\n    \"flowers=default.flowers\"\n  ],\n  \"script\": \"table = params.get('table', 'default.flowers')\\nlimit = int(params.get('limit', 50))\\n\\nflowers = scan(table)\\n\\nresult = (\\n    flowers.group_by('species')\\n    .agg(\\n        pl.len().alias('count'),\\n        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\\n        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\\n    )\\n    .sort('avg_sepal_length', descending=True)\\n    .head(limit)\\n)\",\n  \"params\": {\n    \"table\": \"default.flowers\",\n    \"limit\": \"25\"\n  },\n  \"distributed\": false,\n  \"instanceType\": \"t4g.medium\",\n  \"clusterSize\": 4,\n  \"vcpus\": 2,\n  \"catalog\": \"oleander\",\n  \"destination\": \"default.flower_summary\",\n  \"saveMode\": \"overwrite\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://oleander.dev/api/v1/warehouse/polars")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"query\": \"SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC\",\n  \"tables\": [\n    \"flowers=default.flowers\"\n  ],\n  \"script\": \"table = params.get('table', 'default.flowers')\\nlimit = int(params.get('limit', 50))\\n\\nflowers = scan(table)\\n\\nresult = (\\n    flowers.group_by('species')\\n    .agg(\\n        pl.len().alias('count'),\\n        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\\n        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\\n    )\\n    .sort('avg_sepal_length', descending=True)\\n    .head(limit)\\n)\",\n  \"params\": {\n    \"table\": \"default.flowers\",\n    \"limit\": \"25\"\n  },\n  \"distributed\": false,\n  \"instanceType\": \"t4g.medium\",\n  \"clusterSize\": 4,\n  \"vcpus\": 2,\n  \"catalog\": \"oleander\",\n  \"destination\": \"default.flower_summary\",\n  \"saveMode\": \"overwrite\"\n}"

response = http.request(request)
puts response.read_body

{
  "success": true,
  "results": {
    "columns": [
      "<string>"
    ],
    "column_types": [
      "<string>"
    ],
    "rows": [
      [
        "<unknown>"
      ]
    ]
  },
  "row_count": 123,
  "execution_time": "<string>",
  "error": "<string>",
  "saved": {
    "table": "<string>",
    "rows_written": 123,
    "mode": "<string>"
  },
  "compute": {
    "mode": "<string>",
    "distributed": true,
    "instanceType": "<string>",
    "clusterSize": 123
  }
}

{
  "error": "<string>",
  "details": "<string>"
}

{
  "error": "Unauthorized"
}

{
  "status": 500
}

Queries

Polars

Execute a Polars workload against your Iceberg lake tables. Supports two modes: query (Polars SQL run against registered tables) and script (user-authored Python that assigns result to a LazyFrame or DataFrame). Workloads run in an isolated sandbox; pass distributed: true to offload execution to Polars Cloud.

Beta: Observability (lineage, traces, logs) is not yet captured for Polars workloads.

Cost note: Distributed execution incurs Polars Cloud compute charges in addition to oleander usage. Start small and scale up as needed.

POST

api

warehouse

polars

Polars

curl --request POST \
  --url https://oleander.dev/api/v1/warehouse/polars \
  --header 'Authorization: Bearer <token>' \
  --header 'Content-Type: application/json' \
  --data @- <<EOF
{
  "query": "SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC",
  "tables": [
    "flowers=default.flowers"
  ],
  "script": "table = params.get('table', 'default.flowers')\nlimit = int(params.get('limit', 50))\n\nflowers = scan(table)\n\nresult = (\n    flowers.group_by('species')\n    .agg(\n        pl.len().alias('count'),\n        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\n        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\n    )\n    .sort('avg_sepal_length', descending=True)\n    .head(limit)\n)",
  "params": {
    "table": "default.flowers",
    "limit": "25"
  },
  "distributed": false,
  "instanceType": "t4g.medium",
  "clusterSize": 4,
  "vcpus": 2,
  "catalog": "oleander",
  "destination": "default.flower_summary",
  "saveMode": "overwrite"
}
EOF

import requests

url = "https://oleander.dev/api/v1/warehouse/polars"

payload = {
    "query": "SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC",
    "tables": ["flowers=default.flowers"],
    "script": "table = params.get('table', 'default.flowers')
limit = int(params.get('limit', 50))

flowers = scan(table)

result = (
    flowers.group_by('species')
    .agg(
        pl.len().alias('count'),
        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),
        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),
    )
    .sort('avg_sepal_length', descending=True)
    .head(limit)
)",
    "params": {
        "table": "default.flowers",
        "limit": "25"
    },
    "distributed": False,
    "instanceType": "t4g.medium",
    "clusterSize": 4,
    "vcpus": 2,
    "catalog": "oleander",
    "destination": "default.flower_summary",
    "saveMode": "overwrite"
}
headers = {
    "Authorization": "Bearer <token>",
    "Content-Type": "application/json"
}

response = requests.post(url, json=payload, headers=headers)

print(response.text)

const options = {
  method: 'POST',
  headers: {Authorization: 'Bearer <token>', 'Content-Type': 'application/json'},
  body: JSON.stringify({
    query: 'SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC',
    tables: ['flowers=default.flowers'],
    script: 'table = params.get(\'table\', \'default.flowers\')\nlimit = int(params.get(\'limit\', 50))\n\nflowers = scan(table)\n\nresult = (\n    flowers.group_by(\'species\')\n    .agg(\n        pl.len().alias(\'count\'),\n        pl.col(\'sepal_length\').mean().round(2).alias(\'avg_sepal_length\'),\n        pl.col(\'petal_length\').mean().round(2).alias(\'avg_petal_length\'),\n    )\n    .sort(\'avg_sepal_length\', descending=True)\n    .head(limit)\n)',
    params: {table: 'default.flowers', limit: '25'},
    distributed: false,
    instanceType: 't4g.medium',
    clusterSize: 4,
    vcpus: 2,
    catalog: 'oleander',
    destination: 'default.flower_summary',
    saveMode: 'overwrite'
  })
};

fetch('https://oleander.dev/api/v1/warehouse/polars', options)
  .then(res => res.json())
  .then(res => console.log(res))
  .catch(err => console.error(err));

<?php

$curl = curl_init();

curl_setopt_array($curl, [
  CURLOPT_URL => "https://oleander.dev/api/v1/warehouse/polars",
  CURLOPT_RETURNTRANSFER => true,
  CURLOPT_ENCODING => "",
  CURLOPT_MAXREDIRS => 10,
  CURLOPT_TIMEOUT => 30,
  CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
  CURLOPT_CUSTOMREQUEST => "POST",
  CURLOPT_POSTFIELDS => json_encode([
    'query' => 'SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC',
    'tables' => [
        'flowers=default.flowers'
    ],
    'script' => 'table = params.get(\'table\', \'default.flowers\')
limit = int(params.get(\'limit\', 50))

flowers = scan(table)

result = (
    flowers.group_by(\'species\')
    .agg(
        pl.len().alias(\'count\'),
        pl.col(\'sepal_length\').mean().round(2).alias(\'avg_sepal_length\'),
        pl.col(\'petal_length\').mean().round(2).alias(\'avg_petal_length\'),
    )
    .sort(\'avg_sepal_length\', descending=True)
    .head(limit)
)',
    'params' => [
        'table' => 'default.flowers',
        'limit' => '25'
    ],
    'distributed' => false,
    'instanceType' => 't4g.medium',
    'clusterSize' => 4,
    'vcpus' => 2,
    'catalog' => 'oleander',
    'destination' => 'default.flower_summary',
    'saveMode' => 'overwrite'
  ]),
  CURLOPT_HTTPHEADER => [
    "Authorization: Bearer <token>",
    "Content-Type: application/json"
  ],
]);

$response = curl_exec($curl);
$err = curl_error($curl);

curl_close($curl);

if ($err) {
  echo "cURL Error #:" . $err;
} else {
  echo $response;
}

package main

import (
	"fmt"
	"strings"
	"net/http"
	"io"
)

func main() {

	url := "https://oleander.dev/api/v1/warehouse/polars"

	payload := strings.NewReader("{\n  \"query\": \"SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC\",\n  \"tables\": [\n    \"flowers=default.flowers\"\n  ],\n  \"script\": \"table = params.get('table', 'default.flowers')\\nlimit = int(params.get('limit', 50))\\n\\nflowers = scan(table)\\n\\nresult = (\\n    flowers.group_by('species')\\n    .agg(\\n        pl.len().alias('count'),\\n        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\\n        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\\n    )\\n    .sort('avg_sepal_length', descending=True)\\n    .head(limit)\\n)\",\n  \"params\": {\n    \"table\": \"default.flowers\",\n    \"limit\": \"25\"\n  },\n  \"distributed\": false,\n  \"instanceType\": \"t4g.medium\",\n  \"clusterSize\": 4,\n  \"vcpus\": 2,\n  \"catalog\": \"oleander\",\n  \"destination\": \"default.flower_summary\",\n  \"saveMode\": \"overwrite\"\n}")

	req, _ := http.NewRequest("POST", url, payload)

	req.Header.Add("Authorization", "Bearer <token>")
	req.Header.Add("Content-Type", "application/json")

	res, _ := http.DefaultClient.Do(req)

	defer res.Body.Close()
	body, _ := io.ReadAll(res.Body)

	fmt.Println(string(body))

}

HttpResponse<String> response = Unirest.post("https://oleander.dev/api/v1/warehouse/polars")
  .header("Authorization", "Bearer <token>")
  .header("Content-Type", "application/json")
  .body("{\n  \"query\": \"SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC\",\n  \"tables\": [\n    \"flowers=default.flowers\"\n  ],\n  \"script\": \"table = params.get('table', 'default.flowers')\\nlimit = int(params.get('limit', 50))\\n\\nflowers = scan(table)\\n\\nresult = (\\n    flowers.group_by('species')\\n    .agg(\\n        pl.len().alias('count'),\\n        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\\n        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\\n    )\\n    .sort('avg_sepal_length', descending=True)\\n    .head(limit)\\n)\",\n  \"params\": {\n    \"table\": \"default.flowers\",\n    \"limit\": \"25\"\n  },\n  \"distributed\": false,\n  \"instanceType\": \"t4g.medium\",\n  \"clusterSize\": 4,\n  \"vcpus\": 2,\n  \"catalog\": \"oleander\",\n  \"destination\": \"default.flower_summary\",\n  \"saveMode\": \"overwrite\"\n}")
  .asString();

require 'uri'
require 'net/http'

url = URI("https://oleander.dev/api/v1/warehouse/polars")

http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true

request = Net::HTTP::Post.new(url)
request["Authorization"] = 'Bearer <token>'
request["Content-Type"] = 'application/json'
request.body = "{\n  \"query\": \"SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC\",\n  \"tables\": [\n    \"flowers=default.flowers\"\n  ],\n  \"script\": \"table = params.get('table', 'default.flowers')\\nlimit = int(params.get('limit', 50))\\n\\nflowers = scan(table)\\n\\nresult = (\\n    flowers.group_by('species')\\n    .agg(\\n        pl.len().alias('count'),\\n        pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\\n        pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\\n    )\\n    .sort('avg_sepal_length', descending=True)\\n    .head(limit)\\n)\",\n  \"params\": {\n    \"table\": \"default.flowers\",\n    \"limit\": \"25\"\n  },\n  \"distributed\": false,\n  \"instanceType\": \"t4g.medium\",\n  \"clusterSize\": 4,\n  \"vcpus\": 2,\n  \"catalog\": \"oleander\",\n  \"destination\": \"default.flower_summary\",\n  \"saveMode\": \"overwrite\"\n}"

response = http.request(request)
puts response.read_body

{
  "success": true,
  "results": {
    "columns": [
      "<string>"
    ],
    "column_types": [
      "<string>"
    ],
    "rows": [
      [
        "<unknown>"
      ]
    ]
  },
  "row_count": 123,
  "execution_time": "<string>",
  "error": "<string>",
  "saved": {
    "table": "<string>",
    "rows_written": 123,
    "mode": "<string>"
  },
  "compute": {
    "mode": "<string>",
    "distributed": true,
    "instanceType": "<string>",
    "clusterSize": 123
  }
}

{
  "error": "<string>",
  "details": "<string>"
}

{
  "error": "Unauthorized"
}

{
  "status": 500
}

Authorizations

Authorization

string

header

required

Bearer authentication header of the form Bearer <token>, where <token> is your auth token.

Body

application/json

mode

enum<string>

required

Execution mode. query runs a Polars SQL expression against registered tables. script executes a Python script that has pl, scan(table), and params in scope and must assign result.

Available options:

query,

script

query

string

Polars SQL query string. Required when mode is query.

Example:

"SELECT species, avg(sepal_length) AS avg_sepal_length, avg(petal_length) AS avg_petal_length FROM flowers GROUP BY species ORDER BY avg_sepal_length DESC"

tables

(string | object)[]

Tables to register for query mode. Each entry is either alias=namespace.table or an object {alias, table}. Required when mode is query.

Example:

"flowers=default.flowers"

script

string

Python script source for script mode. The script runs with pl (polars), scan(table), params, and catalog in scope. It must assign result to a Polars LazyFrame or DataFrame. Do not call .collect() or .remote() inside the script; oleander handles execution.

Example:

"table = params.get('table', 'default.flowers')\nlimit = int(params.get('limit', 50))\n\nflowers = scan(table)\n\nresult = (\n flowers.group_by('species')\n .agg(\n pl.len().alias('count'),\n pl.col('sepal_length').mean().round(2).alias('avg_sepal_length'),\n pl.col('petal_length').mean().round(2).alias('avg_petal_length'),\n )\n .sort('avg_sepal_length', descending=True)\n .head(limit)\n)"

params

object

Key-value parameters available inside a script as the params dict.

Show child attributes

Example:

{ "table": "default.flowers", "limit": "25" }

distributed

boolean

default:false

Run the workload on Polars Cloud instead of a local sandbox.

instanceType

string

Polars Cloud instance type. Only used when distributed is true.

Example:

"t4g.medium"

clusterSize

integer

Number of Polars Cloud nodes. Only used when distributed is true.

Example:

4

vcpus

enum<integer>

default:2

Sandbox vCPU tier for local (non-distributed) execution. Valid values: 2, 4, 8, 16, 32.

Available options:

2,

4,

8,

16,

32

catalog

string

default:oleander

Catalog name to query against.

destination

string

Write results to a lake table. Format: namespace.table. If omitted, results are returned inline.

Example:

"default.flower_summary"

saveMode

enum<string>

default:overwrite

How to write to destination. overwrite replaces the table; append adds rows.

Available options:

overwrite,

append

Response

Workload executed successfully

success

boolean

Whether the workload executed successfully.

results

object

Inline results (omitted when destination is set and distributed is true).

Show child attributes

row_count

integer

Total number of rows in the result.

execution_time

string

Wall-clock time for the workload (e.g. "340ms").

error

string

Error message if success is false.

saved

object

Present when destination was set.

Show child attributes

compute

object

Compute environment details.

Show child attributes

Spark

Overview

Lineage

Queries

Polars

Authorizations

Body

Response