/dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-athena/include/aws/athena/model/ |
H A D | QueryExecution.h | 38 class AWS_ATHENA_API QueryExecution 41 QueryExecution(); 42 QueryExecution(Aws::Utils::Json::JsonView jsonValue); 43 QueryExecution& operator=(Aws::Utils::Json::JsonView jsonValue); 85 …inline QueryExecution& WithQueryExecutionId(const char* value) { SetQueryExecutionId(value); retur… in WithQueryExecutionId() 116 inline QueryExecution& WithQuery(const Aws::String& value) { SetQuery(value); return *this;} in WithQuery() 121 … inline QueryExecution& WithQuery(Aws::String&& value) { SetQuery(std::move(value)); return *this;} in WithQuery() 126 inline QueryExecution& WithQuery(const char* value) { SetQuery(value); return *this;} in WithQuery() 298 …inline QueryExecution& WithStatus(const QueryExecutionStatus& value) { SetStatus(value); return *t… in WithStatus() 372 …inline QueryExecution& WithWorkGroup(const Aws::String& value) { SetWorkGroup(value); return *this… in WithWorkGroup() [all …]
|
H A D | BatchGetQueryExecutionResult.h | 40 … inline const Aws::Vector<QueryExecution>& GetQueryExecutions() const{ return m_queryExecutions; } in GetQueryExecutions() 45 …inline void SetQueryExecutions(const Aws::Vector<QueryExecution>& value) { m_queryExecutions = val… in SetQueryExecutions() 50 …inline void SetQueryExecutions(Aws::Vector<QueryExecution>&& value) { m_queryExecutions = std::mov… in SetQueryExecutions() 55 …inline BatchGetQueryExecutionResult& WithQueryExecutions(const Aws::Vector<QueryExecution>& value)… in WithQueryExecutions() 60 …inline BatchGetQueryExecutionResult& WithQueryExecutions(Aws::Vector<QueryExecution>&& value) { Se… in WithQueryExecutions() 65 …inline BatchGetQueryExecutionResult& AddQueryExecutions(const QueryExecution& value) { m_queryExec… in AddQueryExecutions() 70 …inline BatchGetQueryExecutionResult& AddQueryExecutions(QueryExecution&& value) { m_queryExecution… in AddQueryExecutions() 110 Aws::Vector<QueryExecution> m_queryExecutions;
|
H A D | GetQueryExecutionResult.h | 38 inline const QueryExecution& GetQueryExecution() const{ return m_queryExecution; } in GetQueryExecution() 43 inline void SetQueryExecution(const QueryExecution& value) { m_queryExecution = value; } in SetQueryExecution() 48 inline void SetQueryExecution(QueryExecution&& value) { m_queryExecution = std::move(value); } in SetQueryExecution() 53 …inline GetQueryExecutionResult& WithQueryExecution(const QueryExecution& value) { SetQueryExecutio… in WithQueryExecution() 58 …inline GetQueryExecutionResult& WithQueryExecution(QueryExecution&& value) { SetQueryExecution(std… in WithQueryExecution() 62 QueryExecution m_queryExecution;
|
/dports/x11/albert/albert-0.16.1/src/app/ |
H A D | queryexecution.cpp | 27 Core::QueryExecution::QueryExecution(const set<QueryHandler*> & queryHandlers, in QueryExecution() function in Core::QueryExecution 67 Core::QueryExecution::~QueryExecution() { in ~QueryExecution() 73 const Core::Query *Core::QueryExecution::query() { in query() 79 const Core::QueryExecution::State &Core::QueryExecution::state() const { in state() 85 void Core::QueryExecution::setState(State state) { in setState() 94 void Core::QueryExecution::run() { in run() 113 void Core::QueryExecution::cancel() { in cancel() 122 void Core::QueryExecution::runBatchHandlers() { in runBatchHandlers() 142 void Core::QueryExecution::onBatchHandlersFinished() { in onBatchHandlersFinished() 181 void Core::QueryExecution::runRealtimeHandlers() { in runRealtimeHandlers() [all …]
|
H A D | querymanager.cpp | 109 for ( QueryExecution *queryExecution : pastQueries_ ){ in teardownSession() 160 for ( QueryExecution *query : pastQueries_ ) in teardownSession() 161 if ( query->state() == QueryExecution::State::Running ) in teardownSession() 162 connect(query, &QueryExecution::stateChanged, in teardownSession() 183 QueryExecution *last = pastQueries_.back(); in startQuery() 184 disconnect(last, &QueryExecution::resultsReady, this, &QueryManager::resultsReady); in startQuery() 185 if (last->state() != QueryExecution::State::Finished) in startQuery() 192 QueryExecution *currentQuery = new QueryExecution(extensionManager_->queryHandlers(), in startQuery() 197 connect(currentQuery, &QueryExecution::resultsReady, this, &QueryManager::resultsReady); in startQuery() 200 connect(currentQuery, &QueryExecution::stateChanged, [start](QueryExecution::State state){ in startQuery() [all …]
|
H A D | queryexecution.h | 37 class QueryExecution : public QAbstractListModel 45 QueryExecution(const std::set<QueryHandler*> &, 50 ~QueryExecution() override;
|
H A D | querymanager.h | 12 class QueryExecution; variable 35 std::list<QueryExecution*> pastQueries_;
|
/dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/util/ |
H A D | DataFrameCallbackSuite.scala | 25 import org.apache.spark.sql.execution.{QueryExecution, WholeStageCodegenExec} 33 val metrics = ArrayBuffer.empty[(String, QueryExecution, Long)] 36 override def onFailure(funcName: String, qe: QueryExecution, exception: Exception): Unit = {} 38 override def onSuccess(funcName: String, qe: QueryExecution, duration: Long): Unit = { 62 val metrics = ArrayBuffer.empty[(String, QueryExecution, Exception)] 64 override def onFailure(funcName: String, qe: QueryExecution, exception: Exception): Unit = { 69 override def onSuccess(funcName: String, qe: QueryExecution, duration: Long): Unit = {} 90 override def onFailure(funcName: String, qe: QueryExecution, exception: Exception): Unit = {} 92 override def onSuccess(funcName: String, qe: QueryExecution, duration: Long): Unit = { 124 override def onFailure(funcName: String, qe: QueryExecution, exception: Exception): Unit = {} [all …]
|
/dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-athena/source/model/ |
H A D | QueryExecution.cpp | 21 QueryExecution::QueryExecution() : in QueryExecution() function in Aws::Athena::Model::QueryExecution 35 QueryExecution::QueryExecution(JsonView jsonValue) : in QueryExecution() function in Aws::Athena::Model::QueryExecution 50 QueryExecution& QueryExecution::operator =(JsonView jsonValue) in operator =() 118 JsonValue QueryExecution::Jsonize() const in Jsonize()
|
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/util/ |
H A D | QueryExecutionListener.scala | 27 import org.apache.spark.sql.execution.QueryExecution 51 def onSuccess(funcName: String, qe: QueryExecution, durationNs: Long): Unit 64 def onFailure(funcName: String, qe: QueryExecution, exception: Exception): Unit 101 private[sql] def onSuccess(funcName: String, qe: QueryExecution, duration: Long): Unit = { 109 private[sql] def onFailure(funcName: String, qe: QueryExecution, exception: Exception): Unit = {
|
/dports/devel/spark/spark-2.1.1/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/ |
H A D | KafkaWriter.scala | 26 import org.apache.spark.sql.execution.{QueryExecution, SQLExecution} 47 queryExecution: QueryExecution, 84 queryExecution: QueryExecution,
|
/dports/databases/tile38/tile38-1.12.0/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 1776 QueryExecution *QueryExecution `type:"structure"` member 1791 s.QueryExecution = v 2090 type QueryExecution struct { struct 2116 func (s QueryExecution) String() string { argument 2121 func (s QueryExecution) GoString() string { argument 2126 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 2132 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 2138 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 2144 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 2150 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument [all …]
|
/dports/sysutils/aptly/aptly-1.4.0/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 1761 QueryExecution *QueryExecution `type:"structure"` member 1776 s.QueryExecution = v 2067 type QueryExecution struct { struct 2093 func (s QueryExecution) String() string { argument 2098 func (s QueryExecution) GoString() string { argument 2103 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 2109 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 2115 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 2121 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 2127 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument [all …]
|
/dports/devel/awless/awless-0.1.11/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 1776 QueryExecution *QueryExecution `type:"structure"` member 1791 s.QueryExecution = v 2090 type QueryExecution struct { struct 2116 func (s QueryExecution) String() string { argument 2121 func (s QueryExecution) GoString() string { argument 2126 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 2132 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 2138 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 2144 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 2150 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument [all …]
|
/dports/sysutils/docker-registry/distribution-2.7.1/vendor/github.com/aws/aws-sdk-go/aws-sdk-go-1.15.11/service/athena/ |
H A D | api.go | 1761 QueryExecution *QueryExecution `type:"structure"` member 1776 s.QueryExecution = v 2067 type QueryExecution struct { struct 2093 func (s QueryExecution) String() string { argument 2098 func (s QueryExecution) GoString() string { argument 2103 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 2109 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 2115 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 2121 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 2127 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument [all …]
|
/dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/execution/ |
H A D | QueryExecutionSuite.scala | 35 def qe: QueryExecution = new QueryExecution(spark, OneRowRelation)
|
/dports/devel/app-builder/app-builder-3.4.2/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 2698 QueryExecution *QueryExecution `type:"structure"` member 2713 s.QueryExecution = v 3311 type QueryExecution struct { struct 3359 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 3365 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 3371 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 3377 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 3383 func (s *QueryExecution) SetStatementType(v string) *QueryExecution { argument 3389 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument 3395 func (s *QueryExecution) SetStatus(v *QueryExecutionStatus) *QueryExecution { argument [all …]
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 2717 QueryExecution *QueryExecution `type:"structure"` member 2732 s.QueryExecution = v 3333 type QueryExecution struct { struct 3381 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 3387 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 3393 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 3399 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 3405 func (s *QueryExecution) SetStatementType(v string) *QueryExecution { argument 3411 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument 3417 func (s *QueryExecution) SetStatus(v *QueryExecutionStatus) *QueryExecution { argument [all …]
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 2709 QueryExecution *QueryExecution `type:"structure"` member 2724 s.QueryExecution = v 3325 type QueryExecution struct { struct 3374 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 3380 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 3386 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 3392 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 3398 func (s *QueryExecution) SetStatementType(v string) *QueryExecution { argument 3404 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument 3410 func (s *QueryExecution) SetStatus(v *QueryExecutionStatus) *QueryExecution { argument [all …]
|
/dports/databases/litestream/litestream-0.3.6/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 2717 QueryExecution *QueryExecution `type:"structure"` member 2732 s.QueryExecution = v 3333 type QueryExecution struct { struct 3381 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 3387 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 3393 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 3399 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 3405 func (s *QueryExecution) SetStatementType(v string) *QueryExecution { argument 3411 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument 3417 func (s *QueryExecution) SetStatus(v *QueryExecutionStatus) *QueryExecution { argument [all …]
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 2698 QueryExecution *QueryExecution `type:"structure"` member 2713 s.QueryExecution = v 3314 type QueryExecution struct { struct 3362 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 3368 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 3374 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 3380 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 3386 func (s *QueryExecution) SetStatementType(v string) *QueryExecution { argument 3392 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument 3398 func (s *QueryExecution) SetStatus(v *QueryExecutionStatus) *QueryExecution { argument [all …]
|
/dports/security/aws-iam-authenticator/aws-iam-authenticator-0.5.2/vendor/github.com/aws/aws-sdk-go/aws-sdk-go-1.30.0/service/athena/ |
H A D | api.go | 2719 QueryExecution *QueryExecution `type:"structure"` member 2734 s.QueryExecution = v 3457 type QueryExecution struct { struct 3506 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 3512 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 3518 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 3524 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 3530 func (s *QueryExecution) SetStatementType(v string) *QueryExecution { argument 3536 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument 3542 func (s *QueryExecution) SetStatus(v *QueryExecutionStatus) *QueryExecution { argument [all …]
|
/dports/dns/cli53/cli53-0.8.18/vendor/github.com/aws/aws-sdk-go/service/athena/ |
H A D | api.go | 2717 QueryExecution *QueryExecution `type:"structure"` member 2732 s.QueryExecution = v 3451 type QueryExecution struct { struct 3499 func (s *QueryExecution) SetQuery(v string) *QueryExecution { argument 3505 func (s *QueryExecution) SetQueryExecutionContext(v *QueryExecutionContext) *QueryExecution { argument 3511 func (s *QueryExecution) SetQueryExecutionId(v string) *QueryExecution { argument 3517 func (s *QueryExecution) SetResultConfiguration(v *ResultConfiguration) *QueryExecution { argument 3523 func (s *QueryExecution) SetStatementType(v string) *QueryExecution { argument 3529 func (s *QueryExecution) SetStatistics(v *QueryExecutionStatistics) *QueryExecution { argument 3535 func (s *QueryExecution) SetStatus(v *QueryExecutionStatus) *QueryExecution { argument [all …]
|
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ |
H A D | IncrementalExecution.scala | 25 import org.apache.spark.sql.execution.{QueryExecution, SparkPlan, SparkPlanner, UnaryExecNode} 39 extends QueryExecution(sparkSession, logicalPlan) with Logging {
|
/dports/devel/spark/spark-2.1.1/sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ |
H A D | SparkSQLDriver.scala | 31 import org.apache.spark.sql.execution.QueryExecution 44 private def getResultSetSchema(query: QueryExecution): Schema = {
|