Package org.apache.drill.exec.server.rest.stream

Class QueryRunner

java.lang.Object

org.apache.drill.exec.server.rest.BaseQueryRunner

org.apache.drill.exec.server.rest.stream.QueryRunner

public class QueryRunner
extends BaseQueryRunner

Query runner for streaming JSON results. This version is backward-compatible with pre-Drill 1.19 JSON queries.

Field Summary

Fields inherited from class org.apache.drill.exec.server.rest.BaseQueryRunner

maxRows, queryId, webUserConnection, workManager

Constructor Summary

Constructors

Constructor	Description
QueryRunner(WorkManager workManager, WebUserConnection webUserConnection)

Method Summary

Modifier and Type	Method	Description
void	sendResults(OutputStream output)
void	start(QueryWrapper query)

Methods inherited from class org.apache.drill.exec.server.rest.BaseQueryRunner

applyDefaultSchema, applyOptions, applyRowLimit, applyUserName, startQuery

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

QueryRunner

public QueryRunner(WorkManager workManager,
 WebUserConnection webUserConnection)

Method Details

start

public void start(QueryWrapper query)
           throws org.apache.calcite.tools.ValidationException

Throws:

org.apache.calcite.tools.ValidationException

sendResults

public void sendResults(OutputStream output)
                 throws Exception

Throws:

Exception