Package com.amazonaws.athena.connector.lambda

Class QueryStatusChecker

java.lang.Object

com.amazonaws.athena.connector.lambda.QueryStatusChecker

All Implemented Interfaces:

AutoCloseable

public class QueryStatusChecker
extends Object
implements AutoCloseable

This class provides a mechanism for callers to terminate in-progress work if the upstream Athena query waiting for that work has already terminated. Callers using the SDK as-is should only need to call #isQueryRunning, as #startQueryStatusChecker should have already been called by MetadataHandler or RecordHandler.

Constructor Summary

Constructors

Constructor	Description
QueryStatusChecker(software.amazon.awssdk.services.athena.AthenaClient athena, ThrottlingInvoker athenaInvoker, String queryId)

Method Summary

Modifier and Type	Method	Description
void	close()	Stops the status checker thread
boolean	isQueryRunning()	Returns whether the query is still running

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryStatusChecker

public QueryStatusChecker(software.amazon.awssdk.services.athena.AthenaClient athena,
                          ThrottlingInvoker athenaInvoker,
                          String queryId)

Method Detail

isQueryRunning

public boolean isQueryRunning()

Returns whether the query is still running

close

public void close()

Stops the status checker thread

Specified by:

close in interface AutoCloseable