Package com.salesforce.datacloud.jdbc.core.listener

Class AsyncQueryStatusListener

java.lang.Object

com.salesforce.datacloud.jdbc.core.listener.AsyncQueryStatusListener

All Implemented Interfaces:

QueryStatusListener

public class AsyncQueryStatusListener
extends Object
implements QueryStatusListener

Field Summary

Fields inherited from interface com.salesforce.datacloud.jdbc.core.listener.QueryStatusListener

BEFORE_READY

Method Summary

Modifier and Type	Method	Description
DataCloudResultSet	generateResultSet()
String	getQuery()
String	getQueryId()
String	getStatus()
boolean	isReady()
static AsyncQueryStatusListener	of(String query, HyperGrpcClientExecutor client)
Stream<QueryResult>	stream()

Methods inherited from class java.lang.Object

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

Method Detail

of

public static AsyncQueryStatusListener of(String query,
                                          HyperGrpcClientExecutor client)
                                   throws SQLException

Throws:

SQLException

isReady

public boolean isReady()

Specified by:

isReady in interface QueryStatusListener

getStatus

public String getStatus()

Specified by:

getStatus in interface QueryStatusListener

generateResultSet

public DataCloudResultSet generateResultSet()

Specified by:

generateResultSet in interface QueryStatusListener

stream

public Stream<QueryResult> stream()
                           throws SQLException

Specified by:

stream in interface QueryStatusListener

Throws:

SQLException

getQueryId

public String getQueryId()

Specified by:

getQueryId in interface QueryStatusListener

getQuery

public String getQuery()

Specified by:

getQuery in interface QueryStatusListener