语句资源

• 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调用相对应，可以包含正在进行中的查询的状态更新，也可以将最终结果传递给客户端。

请求样例：

GET /v1/statement/20140108_110629_00011_dk5x2/1 HTTP/1.1
Host: localhost:8001
User-Agent: StatementClient/0.55-SNAPSHOT

响应样例：

HTTP/1.1 200 OK

Content-Type: application/json X-Content-Type-Options: nosniff Vary:
Accept-Encoding, User-Agent Transfer-Encoding: chunked

383 { "id":"20140108_110629_00011_dk5x2",
"infoUri":"<http://localhost:8001/v1/query/20140108_110629_00011_dk5x2>",
"columns": [ { "name":"name", "type":"varchar" } ],
"data": [ ["<4165@domU-12-31-39-0F-CC-72>"] ], "stats": {
"state":"FINISHED", "scheduled":true, "nodes":1,
"totalSplits":2, "queuedSplits":0, "runningSplits":0,
"completedSplits":2, "cpuTimeMillis":1, "wallTimeMillis":4,
"processedRows":1, "processedBytes":27, "rootStage": {
"stageId":"0", "state":"FINISHED", "done":true, "nodes":1,
"totalSplits":1, "queuedSplits":0, "runningSplits":0,
"completedSplits":1, "cpuTimeMillis":0, "wallTimeMillis":0,
"processedRows":1, "processedBytes":32, "subStages": [ {
"stageId":"1", "state":"FINISHED", "done":true, "nodes":1,
"totalSplits":1, "queuedSplits":0, "runningSplits":0,
"completedSplits":1, "cpuTimeMillis":0, "wallTimeMillis":4,
"processedRows":1, "processedBytes":27, "subStages":[] } ] }
} }

• DELETE /v1/statement/{queryId}/{token}

query queryId

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

reqheader X-Presto-User

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

reqheader X-Presto-Source

查询来源

reqheader X-Presto-Catalog

执行查询基于的目录

reqheader X-Presto-Schema

执行查询的模式