Home
last modified time | relevance | path

Searched refs:QueryExecution (Results 1 – 25 of 93) sorted by relevance

1234

/dports/devel/aws-sdk-cpp/aws-sdk-cpp-1.9.129/aws-cpp-sdk-athena/include/aws/athena/model/
H A DQueryExecution.h38 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 DBatchGetQueryExecutionResult.h40 … 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 DGetQueryExecutionResult.h38 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 Dqueryexecution.cpp27 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 Dquerymanager.cpp109 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 Dqueryexecution.h37 class QueryExecution : public QAbstractListModel
45 QueryExecution(const std::set<QueryHandler*> &,
50 ~QueryExecution() override;
H A Dquerymanager.h12 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 DDataFrameCallbackSuite.scala25 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 DQueryExecution.cpp21 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 DQueryExecutionListener.scala27 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 DKafkaWriter.scala26 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 Dapi.go1776 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 Dapi.go1761 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 Dapi.go1776 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 Dapi.go1761 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 DQueryExecutionSuite.scala35 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 Dapi.go2698 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 Dapi.go2717 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 Dapi.go2709 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 Dapi.go2717 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 Dapi.go2698 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 Dapi.go2719 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 Dapi.go2717 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 DIncrementalExecution.scala25 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 DSparkSQLDriver.scala31 import org.apache.spark.sql.execution.QueryExecution
44 private def getResultSetSchema(query: QueryExecution): Schema = {

1234