This is an automated email from the ASF dual-hosted git repository.
karan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from 08e2c71cd4d Fix overly-strict VirtualColumns cycle detection. (#18418)
add 1168cf0b482 Move multi-stage-query module out of extension (#18394)
No new revisions were added by this update.
Summary of changes:
.github/labeler.yml | 6 ++---
benchmarks/pom.xml | 4 ++--
distribution/docker/environment | 2 +-
distribution/pom.xml | 4 ----
embedded-tests/pom.xml | 2 +-
.../embedded/indexing/IngestionSmokeTest.java | 14 +----------
.../msq/EmbeddedDurableShuffleStorageTest.java | 24 +------------------
.../embedded/msq/EmbeddedMSQRealtimeQueryTest.java | 20 ----------------
.../msq/EmbeddedMSQRealtimeUnnestQueryTest.java | 20 ----------------
.../druid/auto/_common/common.runtime.properties | 2 +-
.../cluster/_common/common.runtime.properties | 2 +-
.../large/_common/common.runtime.properties | 2 +-
.../medium/_common/common.runtime.properties | 2 +-
.../_common/common.runtime.properties | 2 +-
.../_common/common.runtime.properties | 2 +-
.../small/_common/common.runtime.properties | 2 +-
.../xlarge/_common/common.runtime.properties | 2 +-
extensions-core/druid-catalog/pom.xml | 6 +++++
.../org.apache.druid.initialization.DruidModule | 26 ---------------------
integration-tests-ex/cases/pom.xml | 2 +-
.../docker/environment-configs/common | 2 +-
.../docker/environment-configs/common-ldap | 2 +-
integration-tests/pom.xml | 2 +-
.../README.md | 0
.../pom.xml | 20 +++++-----------
.../druid/catalog/sql/LiveCatalogResolver.java | 0
.../apache/druid/msq/counters/ChannelCounters.java | 0
.../apache/druid/msq/counters/CounterNames.java | 0
.../druid/msq/counters/CounterSnapshots.java | 0
.../msq/counters/CounterSnapshotsSerializer.java | 0
.../druid/msq/counters/CounterSnapshotsTree.java | 0
.../apache/druid/msq/counters/CounterTracker.java | 0
.../org/apache/druid/msq/counters/CpuCounter.java | 0
.../org/apache/druid/msq/counters/CpuCounters.java | 0
.../CpuTimeAccumulatingFrameProcessor.java | 0
.../CpuTimeAccumulatingProcessorManager.java | 0
.../msq/counters/NilQueryCounterSnapshot.java | 0
.../apache/druid/msq/counters/QueryCounter.java | 0
.../druid/msq/counters/QueryCounterSnapshot.java | 0
.../counters/SegmentGenerationProgressCounter.java | 0
.../counters/SegmentGeneratorMetricsWrapper.java | 0
.../SuperSorterProgressTrackerCounter.java | 0
.../apache/druid/msq/counters/WarningCounters.java | 0
.../main/java/org/apache/druid/msq/dart/Dart.java | 0
.../msq/dart/DartResourcePermissionMapper.java | 0
.../msq/dart/controller/ControllerHolder.java | 0
.../dart/controller/ControllerMessageListener.java | 0
.../msq/dart/controller/DartControllerContext.java | 0
.../controller/DartControllerContextFactory.java | 0
.../DartControllerContextFactoryImpl.java | 0
.../dart/controller/DartControllerRegistry.java | 0
.../controller/DartMessageRelayFactoryImpl.java | 0
.../msq/dart/controller/DartMessageRelays.java | 0
.../msq/dart/controller/DartSegmentAssignment.java | 0
.../dart/controller/DartTableInputSpecSlicer.java | 0
.../msq/dart/controller/DartWorkerManager.java | 0
.../msq/dart/controller/http/DartQueryInfo.java | 0
.../controller/messages/ControllerMessage.java | 0
.../dart/controller/messages/DoneReadingInput.java | 0
.../controller/messages/PartialKeyStatistics.java | 0
.../dart/controller/messages/ResultsComplete.java | 0
.../msq/dart/controller/messages/WorkerError.java | 0
.../dart/controller/messages/WorkerWarning.java | 0
.../msq/dart/controller/sql/DartQueryMaker.java | 0
.../msq/dart/controller/sql/DartSqlClient.java | 0
.../dart/controller/sql/DartSqlClientFactory.java | 0
.../controller/sql/DartSqlClientFactoryImpl.java | 0
.../msq/dart/controller/sql/DartSqlClientImpl.java | 0
.../msq/dart/controller/sql/DartSqlClients.java | 0
.../msq/dart/controller/sql/DartSqlEngine.java | 0
.../controller/sql/PrePlannedDartQueryMaker.java | 0
.../druid/msq/dart/guice/DartControllerConfig.java | 0
.../DartControllerMemoryManagementModule.java | 0
.../druid/msq/dart/guice/DartControllerModule.java | 0
.../apache/druid/msq/dart/guice/DartModules.java | 0
.../druid/msq/dart/guice/DartWorkerConfig.java | 0
.../guice/DartWorkerMemoryManagementModule.java | 0
.../druid/msq/dart/guice/DartWorkerModule.java | 0
.../msq/dart/worker/DartControllerClient.java | 0
.../msq/dart/worker/DartDataSegmentProvider.java | 0
.../dart/worker/DartDataServerQueryHandler.java | 0
.../worker/DartDataServerQueryHandlerFactory.java | 0
.../druid/msq/dart/worker/DartFrameContext.java | 0
.../dart/worker/DartProcessingBuffersProvider.java | 0
.../msq/dart/worker/DartQueryableSegment.java | 0
.../druid/msq/dart/worker/DartWorkerClient.java | 0
.../msq/dart/worker/DartWorkerClientImpl.java | 0
.../druid/msq/dart/worker/DartWorkerContext.java | 0
.../msq/dart/worker/DartWorkerContextFactory.java | 0
.../dart/worker/DartWorkerContextFactoryImpl.java | 0
.../msq/dart/worker/DartWorkerRetryPolicy.java | 0
.../druid/msq/dart/worker/DartWorkerRunner.java | 0
.../org/apache/druid/msq/dart/worker/WorkerId.java | 0
.../druid/msq/dart/worker/http/DartWorkerInfo.java | 0
.../msq/dart/worker/http/DartWorkerResource.java | 0
.../msq/dart/worker/http/GetWorkersResponse.java | 0
.../druid/msq/exec/ClusterStatisticsMergeMode.java | 0
.../java/org/apache/druid/msq/exec/Controller.java | 0
.../apache/druid/msq/exec/ControllerClient.java | 0
.../apache/druid/msq/exec/ControllerContext.java | 0
.../org/apache/druid/msq/exec/ControllerImpl.java | 0
.../druid/msq/exec/ControllerMemoryParameters.java | 0
.../msq/exec/ControllerQueryResultsReader.java | 0
.../druid/msq/exec/DataServerQueryHandler.java | 0
.../msq/exec/DataServerQueryHandlerFactory.java | 0
.../msq/exec/DataServerQueryHandlerUtils.java | 0
.../druid/msq/exec/DataServerQueryResult.java | 0
.../msq/exec/ExceptionWrappingWorkerClient.java | 0
.../apache/druid/msq/exec/ExecutionContext.java | 0
.../druid/msq/exec/ExecutionContextImpl.java | 0
.../druid/msq/exec/ExportMetadataManager.java | 0
.../org/apache/druid/msq/exec/ExtraInfoHolder.java | 0
.../org/apache/druid/msq/exec/FrameContext.java | 0
.../org/apache/druid/msq/exec/FrameWriterSpec.java | 0
.../java/org/apache/druid/msq/exec/Limits.java | 0
.../msq/exec/ListeningOutputChannelFactory.java | 0
.../druid/msq/exec/MSQMetriceEventBuilder.java | 0
.../java/org/apache/druid/msq/exec/MSQTasks.java | 0
.../apache/druid/msq/exec/MemoryIntrospector.java | 0
.../druid/msq/exec/MemoryIntrospectorImpl.java | 0
.../apache/druid/msq/exec/OutputChannelMode.java | 0
.../apache/druid/msq/exec/ProcessingBuffers.java | 0
.../druid/msq/exec/ProcessingBuffersProvider.java | 0
.../druid/msq/exec/ProcessingBuffersSet.java | 0
.../druid/msq/exec/QueryKitBasedMSQPlanner.java | 0
.../apache/druid/msq/exec/QueryKitSpecFactory.java | 0
.../org/apache/druid/msq/exec/QueryListener.java | 0
.../org/apache/druid/msq/exec/QueryValidator.java | 0
.../org/apache/druid/msq/exec/ResultsContext.java | 0
.../druid/msq/exec/RetryCapableWorkerManager.java | 0
.../org/apache/druid/msq/exec/RunWorkOrder.java | 0
.../druid/msq/exec/RunWorkOrderListener.java | 0
.../druid/msq/exec/SegmentLoadStatusFetcher.java | 0
.../org/apache/druid/msq/exec/SegmentSource.java | 0
.../org/apache/druid/msq/exec/StageProcessor.java | 0
.../druid/msq/exec/TaskDataSegmentProvider.java | 0
.../java/org/apache/druid/msq/exec/Worker.java | 0
.../org/apache/druid/msq/exec/WorkerClient.java | 0
.../org/apache/druid/msq/exec/WorkerContext.java | 0
.../druid/msq/exec/WorkerFailureListener.java | 0
.../java/org/apache/druid/msq/exec/WorkerImpl.java | 0
.../org/apache/druid/msq/exec/WorkerManager.java | 0
.../druid/msq/exec/WorkerMemoryParameters.java | 0
.../org/apache/druid/msq/exec/WorkerRunRef.java | 0
.../apache/druid/msq/exec/WorkerSketchFetcher.java | 0
.../org/apache/druid/msq/exec/WorkerStats.java | 0
.../druid/msq/exec/WorkerStorageParameters.java | 0
.../msq/exec/std/BasicStandardStageProcessor.java | 0
.../druid/msq/exec/std/ProcessorsAndChannels.java | 0
.../druid/msq/exec/std/ResultAndChannels.java | 0
.../msq/exec/std/StandardShuffleOperations.java | 0
.../druid/msq/exec/std/StandardStageProcessor.java | 0
.../druid/msq/exec/std/StandardStageRunner.java | 0
.../msq/guice/IndexerMemoryManagementModule.java | 0
.../druid/msq/guice/MSQDurableStorageModule.java | 0
.../msq/guice/MSQExternalDataSourceModule.java | 0
.../apache/druid/msq/guice/MSQIndexingModule.java | 0
.../org/apache/druid/msq/guice/MSQSqlModule.java | 0
.../apache/druid/msq/guice/MultiStageQuery.java | 0
.../msq/guice/PeonMemoryManagementModule.java | 0
.../org/apache/druid/msq/guice/SqlTaskModule.java | 0
.../msq/guice/TaskMemoryManagementConfig.java | 0
.../msq/indexing/CountableInputSourceReader.java | 0
.../msq/indexing/CountingOutputChannelFactory.java | 0
.../msq/indexing/CountingReadableFrameChannel.java | 0
.../msq/indexing/CountingWritableFrameChannel.java | 0
.../msq/indexing/IndexerControllerContext.java | 0
.../indexing/IndexerDataServerQueryHandler.java | 0
.../IndexerDataServerQueryHandlerFactory.java | 0
.../druid/msq/indexing/IndexerFrameContext.java | 0
.../indexing/IndexerProcessingBuffersProvider.java | 3 +--
.../indexing/IndexerResourcePermissionMapper.java | 4 +---
.../msq/indexing/IndexerTableInputSpecSlicer.java | 0
.../druid/msq/indexing/IndexerWorkerContext.java | 0
.../druid/msq/indexing/InputChannelFactory.java | 0
.../druid/msq/indexing/InputChannelsImpl.java | 0
.../apache/druid/msq/indexing/LegacyMSQSpec.java | 0
.../druid/msq/indexing/MSQCompactionRunner.java | 0
.../druid/msq/indexing/MSQControllerTask.java | 0
.../druid/msq/indexing/MSQPartitionAssignment.java | 0
.../org/apache/druid/msq/indexing/MSQSpec.java | 0
.../org/apache/druid/msq/indexing/MSQTaskList.java | 0
.../apache/druid/msq/indexing/MSQTuningConfig.java | 0
.../apache/druid/msq/indexing/MSQWorkerTask.java | 0
.../druid/msq/indexing/MSQWorkerTaskLauncher.java | 0
.../indexing/PeonProcessingBuffersProvider.java | 3 +--
.../msq/indexing/PeriodicControllerChecker.java | 0
.../apache/druid/msq/indexing/QueryDefMSQSpec.java | 0
.../msq/indexing/TaskReportQueryListener.java | 0
.../org/apache/druid/msq/indexing/WorkerCount.java | 0
.../indexing/cleaner/DurableStorageCleaner.java | 0
.../cleaner/DurableStorageCleanerConfig.java | 0
.../msq/indexing/client/ControllerChatHandler.java | 0
.../indexing/client/IndexerControllerClient.java | 0
.../msq/indexing/client/IndexerWorkerClient.java | 0
.../msq/indexing/client/SketchResponseHandler.java | 0
.../msq/indexing/client/WorkerChatHandler.java | 0
.../destination/DataSourceMSQDestination.java | 0
.../destination/DurableStorageMSQDestination.java | 0
.../indexing/destination/ExportMSQDestination.java | 0
.../msq/indexing/destination/MSQDestination.java | 0
.../indexing/destination/MSQSelectDestination.java | 0
.../destination/MSQTerminalStageSpecFactory.java | 0
.../destination/SegmentGenerationStageSpec.java | 0
.../SegmentGenerationTerminalStageSpecFactory.java | 0
.../destination/SegmentGenerationUtils.java | 0
.../destination/TaskReportMSQDestination.java | 0
.../indexing/destination/TerminalStageSpec.java | 0
.../druid/msq/indexing/error/BaseMSQFault.java | 0
.../error/BroadcastTablesTooLargeFault.java | 0
.../druid/msq/indexing/error/CanceledFault.java | 0
.../msq/indexing/error/CancellationReason.java | 0
.../error/CannotParseExternalDataFault.java | 0
.../indexing/error/ColumnNameRestrictedFault.java | 0
.../error/ColumnTypeNotSupportedFault.java | 0
.../error/DurableStorageConfigurationFault.java | 0
.../msq/indexing/error/FaultsExceededChecker.java | 0
.../error/InsertCannotAllocateSegmentFault.java | 0
.../indexing/error/InsertCannotBeEmptyFault.java | 0
.../indexing/error/InsertLockPreemptedFault.java | 0
.../msq/indexing/error/InsertTimeNullFault.java | 0
.../indexing/error/InsertTimeOutOfBoundsFault.java | 0
.../msq/indexing/error/InvalidFieldFault.java | 0
.../msq/indexing/error/InvalidNullByteFault.java | 0
.../druid/msq/indexing/error/MSQErrorReport.java | 0
.../druid/msq/indexing/error/MSQException.java | 0
.../apache/druid/msq/indexing/error/MSQFault.java | 0
.../druid/msq/indexing/error/MSQFaultUtils.java | 0
.../error/MSQWarningReportLimiterPublisher.java | 0
.../indexing/error/MSQWarningReportPublisher.java | 0
.../error/MSQWarningReportSimplePublisher.java | 0
.../druid/msq/indexing/error/MSQWarnings.java | 0
.../msq/indexing/error/NotEnoughMemoryFault.java | 0
.../error/NotEnoughTemporaryStorageFault.java | 0
.../msq/indexing/error/QueryNotSupportedFault.java | 0
.../msq/indexing/error/QueryRuntimeFault.java | 0
.../druid/msq/indexing/error/RowTooLargeFault.java | 0
.../msq/indexing/error/TaskStartTimeoutFault.java | 0
.../msq/indexing/error/TooManyAttemptsForJob.java | 0
.../indexing/error/TooManyAttemptsForWorker.java | 0
.../msq/indexing/error/TooManyBucketsFault.java | 0
.../error/TooManyClusteredByColumnsFault.java | 0
.../msq/indexing/error/TooManyColumnsFault.java | 0
.../msq/indexing/error/TooManyInputFilesFault.java | 0
.../msq/indexing/error/TooManyPartitionsFault.java | 0
.../indexing/error/TooManyRowsInAWindowFault.java | 0
.../error/TooManyRowsWithSameKeyFault.java | 0
.../error/TooManySegmentsInTimeChunkFault.java | 0
.../msq/indexing/error/TooManyWarningsFault.java | 0
.../msq/indexing/error/TooManyWorkersFault.java | 0
.../druid/msq/indexing/error/UnknownFault.java | 0
.../msq/indexing/error/WorkerFailedFault.java | 0
.../msq/indexing/error/WorkerRpcFailedFault.java | 0
.../KeyStatisticsCollectionProcessor.java | 0
.../processor/SegmentGeneratorFrameProcessor.java | 0
.../processor/SegmentGeneratorStageProcessor.java | 0
.../msq/indexing/report/MSQResultsReport.java | 0
.../msq/indexing/report/MSQSegmentReport.java | 0
.../druid/msq/indexing/report/MSQStagesReport.java | 0
.../druid/msq/indexing/report/MSQStatusReport.java | 0
.../druid/msq/indexing/report/MSQTaskReport.java | 0
.../msq/indexing/report/MSQTaskReportPayload.java | 0
.../org/apache/druid/msq/input/InputSlice.java | 0
.../apache/druid/msq/input/InputSliceReader.java | 0
.../org/apache/druid/msq/input/InputSlices.java | 0
.../java/org/apache/druid/msq/input/InputSpec.java | 0
.../apache/druid/msq/input/InputSpecSlicer.java | 0
.../druid/msq/input/InputSpecSlicerFactory.java | 0
.../org/apache/druid/msq/input/InputSpecs.java | 0
.../druid/msq/input/MapInputSliceReader.java | 0
.../apache/druid/msq/input/MapInputSpecSlicer.java | 0
.../org/apache/druid/msq/input/NilInputSlice.java | 0
.../druid/msq/input/NilInputSliceReader.java | 0
.../org/apache/druid/msq/input/NilInputSource.java | 0
.../druid/msq/input/ParseExceptionUtils.java | 0
.../org/apache/druid/msq/input/ReadableInput.java | 0
.../org/apache/druid/msq/input/ReadableInputs.java | 0
.../org/apache/druid/msq/input/SlicerUtils.java | 0
.../msq/input/external/ExternalInputSlice.java | 0
.../input/external/ExternalInputSliceReader.java | 0
.../msq/input/external/ExternalInputSpec.java | 0
.../input/external/ExternalInputSpecSlicer.java | 0
.../druid/msq/input/external/ExternalSegment.java | 0
.../druid/msq/input/inline/InlineInputSlice.java | 0
.../msq/input/inline/InlineInputSliceReader.java | 0
.../druid/msq/input/inline/InlineInputSpec.java | 0
.../msq/input/inline/InlineInputSpecSlicer.java | 0
.../druid/msq/input/lookup/LookupInputSlice.java | 0
.../msq/input/lookup/LookupInputSliceReader.java | 0
.../druid/msq/input/lookup/LookupInputSpec.java | 0
.../msq/input/lookup/LookupInputSpecSlicer.java | 0
.../input/stage/CollectedReadablePartitions.java | 0
.../input/stage/CombinedReadablePartitions.java | 0
.../druid/msq/input/stage/InputChannels.java | 0
.../druid/msq/input/stage/ReadablePartition.java | 0
.../druid/msq/input/stage/ReadablePartitions.java | 0
.../stage/SparseStripedReadablePartitions.java | 0
.../druid/msq/input/stage/StageInputSlice.java | 0
.../msq/input/stage/StageInputSliceReader.java | 0
.../druid/msq/input/stage/StageInputSpec.java | 0
.../msq/input/stage/StageInputSpecSlicer.java | 0
.../msq/input/stage/StripedReadablePartitions.java | 0
.../msq/input/table/DataSegmentWithLocation.java | 0
.../input/table/DataServerRequestDescriptor.java | 0
.../druid/msq/input/table/DataServerSelector.java | 0
.../msq/input/table/RichSegmentDescriptor.java | 0
.../msq/input/table/SegmentWithDescriptor.java | 0
.../druid/msq/input/table/SegmentsInputSlice.java | 0
.../msq/input/table/SegmentsInputSliceReader.java | 0
.../druid/msq/input/table/TableInputSpec.java | 0
.../msq/kernel/GlobalSortMaxCountShuffleSpec.java | 0
.../druid/msq/kernel/GlobalSortShuffleSpec.java | 0
.../kernel/GlobalSortTargetSizeShuffleSpec.java | 0
.../apache/druid/msq/kernel/HashShuffleSpec.java | 0
.../msq/kernel/LimitHintJsonIncludeFilter.java | 0
.../apache/druid/msq/kernel/MixShuffleSpec.java | 0
.../druid/msq/kernel/NilExtraInfoHolder.java | 0
.../apache/druid/msq/kernel/QueryDefinition.java | 0
.../druid/msq/kernel/QueryDefinitionBuilder.java | 0
.../org/apache/druid/msq/kernel/ShuffleKind.java | 0
.../org/apache/druid/msq/kernel/ShuffleSpec.java | 0
.../apache/druid/msq/kernel/StageDefinition.java | 0
.../druid/msq/kernel/StageDefinitionBuilder.java | 0
.../java/org/apache/druid/msq/kernel/StageId.java | 0
.../apache/druid/msq/kernel/StagePartition.java | 0
.../org/apache/druid/msq/kernel/WorkOrder.java | 0
.../druid/msq/kernel/WorkerAssignmentStrategy.java | 0
.../kernel/controller/ControllerQueryKernel.java | 0
.../controller/ControllerQueryKernelConfig.java | 0
.../controller/ControllerQueryKernelUtils.java | 0
.../kernel/controller/ControllerStagePhase.java | 0
.../kernel/controller/ControllerStageTracker.java | 0
.../controller/ControllerWorkerStagePhase.java | 0
.../druid/msq/kernel/controller/StageGroup.java | 0
.../druid/msq/kernel/controller/WorkerInputs.java | 0
.../druid/msq/kernel/worker/WorkerStageKernel.java | 0
.../druid/msq/kernel/worker/WorkerStagePhase.java | 0
.../DruidLogicalToQueryDefinitionTranslator.java | 0
.../apache/druid/msq/logical/LogicalInputSpec.java | 0
.../org/apache/druid/msq/logical/StageMaker.java | 0
.../stages/AbstractFrameProcessorStage.java | 0
.../msq/logical/stages/AbstractLogicalStage.java | 0
.../msq/logical/stages/AbstractShuffleStage.java | 0
.../druid/msq/logical/stages/FilterStage.java | 0
.../druid/msq/logical/stages/GroupByStages.java | 0
.../druid/msq/logical/stages/LogicalStage.java | 0
.../druid/msq/logical/stages/OffsetLimitStage.java | 0
.../druid/msq/logical/stages/ProjectStage.java | 0
.../apache/druid/msq/logical/stages/ReadStage.java | 0
.../apache/druid/msq/logical/stages/SortStage.java | 0
.../druid/msq/querykit/BaseLeafFrameProcessor.java | 0
.../querykit/BaseLeafFrameProcessorManager.java | 0
.../druid/msq/querykit/BaseLeafStageProcessor.java | 0
.../BroadcastJoinSegmentMapFnProcessor.java | 0
.../msq/querykit/ChainedProcessorManager.java | 0
.../druid/msq/querykit/DataSegmentProvider.java | 0
.../apache/druid/msq/querykit/DataSourcePlan.java | 0
.../druid/msq/querykit/InputNumberDataSource.java | 0
.../druid/msq/querykit/LazyResourceHolder.java | 0
.../apache/druid/msq/querykit/MultiQueryKit.java | 0
.../org/apache/druid/msq/querykit/QueryKit.java | 0
.../apache/druid/msq/querykit/QueryKitSpec.java | 0
.../apache/druid/msq/querykit/QueryKitUtils.java | 0
.../querykit/RestrictedInputNumberDataSource.java | 0
.../druid/msq/querykit/ShuffleSpecFactories.java | 0
.../druid/msq/querykit/ShuffleSpecFactory.java | 0
.../msq/querykit/SimpleSegmentMapFnProcessor.java | 0
.../WindowOperatorQueryFrameProcessor.java | 0
.../druid/msq/querykit/WindowOperatorQueryKit.java | 0
.../WindowOperatorQueryStageProcessor.java | 0
.../querykit/common/OffsetLimitFrameProcessor.java | 0
.../querykit/common/OffsetLimitStageProcessor.java | 0
.../common/SortMergeJoinFrameProcessor.java | 0
.../common/SortMergeJoinStageProcessor.java | 0
.../groupby/GroupByPostShuffleFrameProcessor.java | 0
.../groupby/GroupByPostShuffleStageProcessor.java | 0
.../groupby/GroupByPreShuffleFrameProcessor.java | 0
.../groupby/GroupByPreShuffleStageProcessor.java | 0
.../msq/querykit/groupby/GroupByQueryKit.java | 0
.../results/ExportResultsFrameProcessor.java | 0
.../results/ExportResultsStageProcessor.java | 0
.../results/QueryResultStageProcessor.java | 0
.../results/QueryResultsFrameProcessor.java | 0
.../scan/ExternalColumnSelectorFactory.java | 0
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 0
.../druid/msq/querykit/scan/ScanQueryKit.java | 0
.../msq/querykit/scan/ScanQueryStageProcessor.java | 0
.../apache/druid/msq/rpc/BaseWorkerClientImpl.java | 0
.../apache/druid/msq/rpc/ControllerResource.java | 0
.../org/apache/druid/msq/rpc/MSQResourceUtils.java | 0
.../druid/msq/rpc/ResourcePermissionMapper.java | 0
.../org/apache/druid/msq/rpc/SketchEncoding.java | 0
.../org/apache/druid/msq/rpc/WorkerResource.java | 0
.../input/DurableStorageInputChannelFactory.java | 0
...ableStorageQueryResultsInputChannelFactory.java | 0
.../DurableStorageStageInputChannelFactory.java | 0
.../msq/shuffle/input/MetaInputChannelFactory.java | 0
.../shuffle/input/WorkerInputChannelFactory.java | 0
.../input/WorkerOrLocalInputChannelFactory.java | 0
.../msq/shuffle/output/ByteChunksInputStream.java | 0
.../shuffle/output/ChannelStageOutputReader.java | 0
.../output/DurableStorageOutputChannelFactory.java | 0
...bleStorageQueryResultsOutputChannelFactory.java | 0
.../DurableStorageTaskOutputChannelFactory.java | 0
.../msq/shuffle/output/FileStageOutputReader.java | 0
.../shuffle/output/FutureReadableFrameChannel.java | 0
.../msq/shuffle/output/NilStageOutputReader.java | 0
.../msq/shuffle/output/StageOutputHolder.java | 0
.../msq/shuffle/output/StageOutputReader.java | 0
.../druid/msq/sql/DartQueryKitSpecFactory.java | 0
.../java/org/apache/druid/msq/sql/MSQMode.java | 0
.../druid/msq/sql/MSQTaskQueryKitSpecFactory.java | 0
.../apache/druid/msq/sql/MSQTaskQueryMaker.java | 0
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 0
.../apache/druid/msq/sql/SqlStatementState.java | 0
.../druid/msq/sql/entity/ColumnNameAndTypes.java | 0
.../druid/msq/sql/entity/PageInformation.java | 0
.../druid/msq/sql/entity/ResultSetInformation.java | 0
.../druid/msq/sql/entity/SqlStatementResult.java | 0
.../msq/sql/resources/SqlStatementResource.java | 0
.../druid/msq/sql/resources/SqlTaskResource.java | 0
.../statistics/ClusterByStatisticsCollector.java | 0
.../ClusterByStatisticsCollectorImpl.java | 0
.../statistics/ClusterByStatisticsSnapshot.java | 0
.../CompleteKeyStatisticsInformation.java | 0
.../msq/statistics/DelegateOrMinKeyCollector.java | 0
.../DelegateOrMinKeyCollectorFactory.java | 0
.../DelegateOrMinKeyCollectorSnapshot.java | 0
.../druid/msq/statistics/DistinctKeyCollector.java | 0
.../statistics/DistinctKeyCollectorFactory.java | 0
.../druid/msq/statistics/DistinctKeySnapshot.java | 0
.../apache/druid/msq/statistics/KeyCollector.java | 0
.../druid/msq/statistics/KeyCollectorFactory.java | 0
.../druid/msq/statistics/KeyCollectorSnapshot.java | 0
.../apache/druid/msq/statistics/KeyCollectors.java | 0
.../PartialKeyStatisticsInformation.java | 0
.../statistics/QuantilesSketchKeyCollector.java | 0
.../QuantilesSketchKeyCollectorFactory.java | 0
.../QuantilesSketchKeyCollectorSnapshot.java | 0
.../serde/ClusterByStatisticsSnapshotSerde.java | 0
.../statistics/serde/DelegateOrMinSerializer.java | 0
.../serde/DistinctSnapshotSerializer.java | 0
.../serde/KeyCollectorSnapshotDeserializer.java | 0
.../serde/KeyCollectorSnapshotSerializer.java | 0
.../serde/QuantilesSnapshotSerializer.java | 0
.../org/apache/druid/msq/util/ArrayIngestMode.java | 0
.../druid/msq/util/DecoratedExecutorService.java | 0
.../druid/msq/util/DimensionSchemaUtils.java | 0
.../org/apache/druid/msq/util/IntervalUtils.java | 0
.../org/apache/druid/msq/util/MSQFutureUtils.java | 0
.../org/apache/druid/msq/util/MSQMetricUtils.java | 0
.../druid/msq/util/MSQTaskQueryMakerUtils.java | 0
.../druid/msq/util/MultiStageQueryContext.java | 0
.../druid/msq/util/PassthroughAggregator.java | 0
.../msq/util/PassthroughAggregatorFactory.java | 0
.../org/apache/druid/msq/util/SequenceUtils.java | 0
.../druid/msq/util/SqlStatementResourceHelper.java | 0
.../apache/druid/msq/util/SupplierIterator.java | 0
.../src/main/resources/log4j2.xml | 0
.../msq/counters/CountersSnapshotTreeTest.java | 0
.../apache/druid/msq/counters/CpuCountersTest.java | 0
.../SegmentGenerationProgressCounterTest.java | 0
.../dart/controller/DartControllerContextTest.java | 0
.../controller/DartTableInputSpecSlicerTest.java | 0
.../msq/dart/controller/DartWorkerManagerTest.java | 0
.../dart/controller/http/DartQueryInfoTest.java | 0
.../dart/controller/http/DartSqlResourceTest.java | 0
.../controller/messages/ControllerMessageTest.java | 0
.../dart/controller/sql/DartSqlClientImplTest.java | 0
.../worker/DartProcessingBuffersProviderTest.java | 0
.../msq/dart/worker/DartQueryableSegmentTest.java | 0
.../msq/dart/worker/DartWorkerRunnerTest.java | 0
.../apache/druid/msq/dart/worker/WorkerIdTest.java | 0
.../msq/dart/worker/http/DartWorkerInfoTest.java | 0
.../dart/worker/http/GetWorkersResponseTest.java | 0
.../apache/druid/msq/exec/ControllerImplTest.java | 0
.../msq/exec/ControllerMemoryParametersTest.java | 0
.../msq/exec/DataServerQueryHandlerUtilsTest.java | 0
.../org/apache/druid/msq/exec/MSQArraysTest.java | 0
.../druid/msq/exec/MSQComplexGroupByTest.java | 0
.../apache/druid/msq/exec/MSQDataSketchesTest.java | 0
.../druid/msq/exec/MSQDrillWindowQueryTest.java | 0
.../org/apache/druid/msq/exec/MSQExportTest.java | 0
.../org/apache/druid/msq/exec/MSQFaultsTest.java | 0
.../org/apache/druid/msq/exec/MSQInsertTest.java | 0
.../druid/msq/exec/MSQLoadedSegmentTests.java | 0
.../druid/msq/exec/MSQParseExceptionsTest.java | 0
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 0
.../org/apache/druid/msq/exec/MSQSelectTest.java | 0
.../org/apache/druid/msq/exec/MSQTasksTest.java | 0
.../org/apache/druid/msq/exec/MSQWindowTest.java | 0
.../druid/msq/exec/ProcessingBuffersSetTest.java | 0
.../apache/druid/msq/exec/QueryValidatorTest.java | 0
.../druid/msq/exec/ResultsContextSerdeTest.java | 0
.../apache/druid/msq/exec/RunWorkOrderTest.java | 0
.../msq/exec/SegmentLoadStatusFetcherTest.java | 0
.../msq/exec/TaskDataSegmentProviderTest.java | 0
.../apache/druid/msq/exec/TestMSQSqlModule.java | 0
.../org/apache/druid/msq/exec/WorkerImplTest.java | 0
.../druid/msq/exec/WorkerMemoryParametersTest.java | 0
.../apache/druid/msq/exec/WorkerRunRefTest.java | 0
.../druid/msq/exec/WorkerSketchFetcherTest.java | 0
.../msq/exec/WorkerStorageParametersTest.java | 0
.../druid/msq/indexing/ColumnMappingTest.java | 0
.../msq/indexing/DurableStorageCleanerTest.java | 0
.../IndexerDataServerQueryHandlerTest.java | 0
.../msq/indexing/MSQCompactionRunnerTest.java | 0
.../druid/msq/indexing/MSQControllerTaskTest.java | 0
.../msq/indexing/MSQPartitionAssignmentTest.java | 0
.../druid/msq/indexing/MSQSpecCompatTest.java | 2 +-
.../org/apache/druid/msq/indexing/MSQSpecTest.java | 0
.../apache/druid/msq/indexing/MSQTaskListTest.java | 0
.../druid/msq/indexing/MSQTuningConfigTest.java | 0
.../indexing/MSQWorkerTaskLauncherRetryTests.java | 0
.../msq/indexing/MSQWorkerTaskLauncherTest.java | 0
.../druid/msq/indexing/MSQWorkerTaskTest.java | 0
.../indexing/PeriodicControllerCheckerTest.java | 0
.../msq/indexing/TaskReportQueryListenerTest.java | 0
.../druid/msq/indexing/WorkerChatHandlerTest.java | 0
.../indexing/client/ControllerChatHandlerTest.java | 0
.../destination/DataSourceMSQDestinationTest.java | 0
.../destination/ExportMSQDestinationTest.java | 0
.../msq/indexing/error/CanceledFaultTest.java | 0
.../error/InsertLockPreemptedFaultTest.java | 0
.../msq/indexing/error/MSQErrorReportTest.java | 0
.../msq/indexing/error/MSQFaultSerdeTest.java | 0
.../druid/msq/indexing/error/MSQWarningsTest.java | 0
.../msq/indexing/report/MSQTaskReportTest.java | 0
.../org/apache/druid/msq/input/InputSpecsTest.java | 0
.../apache/druid/msq/input/NilInputSliceTest.java | 0
.../msq/input/external/ExternalInputSliceTest.java | 0
.../external/ExternalInputSpecSlicerTest.java | 0
.../msq/input/external/ExternalInputSpecTest.java | 0
.../msq/input/external/NilInputSourceTest.java | 0
.../msq/input/inline/InlineInputSliceTest.java | 0
.../msq/input/inline/InlineInputSpecTest.java | 0
.../msq/input/lookup/LookupInputSliceTest.java | 0
.../msq/input/lookup/LookupInputSpecTest.java | 0
.../stage/CollectedReadablePartitionsTest.java | 0
.../stage/CombinedReadablePartitionsTest.java | 0
.../msq/input/stage/ReadablePartitionTest.java | 0
.../stage/SparseStripedReadablePartitionsTest.java | 0
.../druid/msq/input/stage/StageInputSliceTest.java | 0
.../msq/input/stage/StageInputSpecSlicerTest.java | 0
.../druid/msq/input/stage/StageInputSpecTest.java | 0
.../input/stage/StripedReadablePartitionsTest.java | 0
.../table/DataServerRequestDescriptorTest.java | 0
.../table/IndexerTableInputSpecSlicerTest.java | 0
.../msq/input/table/RichSegmentDescriptorTest.java | 0
.../msq/input/table/SegmentWithDescriptorTest.java | 0
.../msq/input/table/SegmentsInputSliceTest.java | 0
.../druid/msq/input/table/TableInputSpecTest.java | 0
.../druid/msq/kernel/QueryDefinitionTest.java | 0
.../druid/msq/kernel/StageDefinitionTest.java | 0
.../org/apache/druid/msq/kernel/StageIdTest.java | 0
.../org/apache/druid/msq/kernel/WorkOrderTest.java | 0
.../controller/BaseControllerQueryKernelTest.java | 0
.../ControllerQueryKernelConfigTest.java | 0
.../controller/ControllerQueryKernelTest.java | 0
.../controller/ControllerQueryKernelUtilsTest.java | 0
.../controller/ControllerTestInputSlice.java | 0
.../kernel/controller/ControllerTestInputSpec.java | 0
.../controller/ControllerTestInputSpecSlicer.java | 0
.../controller/MockQueryDefinitionBuilder.java | 0
.../NonShufflingWorkersWithRetryKernelTest.java | 0
.../ShufflingWorkersWithRetryKernelTest.java | 0
.../msq/kernel/controller/WorkerInputsTest.java | 0
.../BroadcastJoinSegmentMapFnProcessorTest.java | 0
.../msq/querykit/ChainedProcessorManagerTest.java | 0
.../druid/msq/querykit/FrameProcessorTestBase.java | 0
.../querykit/NonFailingWritableFrameChannel.java | 0
.../RestrictedInputNumberDataSourceTest.java | 0
.../WindowOperatorQueryFrameProcessorTest.java | 0
.../WindowOperatorQueryStageProcessorTest.java | 0
.../common/SortMergeJoinFrameProcessorTest.java | 0
.../common/SortMergeJoinStageProcessorTest.java | 0
.../results/ExportResultsStageProcessorTest.java | 0
.../results/QueryResultsFrameProcessorTest.java | 0
.../querykit/scan/ScanQueryFrameProcessorTest.java | 0
.../org/apache/druid/msq/quidem/MSQQuidemTest.java | 2 +-
.../druid/msq/rpc/BaseWorkerClientImplTest.java | 0
.../DurableStorageOutputChannelFactoryTest.java | 0
.../shuffle/output/ByteChunksInputStreamTest.java | 0
.../output/ChannelStageOutputReaderTest.java | 0
.../shuffle/output/NilStageOutputReaderTest.java | 0
.../java/org/apache/druid/msq/sql/MSQModeTest.java | 0
.../druid/msq/sql/MSQTaskQueryMakerTest.java | 0
.../msq/sql/entity/ColumnNameAndTypesTest.java | 0
.../msq/sql/entity/ResultSetInformationTest.java | 0
.../msq/sql/entity/SqlStatementResultTest.java | 0
.../resources/SqlMSQStatementResourcePostTest.java | 0
.../sql/resources/SqlStatementResourceTest.java | 0
.../druid/msq/statistics/ByteRowKeySerdeTest.java | 0
.../ClusterByStatisticsCollectorImplTest.java | 0
.../statistics/DelegateOrMinKeyCollectorTest.java | 0
.../msq/statistics/DistinctKeyCollectorTest.java | 0
.../msq/statistics/KeyCollectorTestUtils.java | 0
.../PartialKeyStatisticsInformationSerdeTest.java | 0
.../QuantilesSketchKeyCollectorSnapshotTest.java | 0
.../QuantilesSketchKeyCollectorTest.java | 0
...ndPartialKeyStatisticsInformationSerdeTest.java | 0
.../serde/KeyCollectorSnapshotSerializerTest.java | 0
.../test/AbstractMSQComponentSupplierDelegate.java | 0
.../msq/test/AllDruidEnginesComponentSupplier.java | 0
.../druid/msq/test/CalciteArraysQueryMSQTest.java | 0
.../org/apache/druid/msq/test/CalciteDartTest.java | 0
.../druid/msq/test/CalciteMSQTestsHelper.java | 0
.../msq/test/CalciteNestedDataQueryMSQTest.java | 0
.../druid/msq/test/CalciteSelectQueryMSQTest.java | 0
.../druid/msq/test/CalciteUnionQueryMSQTest.java | 0
.../druid/msq/test/CounterSnapshotMatcher.java | 0
.../druid/msq/test/DartComponentSupplier.java | 0
.../druid/msq/test/DecoupledCalciteDartTest.java | 0
.../msq/test/DecoupledDartCalciteQueryTest.java | 0
.../druid/msq/test/DecoupledDartExtension.java | 0
.../druid/msq/test/ExtractResultsFactory.java | 0
.../druid/msq/test/LimitedFrameWriterFactory.java | 0
.../msq/test/MSQCalciteSelectJoinQueryTest.java | 0
.../org/apache/druid/msq/test/MSQTestBase.java | 0
.../druid/msq/test/MSQTestControllerClient.java | 0
.../druid/msq/test/MSQTestControllerContext.java | 0
.../msq/test/MSQTestDelegateDataSegmentPusher.java | 0
.../msq/test/MSQTestOverlordServiceClient.java | 0
.../druid/msq/test/MSQTestSegmentManager.java | 0
.../druid/msq/test/MSQTestTaskActionClient.java | 0
.../apache/druid/msq/test/MSQTestWorkerClient.java | 0
.../druid/msq/test/MSQTestWorkerContext.java | 0
.../apache/druid/msq/test/NoopQueryListener.java | 0
.../msq/test/StandardAndMSQComponentSupplier.java | 0
.../msq/test/StandardMSQComponentSupplier.java | 0
.../test/TestDartControllerContextFactoryImpl.java | 0
.../VerifyMSQSupportedNativeQueriesPredicate.java | 0
.../druid/msq/util/DimensionSchemaUtilsTest.java | 0
.../apache/druid/msq/util/IntervalUtilsTest.java | 0
.../apache/druid/msq/util/MSQFaultUtilsTest.java | 0
.../druid/msq/util/MSQTaskQueryMakerUtilsTest.java | 0
.../druid/msq/util/MultiStageQueryContextTest.java | 0
.../msq/util/PassthroughAggregatorFactoryTest.java | 0
.../msq/util/SqlStatementResourceHelperTest.java | 0
.../apache/druid/sql/avatica/DartDruidMeta.java | 0
.../org/apache/druid/sql/avatica/MSQDruidMeta.java | 0
.../sql/calcite/NotYetSupportedUsageTest.java | 0
.../dart.iq | 0
.../msq1.iq | 0
.../msq2.iq | 0
.../msqJoinHint.iq | 0
.../msqNestedJoinHint.iq | 0
.../test/resources/dataset-with-time-column.json | 0
.../multipleFiles/wikipedia-sampled-1.json | 0
.../multipleFiles/wikipedia-sampled-2.json | 0
.../multipleFiles/wikipedia-sampled-3.json | 0
.../testBuilder1.json | 0
.../testBuilder2.json | 0
.../testComplexMSQSpec.json | 0
.../resources/unparseable-mv-string-array.json | 0
.../resources/unparseable-null-byte-string.csv | Bin
.../src/test/resources/unparseable.gz | Bin
.../resources/wikipedia-sampled-unparsable.json | 0
.../src/test/resources/wikipedia-sampled.json | 0
pom.xml | 2 +-
.../org/apache/druid/guice/ExtensionsLoader.java | 13 +++++++++--
quidem-ut/pom.xml | 4 ++--
services/pom.xml | 5 ++++
.../main/java/org/apache/druid/cli/CliBroker.java | 16 ++++++++++++-
.../java/org/apache/druid/cli/CliCoordinator.java | 6 +++++
.../java/org/apache/druid/cli/CliHistorical.java | 12 +++++++++-
.../main/java/org/apache/druid/cli/CliIndexer.java | 10 +++++++-
.../org/apache/druid/cli/CliMiddleManager.java | 8 ++++++-
.../java/org/apache/druid/cli/CliOverlord.java | 8 ++++++-
.../main/java/org/apache/druid/cli/CliPeon.java | 10 +++++++-
670 files changed, 121 insertions(+), 159 deletions(-)
delete mode 100644
extensions-core/multi-stage-query/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
rename {extensions-core/multi-stage-query => multi-stage-query}/README.md
(100%)
rename {extensions-core/multi-stage-query => multi-stage-query}/pom.xml (96%)
rename {extensions-core/druid-catalog =>
multi-stage-query}/src/main/java/org/apache/druid/catalog/sql/LiveCatalogResolver.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/ChannelCounters.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CounterNames.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CounterSnapshots.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CounterSnapshotsSerializer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CounterSnapshotsTree.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CounterTracker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CpuCounter.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CpuCounters.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CpuTimeAccumulatingFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/CpuTimeAccumulatingProcessorManager.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/NilQueryCounterSnapshot.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/QueryCounter.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/QueryCounterSnapshot.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/SegmentGenerationProgressCounter.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/SegmentGeneratorMetricsWrapper.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/SuperSorterProgressTrackerCounter.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/counters/WarningCounters.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/Dart.java (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/DartResourcePermissionMapper.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/ControllerHolder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/ControllerMessageListener.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContextFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContextFactoryImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartControllerRegistry.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartMessageRelayFactoryImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartMessageRelays.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartSegmentAssignment.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartTableInputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/DartWorkerManager.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/http/DartQueryInfo.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/messages/ControllerMessage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/messages/DoneReadingInput.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/messages/PartialKeyStatistics.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/messages/ResultsComplete.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/messages/WorkerError.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/messages/WorkerWarning.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/sql/DartQueryMaker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/sql/DartSqlClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/sql/DartSqlClientFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/sql/DartSqlClientFactoryImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/sql/DartSqlClientImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/sql/DartSqlClients.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/sql/DartSqlEngine.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/controller/sql/PrePlannedDartQueryMaker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/guice/DartControllerConfig.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/guice/DartControllerMemoryManagementModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/guice/DartControllerModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/guice/DartModules.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/guice/DartWorkerConfig.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/guice/DartWorkerMemoryManagementModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/guice/DartWorkerModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartControllerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartDataSegmentProvider.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartDataServerQueryHandler.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartDataServerQueryHandlerFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartFrameContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartProcessingBuffersProvider.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartQueryableSegment.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerClientImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerContextFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerContextFactoryImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerRetryPolicy.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerRunner.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/WorkerId.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/http/DartWorkerInfo.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/http/DartWorkerResource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/dart/worker/http/GetWorkersResponse.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ClusterStatisticsMergeMode.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/Controller.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ControllerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ControllerContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ControllerMemoryParameters.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ControllerQueryResultsReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/DataServerQueryHandler.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/DataServerQueryHandlerFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/DataServerQueryHandlerUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/DataServerQueryResult.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ExceptionWrappingWorkerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ExecutionContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ExecutionContextImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ExportMetadataManager.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ExtraInfoHolder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/FrameContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/FrameWriterSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/Limits.java (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ListeningOutputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/MSQMetriceEventBuilder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/MSQTasks.java (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/MemoryIntrospector.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/MemoryIntrospectorImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/OutputChannelMode.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ProcessingBuffers.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ProcessingBuffersProvider.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ProcessingBuffersSet.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/QueryKitBasedMSQPlanner.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/QueryKitSpecFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/QueryListener.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/QueryValidator.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/ResultsContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/RetryCapableWorkerManager.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/RunWorkOrder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/RunWorkOrderListener.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/SegmentSource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/StageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/TaskDataSegmentProvider.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/Worker.java (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerFailureListener.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerManager.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerMemoryParameters.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerRunRef.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerSketchFetcher.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerStats.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/WorkerStorageParameters.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/std/BasicStandardStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/std/ProcessorsAndChannels.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/std/ResultAndChannels.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/std/StandardShuffleOperations.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/std/StandardStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/exec/std/StandardStageRunner.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/IndexerMemoryManagementModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/MSQDurableStorageModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/MSQExternalDataSourceModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/MSQIndexingModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/MSQSqlModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/MultiStageQuery.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/PeonMemoryManagementModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/SqlTaskModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/guice/TaskMemoryManagementConfig.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/CountableInputSourceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/CountingOutputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/CountingReadableFrameChannel.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/CountingWritableFrameChannel.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/IndexerDataServerQueryHandler.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/IndexerDataServerQueryHandlerFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/IndexerFrameContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/IndexerProcessingBuffersProvider.java
(97%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/IndexerResourcePermissionMapper.java
(93%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/IndexerTableInputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/InputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/InputChannelsImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/LegacyMSQSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/MSQCompactionRunner.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/MSQControllerTask.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/MSQPartitionAssignment.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/MSQSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/MSQTaskList.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/MSQTuningConfig.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/MSQWorkerTask.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/MSQWorkerTaskLauncher.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/PeonProcessingBuffersProvider.java
(98%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/PeriodicControllerChecker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/QueryDefMSQSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/TaskReportQueryListener.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/WorkerCount.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/cleaner/DurableStorageCleaner.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/cleaner/DurableStorageCleanerConfig.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/client/ControllerChatHandler.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/client/IndexerControllerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/client/IndexerWorkerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/client/SketchResponseHandler.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/client/WorkerChatHandler.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/DataSourceMSQDestination.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/DurableStorageMSQDestination.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/ExportMSQDestination.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/MSQDestination.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/MSQSelectDestination.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/MSQTerminalStageSpecFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/SegmentGenerationStageSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/SegmentGenerationTerminalStageSpecFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/SegmentGenerationUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/TaskReportMSQDestination.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/destination/TerminalStageSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/BaseMSQFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/BroadcastTablesTooLargeFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/CanceledFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/CancellationReason.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/CannotParseExternalDataFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/ColumnNameRestrictedFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/ColumnTypeNotSupportedFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/DurableStorageConfigurationFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/FaultsExceededChecker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotAllocateSegmentFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotBeEmptyFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/InsertLockPreemptedFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/InsertTimeNullFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/InsertTimeOutOfBoundsFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/InvalidFieldFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/InvalidNullByteFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/MSQErrorReport.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/MSQException.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/MSQFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/MSQFaultUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportPublisher.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportSimplePublisher.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/MSQWarnings.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/NotEnoughMemoryFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/NotEnoughTemporaryStorageFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/QueryNotSupportedFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/QueryRuntimeFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/RowTooLargeFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TaskStartTimeoutFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyAttemptsForJob.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyAttemptsForWorker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyBucketsFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyClusteredByColumnsFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyColumnsFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyInputFilesFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyPartitionsFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyRowsInAWindowFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyRowsWithSameKeyFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManySegmentsInTimeChunkFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyWarningsFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/TooManyWorkersFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/UnknownFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/WorkerFailedFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/error/WorkerRpcFailedFault.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/processor/KeyStatisticsCollectionProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/processor/SegmentGeneratorFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/processor/SegmentGeneratorStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/report/MSQResultsReport.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/report/MSQSegmentReport.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/report/MSQStagesReport.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/report/MSQStatusReport.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/report/MSQTaskReport.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/indexing/report/MSQTaskReportPayload.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/InputSlice.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/InputSliceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/InputSlices.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/InputSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/InputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/InputSpecSlicerFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/InputSpecs.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/MapInputSliceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/MapInputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/NilInputSlice.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/NilInputSliceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/NilInputSource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/ParseExceptionUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/ReadableInput.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/ReadableInputs.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/SlicerUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/external/ExternalInputSlice.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/external/ExternalInputSliceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/external/ExternalInputSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/external/ExternalInputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/external/ExternalSegment.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/inline/InlineInputSlice.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/inline/InlineInputSliceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/inline/InlineInputSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/inline/InlineInputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/lookup/LookupInputSlice.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/lookup/LookupInputSliceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/lookup/LookupInputSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/lookup/LookupInputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/CollectedReadablePartitions.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/CombinedReadablePartitions.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/InputChannels.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/ReadablePartition.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/ReadablePartitions.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/SparseStripedReadablePartitions.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/StageInputSlice.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/StageInputSliceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/StageInputSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/StageInputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/stage/StripedReadablePartitions.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/table/DataSegmentWithLocation.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/table/DataServerRequestDescriptor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/table/DataServerSelector.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/table/RichSegmentDescriptor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/table/SegmentWithDescriptor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/table/SegmentsInputSlice.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/table/SegmentsInputSliceReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/input/table/TableInputSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/GlobalSortMaxCountShuffleSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/GlobalSortShuffleSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/GlobalSortTargetSizeShuffleSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/HashShuffleSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/LimitHintJsonIncludeFilter.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/MixShuffleSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/NilExtraInfoHolder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/QueryDefinition.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/QueryDefinitionBuilder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/ShuffleKind.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/ShuffleSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/StageDefinition.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/StageDefinitionBuilder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/StageId.java (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/StagePartition.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/WorkOrder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/WorkerAssignmentStrategy.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernel.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelConfig.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStagePhase.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/controller/ControllerWorkerStagePhase.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/controller/StageGroup.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/controller/WorkerInputs.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/worker/WorkerStageKernel.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/kernel/worker/WorkerStagePhase.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/DruidLogicalToQueryDefinitionTranslator.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/LogicalInputSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/StageMaker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/AbstractFrameProcessorStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/AbstractLogicalStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/AbstractShuffleStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/FilterStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/GroupByStages.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/LogicalStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/OffsetLimitStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/ProjectStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/ReadStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/logical/stages/SortStage.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/BaseLeafFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/BaseLeafFrameProcessorManager.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/BaseLeafStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/BroadcastJoinSegmentMapFnProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/ChainedProcessorManager.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/DataSegmentProvider.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/DataSourcePlan.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/InputNumberDataSource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/LazyResourceHolder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/MultiQueryKit.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/QueryKit.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/QueryKitSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/QueryKitUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/RestrictedInputNumberDataSource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/ShuffleSpecFactories.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/ShuffleSpecFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/SimpleSegmentMapFnProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/WindowOperatorQueryFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/WindowOperatorQueryKit.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/WindowOperatorQueryStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/common/OffsetLimitFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/common/OffsetLimitStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/common/SortMergeJoinFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/common/SortMergeJoinStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPostShuffleFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPostShuffleStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPreShuffleFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPreShuffleStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByQueryKit.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/results/ExportResultsFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/results/ExportResultsStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/results/QueryResultStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/results/QueryResultsFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/scan/ExternalColumnSelectorFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryFrameProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryKit.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryStageProcessor.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/rpc/BaseWorkerClientImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/rpc/ControllerResource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/rpc/MSQResourceUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/rpc/ResourcePermissionMapper.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/rpc/SketchEncoding.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/rpc/WorkerResource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/input/DurableStorageInputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/input/DurableStorageQueryResultsInputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/input/DurableStorageStageInputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/input/MetaInputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/input/WorkerInputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/input/WorkerOrLocalInputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/ByteChunksInputStream.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/ChannelStageOutputReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/DurableStorageOutputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/DurableStorageQueryResultsOutputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/DurableStorageTaskOutputChannelFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/FileStageOutputReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/FutureReadableFrameChannel.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/NilStageOutputReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/StageOutputHolder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/shuffle/output/StageOutputReader.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/DartQueryKitSpecFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/MSQMode.java (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/MSQTaskQueryKitSpecFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/MSQTaskQueryMaker.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/MSQTaskSqlEngine.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/SqlStatementState.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/entity/ColumnNameAndTypes.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/entity/PageInformation.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/entity/ResultSetInformation.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/entity/SqlStatementResult.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/resources/SqlStatementResource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/sql/resources/SqlTaskResource.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollector.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollectorImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsSnapshot.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/CompleteKeyStatisticsInformation.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollector.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorSnapshot.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/DistinctKeyCollector.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/DistinctKeyCollectorFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/DistinctKeySnapshot.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/KeyCollector.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/KeyCollectorFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/KeyCollectorSnapshot.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/KeyCollectors.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/PartialKeyStatisticsInformation.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollector.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorSnapshot.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/serde/ClusterByStatisticsSnapshotSerde.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/serde/DelegateOrMinSerializer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/serde/DistinctSnapshotSerializer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/serde/KeyCollectorSnapshotDeserializer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/serde/KeyCollectorSnapshotSerializer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/statistics/serde/QuantilesSnapshotSerializer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/ArrayIngestMode.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/DecoratedExecutorService.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/DimensionSchemaUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/IntervalUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/MSQFutureUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/MSQMetricUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/MSQTaskQueryMakerUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/PassthroughAggregator.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/PassthroughAggregatorFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/SequenceUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/SqlStatementResourceHelper.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/java/org/apache/druid/msq/util/SupplierIterator.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/main/resources/log4j2.xml (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/counters/CountersSnapshotTreeTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/counters/CpuCountersTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/counters/SegmentGenerationProgressCounterTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/controller/DartControllerContextTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/controller/DartTableInputSpecSlicerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/controller/DartWorkerManagerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/controller/http/DartQueryInfoTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/controller/http/DartSqlResourceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/controller/messages/ControllerMessageTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/controller/sql/DartSqlClientImplTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/worker/DartProcessingBuffersProviderTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/worker/DartQueryableSegmentTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/worker/DartWorkerRunnerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/worker/WorkerIdTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/worker/http/DartWorkerInfoTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/dart/worker/http/GetWorkersResponseTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/ControllerImplTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/ControllerMemoryParametersTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/DataServerQueryHandlerUtilsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQArraysTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQComplexGroupByTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQDataSketchesTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQDrillWindowQueryTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQExportTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQFaultsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQInsertTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQLoadedSegmentTests.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQParseExceptionsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQReplaceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQSelectTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQTasksTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/MSQWindowTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/ProcessingBuffersSetTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/QueryValidatorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/ResultsContextSerdeTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/RunWorkOrderTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcherTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/TaskDataSegmentProviderTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/TestMSQSqlModule.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/WorkerImplTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/WorkerMemoryParametersTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/WorkerRunRefTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/WorkerSketchFetcherTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/exec/WorkerStorageParametersTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/ColumnMappingTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/DurableStorageCleanerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/IndexerDataServerQueryHandlerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQCompactionRunnerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQControllerTaskTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQPartitionAssignmentTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQSpecCompatTest.java
(98%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQSpecTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQTaskListTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQTuningConfigTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQWorkerTaskLauncherRetryTests.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQWorkerTaskLauncherTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/MSQWorkerTaskTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/PeriodicControllerCheckerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/TaskReportQueryListenerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/WorkerChatHandlerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/client/ControllerChatHandlerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/destination/DataSourceMSQDestinationTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/destination/ExportMSQDestinationTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/error/CanceledFaultTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/error/InsertLockPreemptedFaultTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/error/MSQErrorReportTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/error/MSQFaultSerdeTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/error/MSQWarningsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/indexing/report/MSQTaskReportTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/InputSpecsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/NilInputSliceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/external/ExternalInputSliceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/external/ExternalInputSpecSlicerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/external/ExternalInputSpecTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/external/NilInputSourceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/inline/InlineInputSliceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/inline/InlineInputSpecTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/lookup/LookupInputSliceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/lookup/LookupInputSpecTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/stage/CollectedReadablePartitionsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/stage/CombinedReadablePartitionsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/stage/ReadablePartitionTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/stage/SparseStripedReadablePartitionsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/stage/StageInputSliceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/stage/StageInputSpecSlicerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/stage/StageInputSpecTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/stage/StripedReadablePartitionsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/table/DataServerRequestDescriptorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/table/IndexerTableInputSpecSlicerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/table/RichSegmentDescriptorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/table/SegmentWithDescriptorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/table/SegmentsInputSliceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/input/table/TableInputSpecTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/QueryDefinitionTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/StageDefinitionTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/StageIdTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/WorkOrderTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/BaseControllerQueryKernelTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelConfigTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelUtilsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSlice.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSpec.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSpecSlicer.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/MockQueryDefinitionBuilder.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/NonShufflingWorkersWithRetryKernelTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/ShufflingWorkersWithRetryKernelTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/kernel/controller/WorkerInputsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/BroadcastJoinSegmentMapFnProcessorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/ChainedProcessorManagerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/FrameProcessorTestBase.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/NonFailingWritableFrameChannel.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/RestrictedInputNumberDataSourceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/WindowOperatorQueryFrameProcessorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/WindowOperatorQueryStageProcessorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/common/SortMergeJoinFrameProcessorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/common/SortMergeJoinStageProcessorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/results/ExportResultsStageProcessorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/results/QueryResultsFrameProcessorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/querykit/scan/ScanQueryFrameProcessorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/quidem/MSQQuidemTest.java
(90%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/rpc/BaseWorkerClientImplTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/shuffle/DurableStorageOutputChannelFactoryTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/shuffle/output/ByteChunksInputStreamTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/shuffle/output/ChannelStageOutputReaderTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/shuffle/output/NilStageOutputReaderTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/sql/MSQModeTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/sql/MSQTaskQueryMakerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/sql/entity/ColumnNameAndTypesTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/sql/entity/ResultSetInformationTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/sql/entity/SqlStatementResultTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/sql/resources/SqlMSQStatementResourcePostTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/sql/resources/SqlStatementResourceTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/ByteRowKeySerdeTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollectorImplTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/DistinctKeyCollectorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/KeyCollectorTestUtils.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/PartialKeyStatisticsInformationSerdeTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorSnapshotTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/SendPartialKeyStatisticsInformationSerdeTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/statistics/serde/KeyCollectorSnapshotSerializerTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/AbstractMSQComponentSupplierDelegate.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/AllDruidEnginesComponentSupplier.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/CalciteArraysQueryMSQTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/CalciteDartTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/CalciteMSQTestsHelper.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/CalciteNestedDataQueryMSQTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/CalciteSelectQueryMSQTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/CalciteUnionQueryMSQTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/CounterSnapshotMatcher.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/DartComponentSupplier.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/DecoupledCalciteDartTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/DecoupledDartCalciteQueryTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/DecoupledDartExtension.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/ExtractResultsFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/LimitedFrameWriterFactory.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQCalciteSelectJoinQueryTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestBase.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestControllerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestControllerContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestDelegateDataSegmentPusher.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestOverlordServiceClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestSegmentManager.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestTaskActionClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestWorkerClient.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/MSQTestWorkerContext.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/NoopQueryListener.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/StandardAndMSQComponentSupplier.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/StandardMSQComponentSupplier.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/TestDartControllerContextFactoryImpl.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/test/VerifyMSQSupportedNativeQueriesPredicate.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/util/DimensionSchemaUtilsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/util/IntervalUtilsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/util/MSQFaultUtilsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/util/MSQTaskQueryMakerUtilsTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/util/MultiStageQueryContextTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/util/PassthroughAggregatorFactoryTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/msq/util/SqlStatementResourceHelperTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/sql/avatica/DartDruidMeta.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/sql/avatica/MSQDruidMeta.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/java/org/apache/druid/sql/calcite/NotYetSupportedUsageTest.java
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/quidem/org.apache.druid.msq.quidem.MSQQuidemTest/dart.iq
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/quidem/org.apache.druid.msq.quidem.MSQQuidemTest/msq1.iq
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/quidem/org.apache.druid.msq.quidem.MSQQuidemTest/msq2.iq
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/quidem/org.apache.druid.msq.quidem.MSQQuidemTest/msqJoinHint.iq
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/quidem/org.apache.druid.msq.quidem.MSQQuidemTest/msqNestedJoinHint.iq
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/dataset-with-time-column.json (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/multipleFiles/wikipedia-sampled-1.json
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/multipleFiles/wikipedia-sampled-2.json
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/multipleFiles/wikipedia-sampled-3.json
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/org.apache.druid.msq.indexing.MSQSpecCompatTest/testBuilder1.json
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/org.apache.druid.msq.indexing.MSQSpecCompatTest/testBuilder2.json
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/org.apache.druid.msq.indexing.MSQSpecCompatTest/testComplexMSQSpec.json
(100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/unparseable-mv-string-array.json (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/unparseable-null-byte-string.csv (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/unparseable.gz (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/wikipedia-sampled-unparsable.json (100%)
rename {extensions-core/multi-stage-query =>
multi-stage-query}/src/test/resources/wikipedia-sampled.json (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]