org.apache.druid.sql

Class DirectStatement.ResultSet

java.lang.Object

org.apache.druid.sql.DirectStatement.ResultSet

All Implemented Interfaces:

SqlLifecycleManager.Cancelable

Enclosing class:

DirectStatement

public class DirectStatement.ResultSet
extends Object
implements SqlLifecycleManager.Cancelable

Represents the execution plan for a query with the ability to run that plan (once).

Constructor Summary

Constructors

Constructor and Description
ResultSet(PlannerResult plannerResult)

Method Summary

Modifier and Type	Method and Description
void	cancel()
void	close()
SqlRowTransformer	createRowTransformer()
SqlQueryPlus	query()
SqlExecutionReporter	reporter()
Set<ResourceAction>	resources()
Sequence<Object[]>	run() Do the actual execute step which allows subclasses to wrap the sequence, as is sometimes needed for testing.
boolean	runnable() Convenience method for the split plan/run case to ensure that the statement can, in fact, be run.

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultSet

public ResultSet(PlannerResult plannerResult)

Method Detail

query

public SqlQueryPlus query()

runnable

public boolean runnable()

Convenience method for the split plan/run case to ensure that the statement can, in fact, be run.

run

public Sequence<Object[]> run()

Do the actual execute step which allows subclasses to wrap the sequence, as is sometimes needed for testing.

createRowTransformer

public SqlRowTransformer createRowTransformer()

reporter

public SqlExecutionReporter reporter()

resources

public Set<ResourceAction> resources()

Specified by:

resources in interface SqlLifecycleManager.Cancelable

cancel

public void cancel()

Specified by:

cancel in interface SqlLifecycleManager.Cancelable

close

public void close()