| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/planner/ |
| H A D | local_plan_cache.c | 27 static Query * GetLocalShardQueryForCache(Query *jobQuery, Task *task,
67 Query *jobQuery = copyObject(originalDistributedPlan->workerJob->jobQuery); in CacheLocalPlanForShardQuery() local
82 pfree(jobQuery); in CacheLocalPlanForShardQuery()
123 DeparseLocalShardQuery(jobQuery, task->relationShardList, in GetLocalShardQueryForCache()
147 DeparseLocalShardQuery(Query *jobQuery, List *relationShardList, Oid in DeparseLocalShardQuery() argument
168 if (jobQuery->commandType == CMD_INSERT) in DeparseLocalShardQuery()
175 Assert(!CheckInsertSelectQuery(jobQuery)); in DeparseLocalShardQuery()
177 AddInsertAliasIfNeeded(jobQuery); in DeparseLocalShardQuery()
186 deparse_shard_query(jobQuery, anchorDistributedTableId, anchorShardId, in DeparseLocalShardQuery()
191 UpdateRelationToShardNames((Node *) jobQuery, relationShardList); in DeparseLocalShardQuery()
[all …]
|
| H A D | multi_physical_planner.c | 701 jobQuery->hasSubLinks = checkExprHasSubLink((Node *) jobQuery); in BuildJobQuery()
703 Assert(jobQuery->hasWindowFuncs == contain_window_function((Node *) jobQuery)); in BuildJobQuery()
705 return jobQuery; in BuildJobQuery()
1474 Query *jobQuery = dependentJob->jobQuery; in ConstructCallingRTE() local
1644 jobQuery->hasSubLinks = checkExprHasSubLink((Node *) jobQuery); in BuildSubqueryJobQuery()
1646 Assert(jobQuery->hasWindowFuncs == contain_window_function((Node *) jobQuery)); in BuildSubqueryJobQuery()
1648 return jobQuery; in BuildSubqueryJobQuery()
1951 job->jobQuery = jobQuery; in BuildJob()
1981 mapMergeJob->job.jobQuery = jobQuery; in BuildMapMergeJob()
2855 Query *jobQuery = job->jobQuery; in SqlTaskList() local
[all …]
|
| H A D | combine_query_planner.c | 66 List *workerTargetList = workerJob->jobQuery->targetList; in PlanCombineQuery()
|
| H A D | function_call_delegation.c | 328 job->jobQuery = planContext->query; in TryToDelegateFunctionCall()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/executor/ |
| H A D | citus_custom_scan.c | 264 Query *jobQuery = workerJob->jobQuery; in CitusBeginReadOnlyScan() local
283 ExecuteCoordinatorEvaluableExpressions(jobQuery, planState); in CitusBeginReadOnlyScan()
336 Query *jobQuery = workerJob->jobQuery; in CitusBeginModifyScan() local
340 ExecuteCoordinatorEvaluableExpressions(jobQuery, planState); in CitusBeginModifyScan()
356 jobQuery->commandType == CMD_INSERT); in CitusBeginModifyScan()
362 if (jobQuery->commandType == CMD_INSERT) in CitusBeginModifyScan()
485 Query *jobQuery = workerJob->jobQuery; in RegenerateTaskListForInsert() local
490 List *taskList = RouterInsertTaskList(jobQuery, parametersInJobQueryResolved, in RegenerateTaskListForInsert()
506 workerJob->partitionKeyValue = ExtractInsertPartitionKeyValue(jobQuery); in RegenerateTaskListForInsert()
522 TargetShardIntervalForFastPathQuery(workerJob->jobQuery, in RegenerateTaskForFasthPathQuery()
[all …]
|
| H A D | local_executor.c | 322 Query *jobQuery = distributedPlan->workerJob->jobQuery; in ExecuteLocalTaskListInternal() local
323 LOCKMODE lockMode = GetQueryLockMode(jobQuery); in ExecuteLocalTaskListInternal()
|
| /dports/www/orangehrm/orangehrm-4.9/symfony/lib/vendor/google/apiclient-services/src/Google/Service/CloudTalentSolution/ |
| H A D | SearchJobsRequest.php | 78 public function setJobQuery(Google_Service_CloudTalentSolution_JobQuery $jobQuery) argument
80 $this->jobQuery = $jobQuery;
87 return $this->jobQuery;
|
| /dports/www/owncloud/owncloud/apps/files_external/3rdparty/google/apiclient-services/src/Google/Service/CloudTalentSolution/ |
| H A D | SearchJobsRequest.php | 94 public function setJobQuery(Google_Service_CloudTalentSolution_JobQuery $jobQuery) argument
96 $this->jobQuery = $jobQuery;
103 return $this->jobQuery;
|
| /dports/sysutils/bareos-client/bareos-Release-20.0.3/rest-api/ |
| H A D | bareos-restapi.py | 361 jobQuery: Optional[jobQuery] = None, argument
378 if jobQuery is not None:
379 queryDict = jobQuery.dict()
915 jobQuery: Optional[jobQuery] = Body(None, title="Query parameter"), argument
923 jobQuery=jobQuery,
|
| /dports/sysutils/bareos-traymonitor/bareos-Release-20.0.3/systemtests/tests/python-restapi/api/ |
| H A D | bareos-restapi.py | 361 jobQuery: Optional[jobQuery] = None, argument
378 if jobQuery is not None:
379 queryDict = jobQuery.dict()
915 jobQuery: Optional[jobQuery] = Body(None, title="Query parameter"), argument
923 jobQuery=jobQuery,
|
| /dports/sysutils/bareos-traymonitor/bareos-Release-20.0.3/rest-api/ |
| H A D | bareos-restapi.py | 361 jobQuery: Optional[jobQuery] = None, argument
378 if jobQuery is not None:
379 queryDict = jobQuery.dict()
915 jobQuery: Optional[jobQuery] = Body(None, title="Query parameter"), argument
923 jobQuery=jobQuery,
|
| /dports/sysutils/bareos-client/bareos-Release-20.0.3/systemtests/tests/python-restapi/api/ |
| H A D | bareos-restapi.py | 361 jobQuery: Optional[jobQuery] = None, argument
378 if jobQuery is not None:
379 queryDict = jobQuery.dict()
915 jobQuery: Optional[jobQuery] = Body(None, title="Query parameter"), argument
923 jobQuery=jobQuery,
|
| /dports/sysutils/bareos-server/bareos-Release-20.0.3/rest-api/ |
| H A D | bareos-restapi.py | 361 jobQuery: Optional[jobQuery] = None, argument
378 if jobQuery is not None:
379 queryDict = jobQuery.dict()
915 jobQuery: Optional[jobQuery] = Body(None, title="Query parameter"), argument
923 jobQuery=jobQuery,
|
| /dports/sysutils/bareos-server/bareos-Release-20.0.3/systemtests/tests/python-restapi/api/ |
| H A D | bareos-restapi.py | 361 jobQuery: Optional[jobQuery] = None, argument
378 if jobQuery is not None:
379 queryDict = jobQuery.dict()
915 jobQuery: Optional[jobQuery] = Body(None, title="Query parameter"), argument
923 jobQuery=jobQuery,
|
| /dports/www/bareos-webui/bareos-Release-20.0.3/rest-api/ |
| H A D | bareos-restapi.py | 361 jobQuery: Optional[jobQuery] = None, argument
378 if jobQuery is not None:
379 queryDict = jobQuery.dict()
915 jobQuery: Optional[jobQuery] = Body(None, title="Query parameter"), argument
923 jobQuery=jobQuery,
|
| /dports/www/bareos-webui/bareos-Release-20.0.3/systemtests/tests/python-restapi/api/ |
| H A D | bareos-restapi.py | 361 jobQuery: Optional[jobQuery] = None, argument
378 if jobQuery is not None:
379 queryDict = jobQuery.dict()
915 jobQuery: Optional[jobQuery] = Body(None, title="Query parameter"), argument
923 jobQuery=jobQuery,
|
| /dports/net-mgmt/nagios-check_bacula11/bacula-11.0.5/src/qt-console/restore/ |
| H A D | restoretree.cpp | 630 QString jobQuery = in populateJobTable() local
642 jobQuery += " AND Job.name = '" + jobCombo->currentText() + "'"; in populateJobTable()
645 jobQuery += " AND FileSet.FileSet='" + fileSetCombo->currentText() + "'"; in populateJobTable()
651 jobQuery += " AND Job.Starttime>'" + since + "'"; in populateJobTable()
654 jobQuery += " ORDER BY Job.EndTime DESC"; in populateJobTable()
659 jobQuery += " LIMIT " + limit; in populateJobTable()
661 if (mainWin->m_sqlDebug) Pmsg1(000, "Query cmd : %s\n", jobQuery.toUtf8().data()); in populateJobTable()
665 if (m_console->sql_cmd(jobQuery, results)) { in populateJobTable()
|
| /dports/net-mgmt/nagios-check_bacula9/bacula-9.6.7/src/qt-console/restore/ |
| H A D | restoretree.cpp | 654 QString jobQuery = in populateJobTable() local
666 jobQuery += " AND Job.name = '" + jobCombo->currentText() + "'"; in populateJobTable()
669 jobQuery += " AND FileSet.FileSet='" + fileSetCombo->currentText() + "'"; in populateJobTable()
675 jobQuery += " AND Job.Starttime>'" + since + "'"; in populateJobTable()
678 jobQuery += " ORDER BY Job.EndTime DESC"; in populateJobTable()
683 jobQuery += " LIMIT " + limit; in populateJobTable()
685 if (mainWin->m_sqlDebug) Pmsg1(000, "Query cmd : %s\n", jobQuery.toUtf8().data()); in populateJobTable()
689 if (m_console->sql_cmd(jobQuery, results)) { in populateJobTable()
|
| /dports/sysutils/bacula11-server/bacula-11.0.5/src/qt-console/restore/ |
| H A D | restoretree.cpp | 630 QString jobQuery = in populateJobTable() local
642 jobQuery += " AND Job.name = '" + jobCombo->currentText() + "'"; in populateJobTable()
645 jobQuery += " AND FileSet.FileSet='" + fileSetCombo->currentText() + "'"; in populateJobTable()
651 jobQuery += " AND Job.Starttime>'" + since + "'"; in populateJobTable()
654 jobQuery += " ORDER BY Job.EndTime DESC"; in populateJobTable()
659 jobQuery += " LIMIT " + limit; in populateJobTable()
661 if (mainWin->m_sqlDebug) Pmsg1(000, "Query cmd : %s\n", jobQuery.toUtf8().data()); in populateJobTable()
665 if (m_console->sql_cmd(jobQuery, results)) { in populateJobTable()
|
| /dports/sysutils/bacula11-client/bacula-11.0.5/src/qt-console/restore/ |
| H A D | restoretree.cpp | 630 QString jobQuery = in populateJobTable() local
642 jobQuery += " AND Job.name = '" + jobCombo->currentText() + "'"; in populateJobTable()
645 jobQuery += " AND FileSet.FileSet='" + fileSetCombo->currentText() + "'"; in populateJobTable()
651 jobQuery += " AND Job.Starttime>'" + since + "'"; in populateJobTable()
654 jobQuery += " ORDER BY Job.EndTime DESC"; in populateJobTable()
659 jobQuery += " LIMIT " + limit; in populateJobTable()
661 if (mainWin->m_sqlDebug) Pmsg1(000, "Query cmd : %s\n", jobQuery.toUtf8().data()); in populateJobTable()
665 if (m_console->sql_cmd(jobQuery, results)) { in populateJobTable()
|
| /dports/sysutils/bacula11-client-static/bacula-11.0.5/src/qt-console/restore/ |
| H A D | restoretree.cpp | 630 QString jobQuery = in populateJobTable() local
642 jobQuery += " AND Job.name = '" + jobCombo->currentText() + "'"; in populateJobTable()
645 jobQuery += " AND FileSet.FileSet='" + fileSetCombo->currentText() + "'"; in populateJobTable()
651 jobQuery += " AND Job.Starttime>'" + since + "'"; in populateJobTable()
654 jobQuery += " ORDER BY Job.EndTime DESC"; in populateJobTable()
659 jobQuery += " LIMIT " + limit; in populateJobTable()
661 if (mainWin->m_sqlDebug) Pmsg1(000, "Query cmd : %s\n", jobQuery.toUtf8().data()); in populateJobTable()
665 if (m_console->sql_cmd(jobQuery, results)) { in populateJobTable()
|
| /dports/sysutils/bacula9-client/bacula-9.6.7/src/qt-console/restore/ |
| H A D | restoretree.cpp | 654 QString jobQuery = in populateJobTable() local
666 jobQuery += " AND Job.name = '" + jobCombo->currentText() + "'"; in populateJobTable()
669 jobQuery += " AND FileSet.FileSet='" + fileSetCombo->currentText() + "'"; in populateJobTable()
675 jobQuery += " AND Job.Starttime>'" + since + "'"; in populateJobTable()
678 jobQuery += " ORDER BY Job.EndTime DESC"; in populateJobTable()
683 jobQuery += " LIMIT " + limit; in populateJobTable()
685 if (mainWin->m_sqlDebug) Pmsg1(000, "Query cmd : %s\n", jobQuery.toUtf8().data()); in populateJobTable()
689 if (m_console->sql_cmd(jobQuery, results)) { in populateJobTable()
|
| /dports/sysutils/bacula9-client-static/bacula-9.6.7/src/qt-console/restore/ |
| H A D | restoretree.cpp | 654 QString jobQuery = in populateJobTable() local
666 jobQuery += " AND Job.name = '" + jobCombo->currentText() + "'"; in populateJobTable()
669 jobQuery += " AND FileSet.FileSet='" + fileSetCombo->currentText() + "'"; in populateJobTable()
675 jobQuery += " AND Job.Starttime>'" + since + "'"; in populateJobTable()
678 jobQuery += " ORDER BY Job.EndTime DESC"; in populateJobTable()
683 jobQuery += " LIMIT " + limit; in populateJobTable()
685 if (mainWin->m_sqlDebug) Pmsg1(000, "Query cmd : %s\n", jobQuery.toUtf8().data()); in populateJobTable()
689 if (m_console->sql_cmd(jobQuery, results)) { in populateJobTable()
|
| /dports/sysutils/bacula9-server/bacula-9.6.7/src/qt-console/restore/ |
| H A D | restoretree.cpp | 654 QString jobQuery = in populateJobTable() local
666 jobQuery += " AND Job.name = '" + jobCombo->currentText() + "'"; in populateJobTable()
669 jobQuery += " AND FileSet.FileSet='" + fileSetCombo->currentText() + "'"; in populateJobTable()
675 jobQuery += " AND Job.Starttime>'" + since + "'"; in populateJobTable()
678 jobQuery += " ORDER BY Job.EndTime DESC"; in populateJobTable()
683 jobQuery += " LIMIT " + limit; in populateJobTable()
685 if (mainWin->m_sqlDebug) Pmsg1(000, "Query cmd : %s\n", jobQuery.toUtf8().data()); in populateJobTable()
689 if (m_console->sql_cmd(jobQuery, results)) { in populateJobTable()
|
| /dports/databases/pg_citus/citus-10.2.3/src/backend/distributed/utils/ |
| H A D | citus_copyfuncs.c | 95 COPY_NODE_FIELD(jobQuery); in copyJobInfo()
|