This is an automated email from the ASF dual-hosted git repository.
gian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from f0fc45028e Update year in the notice file and the release process
instructions (#12622)
add d7d15ba51f Add druid-multi-stage-query extension. (#12918)
No new revisions were added by this update.
Summary of changes:
codestyle/spotbugs-exclude.xml | 7 +
.../org/apache/druid/common/utils/IdUtils.java | 4 +-
distribution/pom.xml | 6 +
.../cluster/_common/common.runtime.properties | 2 +-
.../master/coordinator-overlord/runtime.properties | 1 +
.../large/_common/common.runtime.properties | 2 +-
.../large/coordinator-overlord/runtime.properties | 1 +
.../medium/_common/common.runtime.properties | 2 +-
.../medium/coordinator-overlord/runtime.properties | 1 +
.../_common/common.runtime.properties | 2 +-
.../coordinator-overlord/runtime.properties | 1 +
.../_common/common.runtime.properties | 2 +-
.../coordinator-overlord/runtime.properties | 1 +
.../small/_common/common.runtime.properties | 2 +-
.../small/coordinator-overlord/runtime.properties | 1 +
.../xlarge/_common/common.runtime.properties | 2 +-
.../xlarge/coordinator-overlord/runtime.properties | 1 +
extensions-core/multi-stage-query/README.md | 141 ++
extensions-core/multi-stage-query/pom.xml | 299 +++
.../apache/druid/msq/counters/ChannelCounters.java | 274 +++
.../apache/druid/msq/counters/CounterNames.java | 142 ++
.../druid/msq/counters/CounterSnapshots.java | 75 +
.../msq/counters/CounterSnapshotsSerializer.java | 55 +
.../druid/msq/counters/CounterSnapshotsTree.java | 104 +
.../apache/druid/msq/counters/CounterTracker.java | 74 +
.../apache/druid/msq/counters/QueryCounter.java | 32 +
.../druid/msq/counters/QueryCounterSnapshot.java | 31 +
.../SuperSorterProgressTrackerCounter.java | 71 +
.../apache/druid/msq/counters/WarningCounters.java | 94 +
.../java/org/apache/druid/msq/exec/Controller.java | 125 ++
.../apache/druid/msq/exec/ControllerClient.java | 81 +
.../apache/druid/msq/exec/ControllerContext.java | 82 +
.../org/apache/druid/msq/exec/ControllerImpl.java | 2171 ++++++++++++++++++++
.../msq/exec/ExceptionWrappingWorkerClient.java | 145 ++
.../java/org/apache/druid/msq/exec/Limits.java | 61 +
.../java/org/apache/druid/msq/exec/MSQTasks.java | 216 ++
.../org/apache/druid/msq/exec/QueryValidator.java | 77 +
.../druid/msq/exec/TaskDataSegmentProvider.java | 115 ++
.../java/org/apache/druid/msq/exec/Worker.java | 108 +
.../org/apache/druid/msq/exec/WorkerClient.java | 84 +
.../org/apache/druid/msq/exec/WorkerContext.java | 76 +
.../java/org/apache/druid/msq/exec/WorkerImpl.java | 1249 +++++++++++
.../apache/druid/msq/exec/WorkerManagerClient.java | 57 +
.../druid/msq/exec/WorkerMemoryParameters.java | 294 +++
.../druid/msq/guice/MSQDurableStorageModule.java | 86 +
.../msq/guice/MSQExternalDataSourceModule.java | 52 +
.../apache/druid/msq/guice/MSQIndexingModule.java | 201 ++
.../druid/msq/guice/MSQServiceClientModule.java | 86 +
.../org/apache/druid/msq/guice/MSQSqlModule.java | 60 +
.../apache/druid/msq/guice/MultiStageQuery.java | 34 +
.../org/apache/druid/msq/guice/SqlTaskModule.java | 53 +
.../apache/druid/msq/indexing/ColumnMapping.java | 82 +
.../apache/druid/msq/indexing/ColumnMappings.java | 144 ++
.../druid/msq/indexing/ControllerChatHandler.java | 194 ++
.../msq/indexing/CountableInputSourceReader.java | 58 +
.../msq/indexing/CountingOutputChannelFactory.java | 64 +
.../msq/indexing/CountingReadableFrameChannel.java | 75 +
.../msq/indexing/CountingWritableFrameChannel.java | 71 +
.../msq/indexing/DataSourceMSQDestination.java | 163 ++
.../msq/indexing/IndexerControllerClient.java | 182 ++
.../msq/indexing/IndexerControllerContext.java | 123 ++
.../druid/msq/indexing/IndexerFrameContext.java | 120 ++
.../druid/msq/indexing/IndexerWorkerClient.java | 271 +++
.../druid/msq/indexing/IndexerWorkerContext.java | 296 +++
.../msq/indexing/IndexerWorkerManagerClient.java | 81 +
.../druid/msq/indexing/InputChannelFactory.java | 38 +
.../druid/msq/indexing/InputChannelsImpl.java | 211 ++
.../indexing/KeyStatisticsCollectionProcessor.java | 183 ++
.../druid/msq/indexing/MSQControllerTask.java | 222 ++
.../apache/druid/msq/indexing/MSQDestination.java | 33 +
.../druid/msq/indexing/MSQPartitionAssignment.java | 96 +
.../org/apache/druid/msq/indexing/MSQSpec.java | 160 ++
.../org/apache/druid/msq/indexing/MSQTaskList.java | 71 +
.../apache/druid/msq/indexing/MSQTuningConfig.java | 140 ++
.../apache/druid/msq/indexing/MSQWorkerTask.java | 115 ++
.../druid/msq/indexing/MSQWorkerTaskLauncher.java | 487 +++++
.../indexing/SegmentGeneratorFrameProcessor.java | 295 +++
.../SegmentGeneratorFrameProcessorFactory.java | 373 ++++
.../msq/indexing/TaskReportMSQDestination.java | 45 +
.../druid/msq/indexing/WorkerChatHandler.java | 222 ++
.../druid/msq/indexing/error/BaseMSQFault.java | 121 ++
.../error/BroadcastTablesTooLargeFault.java | 72 +
.../druid/msq/indexing/error/CanceledFault.java | 41 +
.../error/CannotParseExternalDataFault.java | 35 +
.../indexing/error/ColumnNameRestrictedFault.java | 75 +
.../error/ColumnTypeNotSupportedFault.java | 89 +
.../error/DurableStorageConfigurationFault.java | 80 +
.../msq/indexing/error/FaultsExceededChecker.java | 92 +
.../error/InsertCannotAllocateSegmentFault.java | 82 +
.../indexing/error/InsertCannotBeEmptyFault.java | 72 +
.../error/InsertCannotOrderByDescendingFault.java | 72 +
.../InsertCannotReplaceExistingSegmentFault.java | 76 +
.../indexing/error/InsertLockPreemptedFault.java | 45 +
.../msq/indexing/error/InsertTimeNullFault.java | 42 +
.../indexing/error/InsertTimeOutOfBoundsFault.java | 66 +
.../msq/indexing/error/InvalidNullByteFault.java | 71 +
.../druid/msq/indexing/error/MSQErrorReport.java | 200 ++
.../druid/msq/indexing/error/MSQException.java | 51 +
.../apache/druid/msq/indexing/error/MSQFault.java | 49 +
.../error/MSQWarningReportLimiterPublisher.java | 96 +
.../indexing/error/MSQWarningReportPublisher.java | 35 +
.../error/MSQWarningReportSimplePublisher.java | 72 +
.../druid/msq/indexing/error/MSQWarnings.java | 36 +
.../msq/indexing/error/NotEnoughMemoryFault.java | 108 +
.../msq/indexing/error/QueryNotSupportedFault.java | 41 +
.../druid/msq/indexing/error/RowTooLargeFault.java | 69 +
.../msq/indexing/error/TaskStartTimeoutFault.java | 76 +
.../msq/indexing/error/TooManyBucketsFault.java | 77 +
.../msq/indexing/error/TooManyColumnsFault.java | 80 +
.../msq/indexing/error/TooManyInputFilesFault.java | 102 +
.../msq/indexing/error/TooManyPartitionsFault.java | 74 +
.../msq/indexing/error/TooManyWarningsFault.java | 80 +
.../msq/indexing/error/TooManyWorkersFault.java | 89 +
.../druid/msq/indexing/error/UnknownFault.java | 84 +
.../msq/indexing/error/WorkerFailedFault.java | 86 +
.../msq/indexing/error/WorkerRpcFailedFault.java | 69 +
.../msq/indexing/report/MSQResultsReport.java | 84 +
.../druid/msq/indexing/report/MSQStagesReport.java | 248 +++
.../druid/msq/indexing/report/MSQStatusReport.java | 135 ++
.../druid/msq/indexing/report/MSQTaskReport.java | 64 +
.../msq/indexing/report/MSQTaskReportPayload.java | 85 +
.../org/apache/druid/msq/input/InputSlice.java | 40 +
.../apache/druid/msq/input/InputSliceReader.java | 50 +
.../org/apache/druid/msq/input/InputSlices.java | 65 +
.../java/org/apache/druid/msq/input/InputSpec.java | 30 +
.../apache/druid/msq/input/InputSpecSlicer.java | 50 +
.../druid/msq/input/InputSpecSlicerFactory.java | 36 +
.../org/apache/druid/msq/input/InputSpecs.java | 50 +
.../druid/msq/input/MapInputSliceReader.java | 70 +
.../apache/druid/msq/input/MapInputSpecSlicer.java | 73 +
.../org/apache/druid/msq/input/NilInputSlice.java | 60 +
.../druid/msq/input/NilInputSliceReader.java | 55 +
.../org/apache/druid/msq/input/NilInputSource.java | 90 +
.../org/apache/druid/msq/input/ReadableInput.java | 112 +
.../org/apache/druid/msq/input/ReadableInputs.java | 92 +
.../org/apache/druid/msq/input/SlicerUtils.java | 129 ++
.../msq/input/external/ExternalInputSlice.java | 111 +
.../input/external/ExternalInputSliceReader.java | 243 +++
.../msq/input/external/ExternalInputSpec.java | 106 +
.../input/external/ExternalInputSpecSlicer.java | 166 ++
.../input/stage/CollectedReadablePartitions.java | 126 ++
.../input/stage/CombinedReadablePartitions.java | 111 +
.../druid/msq/input/stage/InputChannels.java | 42 +
.../druid/msq/input/stage/ReadablePartition.java | 118 ++
.../druid/msq/input/stage/ReadablePartitions.java | 100 +
.../druid/msq/input/stage/StageInputSlice.java | 96 +
.../msq/input/stage/StageInputSliceReader.java | 96 +
.../druid/msq/input/stage/StageInputSpec.java | 75 +
.../msq/input/stage/StageInputSpecSlicer.java | 82 +
.../msq/input/stage/StripedReadablePartitions.java | 132 ++
.../msq/input/table/RichSegmentDescriptor.java | 119 ++
.../msq/input/table/SegmentWithDescriptor.java | 78 +
.../druid/msq/input/table/SegmentsInputSlice.java | 103 +
.../msq/input/table/SegmentsInputSliceReader.java | 100 +
.../druid/msq/input/table/TableInputSpec.java | 130 ++
.../msq/input/table/TableInputSpecSlicer.java | 196 ++
.../apache/druid/msq/kernel/ExtraInfoHolder.java | 80 +
.../org/apache/druid/msq/kernel/FrameContext.java | 60 +
.../druid/msq/kernel/FrameProcessorFactory.java | 105 +
.../druid/msq/kernel/MaxCountShuffleSpec.java | 137 ++
.../druid/msq/kernel/NilExtraInfoHolder.java | 40 +
.../druid/msq/kernel/ProcessorsAndChannels.java | 54 +
.../apache/druid/msq/kernel/QueryDefinition.java | 169 ++
.../druid/msq/kernel/QueryDefinitionBuilder.java | 87 +
.../org/apache/druid/msq/kernel/ShuffleSpec.java | 72 +
.../apache/druid/msq/kernel/StageDefinition.java | 353 ++++
.../druid/msq/kernel/StageDefinitionBuilder.java | 126 ++
.../java/org/apache/druid/msq/kernel/StageId.java | 115 ++
.../apache/druid/msq/kernel/StagePartition.java | 86 +
.../druid/msq/kernel/TargetSizeShuffleSpec.java | 132 ++
.../org/apache/druid/msq/kernel/WorkOrder.java | 143 ++
.../druid/msq/kernel/WorkerAssignmentStrategy.java | 119 ++
.../kernel/controller/ControllerQueryKernel.java | 546 +++++
.../kernel/controller/ControllerStagePhase.java | 118 ++
.../kernel/controller/ControllerStageTracker.java | 412 ++++
.../druid/msq/kernel/controller/WorkerInputs.java | 179 ++
.../druid/msq/kernel/worker/WorkerStageKernel.java | 217 ++
.../druid/msq/kernel/worker/WorkerStagePhase.java | 87 +
.../msq/querykit/BaseFrameProcessorFactory.java | 72 +
.../druid/msq/querykit/BaseLeafFrameProcessor.java | 216 ++
.../querykit/BaseLeafFrameProcessorFactory.java | 307 +++
.../druid/msq/querykit/BroadcastJoinHelper.java | 205 ++
.../druid/msq/querykit/DataSegmentProvider.java | 37 +
.../msq/querykit/DataSegmentTimelineView.java | 49 +
.../apache/druid/msq/querykit/DataSourcePlan.java | 384 ++++
.../druid/msq/querykit/InputNumberDataSource.java | 116 ++
.../druid/msq/querykit/LazyResourceHolder.java | 73 +
.../apache/druid/msq/querykit/MultiQueryKit.java | 68 +
.../org/apache/druid/msq/querykit/QueryKit.java | 52 +
.../apache/druid/msq/querykit/QueryKitUtils.java | 222 ++
.../druid/msq/querykit/ShuffleSpecFactories.java | 51 +
.../druid/msq/querykit/ShuffleSpecFactory.java | 35 +
.../querykit/common/OffsetLimitFrameProcessor.java | 168 ++
.../common/OffsetLimitFrameProcessorFactory.java | 162 ++
.../groupby/GroupByPostShuffleFrameProcessor.java | 324 +++
.../GroupByPostShuffleFrameProcessorFactory.java | 131 ++
.../groupby/GroupByPreShuffleFrameProcessor.java | 245 +++
.../GroupByPreShuffleFrameProcessorFactory.java | 80 +
.../msq/querykit/groupby/GroupByQueryKit.java | 302 +++
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 316 +++
.../scan/ScanQueryFrameProcessorFactory.java | 96 +
.../druid/msq/querykit/scan/ScanQueryKit.java | 173 ++
.../druid/msq/rpc/CoordinatorServiceClient.java | 40 +
.../msq/rpc/CoordinatorServiceClientImpl.java | 90 +
.../shuffle/DurableStorageInputChannelFactory.java | 122 ++
.../DurableStorageOutputChannelFactory.java | 142 ++
.../msq/shuffle/WorkerInputChannelFactory.java | 101 +
.../java/org/apache/druid/msq/sql/MSQMode.java | 81 +
.../apache/druid/msq/sql/MSQTaskQueryMaker.java | 298 +++
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 299 +++
.../org/apache/druid/msq/sql/SqlTaskResource.java | 336 +++
.../org/apache/druid/msq/sql/SqlTaskStatus.java | 104 +
.../statistics/ClusterByStatisticsCollector.java | 97 +
.../ClusterByStatisticsCollectorImpl.java | 440 ++++
.../statistics/ClusterByStatisticsSnapshot.java | 133 ++
.../msq/statistics/DelegateOrMinKeyCollector.java | 170 ++
.../DelegateOrMinKeyCollectorFactory.java | 122 ++
.../DelegateOrMinKeyCollectorSnapshot.java | 87 +
.../druid/msq/statistics/DistinctKeyCollector.java | 305 +++
.../statistics/DistinctKeyCollectorFactory.java | 87 +
.../druid/msq/statistics/DistinctKeySnapshot.java | 94 +
.../apache/druid/msq/statistics/KeyCollector.java | 77 +
.../druid/msq/statistics/KeyCollectorFactory.java | 46 +
.../druid/msq/statistics/KeyCollectorSnapshot.java | 27 +
.../KeyCollectorSnapshotDeserializerModule.java | 34 +
.../apache/druid/msq/statistics/KeyCollectors.java | 51 +
.../statistics/QuantilesSketchKeyCollector.java | 168 ++
.../QuantilesSketchKeyCollectorFactory.java | 149 ++
.../QuantilesSketchKeyCollectorSnapshot.java | 61 +
.../msq/statistics/TooManyBucketsException.java | 38 +
.../druid/msq/util/DecoratedExecutorService.java | 162 ++
.../druid/msq/util/DimensionSchemaUtils.java | 70 +
.../org/apache/druid/msq/util/IntervalUtils.java | 64 +
.../org/apache/druid/msq/util/MSQFutureUtils.java | 70 +
.../druid/msq/util/MultiStageQueryContext.java | 237 +++
.../druid/msq/util/PassthroughAggregator.java | 78 +
.../msq/util/PassthroughAggregatorFactory.java | 208 ++
.../org/apache/druid/msq/util/SequenceUtils.java | 44 +
.../apache/druid/msq/util/SupplierIterator.java | 57 +
.../org.apache.druid.initialization.DruidModule | 21 +
.../src/main/resources/log4j2.xml | 38 +
.../apache/druid/msq/TestArrayStorageAdapter.java | 56 +
.../msq/counters/CountersSnapshotTreeTest.java | 49 +
.../org/apache/druid/msq/exec/MSQInsertTest.java | 661 ++++++
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 506 +++++
.../org/apache/druid/msq/exec/MSQSelectTest.java | 1052 ++++++++++
.../org/apache/druid/msq/exec/MSQTasksTest.java | 247 +++
.../apache/druid/msq/exec/QueryValidatorTest.java | 144 ++
.../druid/msq/exec/WorkerMemoryParametersTest.java | 116 ++
.../druid/msq/indexing/ColumnMappingTest.java | 36 +
.../msq/indexing/DataSourceMSQDestinationTest.java | 37 +
.../msq/indexing/IndexerWorkerContextTest.java | 87 +
.../msq/indexing/MSQPartitionAssignmentTest.java | 57 +
.../org/apache/druid/msq/indexing/MSQSpecTest.java | 36 +
.../druid/msq/indexing/MSQTuningConfigTest.java | 64 +
.../error/InsertLockPreemptedFaultTest.java | 74 +
.../msq/indexing/error/MSQFaultSerdeTest.java | 97 +
.../druid/msq/indexing/error/MSQWarningsTest.java | 404 ++++
.../msq/indexing/report/MSQTaskReportTest.java | 214 ++
.../org/apache/druid/msq/input/InputSpecsTest.java | 43 +
.../apache/druid/msq/input/NilInputSliceTest.java | 50 +
.../msq/input/external/ExternalInputSliceTest.java | 65 +
.../external/ExternalInputSpecSlicerTest.java | 320 +++
.../msq/input/external/ExternalInputSpecTest.java | 63 +
.../stage/CollectedReadablePartitionsTest.java | 83 +
.../stage/CombinedReadablePartitionsTest.java | 95 +
.../msq/input/stage/ReadablePartitionTest.java | 32 +
.../druid/msq/input/stage/StageInputSliceTest.java | 54 +
.../msq/input/stage/StageInputSpecSlicerTest.java | 120 ++
.../druid/msq/input/stage/StageInputSpecTest.java | 51 +
.../input/stage/StripedReadablePartitionsTest.java | 91 +
.../msq/input/table/RichSegmentDescriptorTest.java | 88 +
.../msq/input/table/SegmentWithDescriptorTest.java | 32 +
.../msq/input/table/SegmentsInputSliceTest.java | 63 +
.../msq/input/table/TableInputSpecSlicerTest.java | 493 +++++
.../druid/msq/input/table/TableInputSpecTest.java | 78 +
.../druid/msq/kernel/QueryDefinitionTest.java | 76 +
.../druid/msq/kernel/StageDefinitionTest.java | 35 +
.../org/apache/druid/msq/kernel/StageIdTest.java | 76 +
.../org/apache/druid/msq/kernel/WorkOrderTest.java | 35 +
.../controller/BaseControllerQueryKernelTest.java | 320 +++
.../controller/ControllerQueryKernelTests.java | 383 ++++
.../controller/ControllerTestInputSlice.java | 31 +
.../kernel/controller/ControllerTestInputSpec.java | 26 +
.../controller/ControllerTestInputSpecSlicer.java | 57 +
.../controller/MockQueryDefinitionBuilder.java | 221 ++
.../msq/kernel/controller/WorkerInputsTest.java | 32 +
.../msq/querykit/BroadcastJoinHelperTest.java | 278 +++
.../java/org/apache/druid/msq/sql/MSQModeTest.java | 57 +
.../druid/msq/sql/MSQTaskQueryMakerTest.java | 53 +
.../apache/druid/msq/sql/SqlTaskStatusTest.java | 60 +
.../ClusterByStatisticsCollectorImplTest.java | 951 +++++++++
.../statistics/DelegateOrMinKeyCollectorTest.java | 152 ++
.../msq/statistics/DistinctKeyCollectorTest.java | 243 +++
.../msq/statistics/KeyCollectorTestUtils.java | 296 +++
.../QuantilesSketchKeyCollectorTest.java | 200 ++
.../org/apache/druid/msq/test/MSQTestBase.java | 1068 ++++++++++
.../druid/msq/test/MSQTestControllerClient.java | 94 +
.../druid/msq/test/MSQTestControllerContext.java | 261 +++
.../msq/test/MSQTestDelegateDataSegmentPusher.java | 72 +
.../msq/test/MSQTestOverlordServiceClient.java | 119 ++
.../druid/msq/test/MSQTestSegmentManager.java | 84 +
.../druid/msq/test/MSQTestTaskActionClient.java | 98 +
.../apache/druid/msq/test/MSQTestWorkerClient.java | 128 ++
.../druid/msq/test/MSQTestWorkerContext.java | 183 ++
.../apache/druid/msq/util/IntervalUtilsTest.java | 91 +
.../druid/msq/util/MultiStageQueryContextTest.java | 191 ++
.../msq/util/PassthroughAggregatorFactoryTest.java | 77 +
.../src/test/resources/unparseable.gz | Bin 0 -> 538 bytes
.../resources/wikipedia-sampled-unparsable.json | 3 +
.../src/test/resources/wikipedia-sampled.json | 20 +
.../druid/indexing/common/config/TaskConfig.java | 3 +-
.../druid/indexing/common/task/AbstractTask.java | 2 +-
.../apache/druid/indexing/overlord/TaskQueue.java | 4 +
pom.xml | 1 +
315 files changed, 42209 insertions(+), 10 deletions(-)
create mode 100644 extensions-core/multi-stage-query/README.md
create mode 100644 extensions-core/multi-stage-query/pom.xml
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/ChannelCounters.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterNames.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterSnapshots.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterSnapshotsSerializer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterSnapshotsTree.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterTracker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/QueryCounter.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/QueryCounterSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/SuperSorterProgressTrackerCounter.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/WarningCounters.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/Controller.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ExceptionWrappingWorkerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/Limits.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/MSQTasks.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/QueryValidator.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/TaskDataSegmentProvider.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/Worker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerManagerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerMemoryParameters.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQDurableStorageModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQExternalDataSourceModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQIndexingModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQServiceClientModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQSqlModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MultiStageQuery.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/SqlTaskModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/ColumnMapping.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/ColumnMappings.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/ControllerChatHandler.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/CountableInputSourceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/CountingOutputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/CountingReadableFrameChannel.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/CountingWritableFrameChannel.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/DataSourceMSQDestination.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerFrameContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerManagerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/InputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/InputChannelsImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/KeyStatisticsCollectionProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQControllerTask.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQDestination.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQPartitionAssignment.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQTaskList.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQTuningConfig.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQWorkerTask.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQWorkerTaskLauncher.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/SegmentGeneratorFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/SegmentGeneratorFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/TaskReportMSQDestination.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/WorkerChatHandler.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/BaseMSQFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/BroadcastTablesTooLargeFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/CanceledFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/CannotParseExternalDataFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/ColumnNameRestrictedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/ColumnTypeNotSupportedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/DurableStorageConfigurationFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/FaultsExceededChecker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotAllocateSegmentFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotBeEmptyFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotOrderByDescendingFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotReplaceExistingSegmentFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertLockPreemptedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertTimeNullFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertTimeOutOfBoundsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InvalidNullByteFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQErrorReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQException.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportPublisher.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportSimplePublisher.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarnings.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/NotEnoughMemoryFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/QueryNotSupportedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/RowTooLargeFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TaskStartTimeoutFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyBucketsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyColumnsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyInputFilesFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyPartitionsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyWarningsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyWorkersFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/UnknownFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/WorkerFailedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/WorkerRpcFailedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQResultsReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQStagesReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQStatusReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQTaskReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQTaskReportPayload.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSlices.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpecSlicerFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpecs.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/MapInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/MapInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/NilInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/NilInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/NilInputSource.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/ReadableInput.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/ReadableInputs.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/SlicerUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/external/ExternalInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/external/ExternalInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/external/ExternalInputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/external/ExternalInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/CollectedReadablePartitions.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/CombinedReadablePartitions.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/InputChannels.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/ReadablePartition.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/ReadablePartitions.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StageInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StageInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StageInputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StageInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StripedReadablePartitions.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/RichSegmentDescriptor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/SegmentWithDescriptor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/SegmentsInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/SegmentsInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/TableInputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/TableInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/ExtraInfoHolder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/FrameContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/FrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/MaxCountShuffleSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/NilExtraInfoHolder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/ProcessorsAndChannels.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/QueryDefinition.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/QueryDefinitionBuilder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/ShuffleSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageDefinition.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageDefinitionBuilder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageId.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StagePartition.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/TargetSizeShuffleSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/WorkOrder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/WorkerAssignmentStrategy.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernel.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStagePhase.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/WorkerInputs.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/worker/WorkerStageKernel.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/worker/WorkerStagePhase.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BroadcastJoinHelper.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/DataSegmentProvider.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/DataSegmentTimelineView.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/DataSourcePlan.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/InputNumberDataSource.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/LazyResourceHolder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/MultiQueryKit.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/QueryKit.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/QueryKitUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/ShuffleSpecFactories.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/ShuffleSpecFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/common/OffsetLimitFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/common/OffsetLimitFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPostShuffleFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPostShuffleFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPreShuffleFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPreShuffleFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByQueryKit.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryKit.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/CoordinatorServiceClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/CoordinatorServiceClientImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/DurableStorageInputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/DurableStorageOutputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/WorkerInputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/MSQMode.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/MSQTaskQueryMaker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/MSQTaskSqlEngine.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/SqlTaskResource.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/SqlTaskStatus.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollectorImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DistinctKeyCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DistinctKeyCollectorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DistinctKeySnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollectorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollectorSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollectorSnapshotDeserializerModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollectors.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/TooManyBucketsException.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/DecoratedExecutorService.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/DimensionSchemaUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/IntervalUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MSQFutureUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/PassthroughAggregator.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/PassthroughAggregatorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/SequenceUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/SupplierIterator.java
create mode 100644
extensions-core/multi-stage-query/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
create mode 100644
extensions-core/multi-stage-query/src/main/resources/log4j2.xml
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/TestArrayStorageAdapter.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/counters/CountersSnapshotTreeTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQInsertTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQReplaceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQSelectTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQTasksTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/QueryValidatorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/WorkerMemoryParametersTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/ColumnMappingTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/DataSourceMSQDestinationTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/IndexerWorkerContextTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/MSQPartitionAssignmentTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/MSQSpecTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/MSQTuningConfigTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/InsertLockPreemptedFaultTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/MSQFaultSerdeTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/MSQWarningsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/report/MSQTaskReportTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/InputSpecsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/NilInputSliceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/external/ExternalInputSliceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/external/ExternalInputSpecSlicerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/external/ExternalInputSpecTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/CollectedReadablePartitionsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/CombinedReadablePartitionsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/ReadablePartitionTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/StageInputSliceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/StageInputSpecSlicerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/StageInputSpecTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/StripedReadablePartitionsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/RichSegmentDescriptorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/SegmentWithDescriptorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/SegmentsInputSliceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/TableInputSpecSlicerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/TableInputSpecTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/QueryDefinitionTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/StageDefinitionTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/StageIdTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/WorkOrderTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/BaseControllerQueryKernelTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelTests.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/MockQueryDefinitionBuilder.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/WorkerInputsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/BroadcastJoinHelperTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/sql/MSQModeTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/sql/MSQTaskQueryMakerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/sql/SqlTaskStatusTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollectorImplTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/DistinctKeyCollectorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/KeyCollectorTestUtils.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestBase.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestControllerClient.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestControllerContext.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestDelegateDataSegmentPusher.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestOverlordServiceClient.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestSegmentManager.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestTaskActionClient.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestWorkerClient.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestWorkerContext.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/util/IntervalUtilsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/util/MultiStageQueryContextTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/util/PassthroughAggregatorFactoryTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/resources/unparseable.gz
create mode 100644
extensions-core/multi-stage-query/src/test/resources/wikipedia-sampled-unparsable.json
create mode 100644
extensions-core/multi-stage-query/src/test/resources/wikipedia-sampled.json
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
