语句资源

语句资源

POST /v1/statement

query query

需要执行的SQL查询

reqheader X-Presto-User

代表(optional)执行语句的用户

reqheader X-Presto-Source

查询的来源

reqheader X-Presto-Catalog

执行查询基于的目录

reqheader X-Presto-Schema

执行查询的模式

提交语句给openLooKeng执行。openLooKeng客户端代表用户根据指定的目录和架构进行查询。当使用openLooKeng命令行进行查询时，则调用openLooKeng协调节点的语句资源。

对语句资源的请求就是和标准X-Presto-Catalog、X-Presto-Source、X-Presto-Schema和X-Presto-User头域一起作为post执行的SQL查询。

语句资源的响应包含一个查询标识符，该标识符可用于收集有关查询的详细信息。初始响应还包括有关为执行此查询而在openLooKeng worker上创建的阶段的信息。每个查询都有一个根阶段，并且根阶段被赋予一个”0”的阶段标识符，如下面的响应示例所示。

这个根阶段聚合了在openLooKeng worker上运行的其他阶段的响应，并通过openLooKeng协调节点将它们传递给客户端。当一个客户端收到这个POST的响应时，它将包含一个”nextUri”属性，这个属性指示客户端查询这个地址以获得查询的更多结果。

请求样例：

POST /v1/statement HTTP/1.1
Host: localhost:8001 X-Presto-Catalog: jmx X-Presto-Source: presto-cli
X-Presto-Schema: jmx User-Agent: StatementClient/0.55-SNAPSHOT
X-Presto-User: tobrie1 Content-Length: 41
select name from "java.lang:type=runtime"

响应样例：

HTTP/1.1 200 OK
Content-Type: application/json X-Content-Type-Options: nosniff
Transfer-Encoding: chunked
{
    "id":"20140108_110629_00011_dk5x2",
    "infoUri":"<http://localhost:8001/v1/query/20140108_110629_00011_dk5x2>",
    "partialCancelUri":"<http://192.168.1.1:8080/v1/stage/20140108_110629_00011_dk5x2.1>",
    "nextUri":"<http://localhost:8001/v1/statement/20140108_110629_00011_dk5x2/1>",
    "columns": [ { "name":"name", "type":"varchar" } ],
    "stats": { "state":"RUNNING", "scheduled":false,
    "nodes":1, "totalSplits":0, "queuedSplits":0,
    "runningSplits":0, "completedSplits":0, "cpuTimeMillis":0,
    "wallTimeMillis":0, "processedRows":0, "processedBytes":0,
    "rootStage": { "stageId":"0", "state":"SCHEDULED",
    "done":false, "nodes":1, "totalSplits":0,
    "queuedSplits":0, "runningSplits":0, "completedSplits":0,
    "cpuTimeMillis":0, "wallTimeMillis":0, "processedRows":0,
    "processedBytes":0, "subStages": [ { "stageId":"1",
    "state":"SCHEDULED", "done":false, "nodes":1,
    "totalSplits":0, "queuedSplits":0, "runningSplits":0,
    "completedSplits":0, "cpuTimeMillis":0, "wallTimeMillis":0,
    "processedRows":0, "processedBytes":0, "subStages":[] } ]
    } }
}

GET /v1/statement/{queryId}/{token}

query queryId

初始POST返回给/v1/statement的查询标识

query token

初始POST返回给/v1/statement的令牌或先前调用返回给此调用的令牌。当openLooKeng客户端提交语句执行时，openLooKeng创建一个查询，然后它向客户端返回一个nextUri。此调用与nextUri调用相对应，可以包含正在进行中的查询的状态更新，也可以将最终结果传递给客户端。