This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch pipeline
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c5f5164f98 init pipeline process
add deccb903b2 implement time join pipeline
No new revisions were added by this update.
Summary of changes:
.../iotdb/db/mpp/common/FragmentInstanceId.java | 2 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 5 +-
.../db/mpp/execution/driver/DataDriverContext.java | 16 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 27 ++--
.../db/mpp/execution/driver/DriverContext.java | 27 ++--
.../iotdb/db/mpp/execution/driver/IDriver.java | 5 +-
.../mpp/execution/driver/SchemaDriverContext.java | 11 +-
.../exchange/IMPPDataExchangeManager.java | 4 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 17 +--
.../mpp/execution/exchange/LocalSourceHandle.java | 24 +--
.../execution/exchange/MPPDataExchangeManager.java | 108 +++++++++++---
.../mpp/execution/exchange/SharedTsBlockQueue.java | 32 ++--
.../fragment/FragmentInstanceContext.java | 4 +-
.../fragment/FragmentInstanceManager.java | 2 +-
.../db/mpp/execution/operator/OperatorContext.java | 8 +-
.../operator/source/AlignedSeriesScanUtil.java | 3 +-
.../execution/schedule/AbstractDriverThread.java | 8 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 144 ++++++++++--------
...eption.java => DriverTaskAbortedException.java} | 7 +-
.../mpp/execution/schedule/DriverTaskThread.java | 8 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../mpp/execution/schedule/IDriverScheduler.java | 7 +-
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 3 +-
.../execution/schedule/queue/L1PriorityQueue.java | 10 +-
.../execution/schedule/queue/L2PriorityQueue.java | 16 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 44 +++---
.../task/{DriverTaskID.java => DriverTaskId.java} | 41 +++--
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../plan/planner/LocalExecutionPlanContext.java | 7 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 3 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 31 ++--
.../db/mpp/plan/planner/PipelineDriverFactory.java | 18 +--
.../iotdb/db/mpp/execution/DataDriverTest.java | 2 +-
.../execution/exchange/LocalSinkHandleTest.java | 10 +-
.../execution/exchange/LocalSourceHandleTest.java | 16 +-
.../exchange/MPPDataExchangeManagerTest.java | 8 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 4 +-
.../schedule/DefaultDriverSchedulerTest.java | 166 +++++++++++++--------
.../execution/schedule/DriverSchedulerTest.java | 45 +++---
.../DriverTaskTimeoutSentinelThreadTest.java | 23 ++-
.../schedule/queue/L1PriorityQueueTest.java | 6 +-
.../schedule/queue/L2PriorityQueueTest.java | 12 +-
.../mpp/execution/schedule/queue/QueueElement.java | 4 +-
44 files changed, 540 insertions(+), 404 deletions(-)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/{FragmentInstanceAbortedException.java
=> DriverTaskAbortedException.java} (82%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/{DriverTaskID.java
=> DriverTaskId.java} (62%)
