This is an automated email from the ASF dual-hosted git repository.
gian pushed a change to branch kll_sketch
in repository https://gitbox.apache.org/repos/asf/druid.git
from 56db1ff9ec Merge branch 'kll_sketch' of github.com:apache/druid into
kll_sketch pulled from remote
add d7d15ba51f Add druid-multi-stage-query extension. (#12918)
add 31eda58e9a Fix misspelling in license.md (#12941)
add 3b58a01c7c Correct spelling in messages and variable names. (#12932)
add 0bc9f9f303 #12912 Fix KafkaEmitter not emitting queryType for a native
query (#12915)
add cfed036091 Add the new integration test framework (#12368)
add f7c6316992 Setting useNativeQueryExplain to true (#12936)
add c1a75fca3c Docs: fix doc footer (#12943)
add 35aaaa9573 Fix serialization in TaskReportFileWriters. (#12938)
add 02914c17b9 Tutorial on ingesting and querying Theta sketches (#12723)
add 04ee7abeff Web console: Multi-stage query support (#12919)
add 31db3beed8 Fixing json creator for s3 storage connector provider
(#12948)
add 599bdde02a Update asf-release-process-guide.md (#12966)
add 82ad927087 tighten up array handling, fix bug with array_slice output
type inference (#12914)
add 8ee8786d3c add maxBytesInMemory and maxClientResponseBytes to
SamplerConfig (#12947)
add 9cc30ee120 Suppressing CVE-2022-25168 - hadoop-common-2.8.5.jar
(#12970)
add 31dc9004bd Auto-reload TLS certs for druid endpoints (#12933)
add fd6cfcb8fb Web console: fix pagination, add error delimiters (#12969)
add 7a1e1f88bb Remove experimental note from stable features (#12973)
add c54128ab8a Merge branch 'master' into kll_sketch
No new revisions were added by this update.
Summary of changes:
.gitignore | 2 +-
.travis.yml | 52 +-
codestyle/spotbugs-exclude.xml | 7 +
.../org/apache/druid/common/utils/IdUtils.java | 4 +-
.../input/impl/InputEntityIteratingReader.java | 4 +-
.../main/java/org/apache/druid/guice/PolyBind.java | 19 +-
.../java/util/common/parsers/ObjectFlatteners.java | 2 +-
.../apache/druid/java/util/emitter/core/Event.java | 4 +-
.../druid/java/util/emitter/core/EventMap.java | 109 +
.../java/util/emitter/core/EventMapSerializer.java | 40 +
.../java/util/emitter/service/AlertEvent.java | 6 +-
.../util/emitter/service/ServiceMetricEvent.java | 45 +-
.../org/apache/druid/math/expr/ApplyFunction.java | 20 +-
.../java/org/apache/druid/math/expr/Evals.java | 15 +-
.../java/org/apache/druid/math/expr/ExprEval.java | 278 +--
.../java/org/apache/druid/math/expr/Function.java | 66 +-
.../expr/vector/CastToStringVectorProcessor.java | 12 +-
.../metadata/MetadataStorageConnectorConfig.java | 2 +
.../metadata/MetadataStorageTablesConfig.java | 2 +
.../apache/druid/segment/column/ColumnType.java | 59 +
.../org/apache/druid/segment/column/ValueType.java | 31 +-
.../input/impl/InputEntityIteratingReaderTest.java | 2 +-
.../PrefetchableTextFilesFirehoseFactoryTest.java | 3 +
.../java/org/apache/druid/guice/PolyBindTest.java | 8 +-
.../util/common/parsers/ObjectFlattenersTest.java | 4 +
.../druid/java/util/emitter/core/IntEvent.java | 4 +-
.../emitter/service/ServiceMetricEventTest.java | 1 +
.../druid/java/util/emitter/service/UnitEvent.java | 15 +-
.../java/util/http/client/FriendlyServersTest.java | 3 +
.../org/apache/druid/math/expr/ExprEvalTest.java | 11 +-
dev/license.md | 2 +-
distribution/asf-release-process-guide.md | 56 +-
distribution/pom.xml | 6 +
docs/assets/tutorial-theta-01.png | Bin 0 -> 160923 bytes
docs/assets/tutorial-theta-02.png | Bin 0 -> 149124 bytes
docs/assets/tutorial-theta-03.png | Bin 0 -> 183232 bytes
docs/assets/tutorial-theta-04.png | Bin 0 -> 162593 bytes
docs/assets/tutorial-theta-05.png | Bin 0 -> 215624 bytes
docs/assets/tutorial-theta-06.png | Bin 0 -> 146114 bytes
docs/assets/tutorial-theta-07.png | Bin 0 -> 125992 bytes
docs/assets/tutorial-theta-08.png | Bin 0 -> 70597 bytes
docs/assets/tutorial-theta-09.png | Bin 0 -> 86495 bytes
docs/assets/tutorial-theta-10.png | Bin 0 -> 86440 bytes
docs/assets/tutorial-theta-11.png | Bin 0 -> 86126 bytes
docs/configuration/index.md | 2 +-
docs/design/router.md | 4 -
.../extensions-core/approximate-histograms.md | 8 +-
.../extensions-core/kafka-extraction-namespace.md | 2 -
.../development/extensions-core/kafka-ingestion.md | 2 -
.../extensions-core/lookups-cached-global.md | 3 -
docs/ingestion/data-formats.md | 2 -
docs/ingestion/native-batch.md | 4 +-
docs/ingestion/schema-design.md | 8 +-
docs/operations/tls-support.md | 2 +
docs/querying/lookups.md | 3 -
docs/querying/sql-query-context.md | 2 +-
docs/tutorials/tutorial-sketches-theta.md | 327 +++
.../cluster/_common/common.runtime.properties | 2 +-
.../master/coordinator-overlord/runtime.properties | 1 +
.../large/_common/common.runtime.properties | 2 +-
.../large/coordinator-overlord/runtime.properties | 1 +
.../medium/_common/common.runtime.properties | 2 +-
.../medium/coordinator-overlord/runtime.properties | 1 +
.../_common/common.runtime.properties | 2 +-
.../coordinator-overlord/runtime.properties | 1 +
.../_common/common.runtime.properties | 2 +-
.../coordinator-overlord/runtime.properties | 1 +
.../small/_common/common.runtime.properties | 2 +-
.../small/coordinator-overlord/runtime.properties | 1 +
.../xlarge/_common/common.runtime.properties | 2 +-
.../xlarge/coordinator-overlord/runtime.properties | 1 +
.../apache/druid/emitter/kafka/KafkaEmitter.java | 27 +-
.../opentelemetry/OpenTelemetryEmitterTest.java | 6 +-
.../druid/security/basic/CommonCacheNotifier.java | 2 +-
...natorPollingBasicAuthenticatorCacheManager.java | 2 +-
...orBasicAuthenticatorMetadataStorageUpdater.java | 2 +-
...rdinatorPollingBasicAuthorizerCacheManager.java | 4 +-
...natorBasicAuthorizerMetadataStorageUpdater.java | 2 +-
.../druid/indexing/kafka/KafkaSamplerSpecTest.java | 8 +-
.../kafka/supervisor/KafkaSupervisorTest.java | 2 +-
.../indexing/kinesis/KinesisSamplerSpecTest.java | 5 +-
.../kinesis/supervisor/KinesisSupervisorTest.java | 2 +-
extensions-core/multi-stage-query/README.md | 141 ++
extensions-core/multi-stage-query/pom.xml | 299 +++
.../apache/druid/msq/counters/ChannelCounters.java | 274 +++
.../apache/druid/msq/counters/CounterNames.java | 142 ++
.../druid/msq/counters/CounterSnapshots.java | 75 +
.../msq/counters/CounterSnapshotsSerializer.java | 55 +
.../druid/msq/counters/CounterSnapshotsTree.java | 104 +
.../apache/druid/msq/counters/CounterTracker.java | 74 +
.../apache/druid/msq/counters/QueryCounter.java | 32 +
.../druid/msq/counters/QueryCounterSnapshot.java | 31 +
.../SuperSorterProgressTrackerCounter.java | 71 +
.../apache/druid/msq/counters/WarningCounters.java | 94 +
.../java/org/apache/druid/msq/exec/Controller.java | 125 +
.../apache/druid/msq/exec/ControllerClient.java | 81 +
.../apache/druid/msq/exec/ControllerContext.java | 82 +
.../org/apache/druid/msq/exec/ControllerImpl.java | 2171 +++++++++++++++++
.../msq/exec/ExceptionWrappingWorkerClient.java | 145 ++
.../java/org/apache/druid/msq/exec/Limits.java | 61 +
.../java/org/apache/druid/msq/exec/MSQTasks.java | 216 ++
.../org/apache/druid/msq/exec/QueryValidator.java | 77 +
.../druid/msq/exec/TaskDataSegmentProvider.java | 115 +
.../java/org/apache/druid/msq/exec/Worker.java | 108 +
.../org/apache/druid/msq/exec/WorkerClient.java | 84 +
.../org/apache/druid/msq/exec/WorkerContext.java | 76 +
.../java/org/apache/druid/msq/exec/WorkerImpl.java | 1249 ++++++++++
.../apache/druid/msq/exec/WorkerManagerClient.java | 57 +
.../druid/msq/exec/WorkerMemoryParameters.java | 294 +++
.../druid/msq/guice/MSQDurableStorageModule.java | 86 +
.../msq/guice/MSQExternalDataSourceModule.java | 52 +
.../apache/druid/msq/guice/MSQIndexingModule.java | 201 ++
.../druid/msq/guice/MSQServiceClientModule.java | 86 +
.../org/apache/druid/msq/guice/MSQSqlModule.java | 60 +
.../apache/druid/msq/guice/MultiStageQuery.java | 34 +
.../org/apache/druid/msq/guice/SqlTaskModule.java | 53 +
.../apache/druid/msq/indexing/ColumnMapping.java | 82 +
.../apache/druid/msq/indexing/ColumnMappings.java | 144 ++
.../druid/msq/indexing/ControllerChatHandler.java | 194 ++
.../msq/indexing/CountableInputSourceReader.java | 58 +
.../msq/indexing/CountingOutputChannelFactory.java | 64 +
.../msq/indexing/CountingReadableFrameChannel.java | 75 +
.../msq/indexing/CountingWritableFrameChannel.java | 71 +
.../msq/indexing/DataSourceMSQDestination.java | 163 ++
.../msq/indexing/IndexerControllerClient.java | 182 ++
.../msq/indexing/IndexerControllerContext.java | 123 +
.../druid/msq/indexing/IndexerFrameContext.java | 120 +
.../druid/msq/indexing/IndexerWorkerClient.java | 271 +++
.../druid/msq/indexing/IndexerWorkerContext.java | 296 +++
.../msq/indexing/IndexerWorkerManagerClient.java | 81 +
.../druid/msq/indexing/InputChannelFactory.java | 38 +
.../druid/msq/indexing/InputChannelsImpl.java | 211 ++
.../indexing/KeyStatisticsCollectionProcessor.java | 183 ++
.../druid/msq/indexing/MSQControllerTask.java | 222 ++
.../apache/druid/msq/indexing/MSQDestination.java | 33 +
.../druid/msq/indexing/MSQPartitionAssignment.java | 96 +
.../org/apache/druid/msq/indexing/MSQSpec.java | 160 ++
.../org/apache/druid/msq/indexing/MSQTaskList.java | 71 +
.../apache/druid/msq/indexing/MSQTuningConfig.java | 140 ++
.../apache/druid/msq/indexing/MSQWorkerTask.java | 115 +
.../druid/msq/indexing/MSQWorkerTaskLauncher.java | 487 ++++
.../indexing/SegmentGeneratorFrameProcessor.java | 295 +++
.../SegmentGeneratorFrameProcessorFactory.java | 373 +++
.../msq/indexing/TaskReportMSQDestination.java | 45 +
.../druid/msq/indexing/WorkerChatHandler.java | 222 ++
.../druid/msq/indexing/error/BaseMSQFault.java | 121 +
.../error/BroadcastTablesTooLargeFault.java | 72 +
.../druid/msq/indexing/error/CanceledFault.java | 41 +
.../error/CannotParseExternalDataFault.java | 35 +
.../indexing/error/ColumnNameRestrictedFault.java | 75 +
.../error/ColumnTypeNotSupportedFault.java | 89 +
.../error/DurableStorageConfigurationFault.java | 80 +
.../msq/indexing/error/FaultsExceededChecker.java | 92 +
.../error/InsertCannotAllocateSegmentFault.java | 82 +
.../indexing/error/InsertCannotBeEmptyFault.java | 72 +
.../error/InsertCannotOrderByDescendingFault.java | 72 +
.../InsertCannotReplaceExistingSegmentFault.java | 76 +
.../indexing/error/InsertLockPreemptedFault.java | 45 +
.../msq/indexing/error/InsertTimeNullFault.java | 42 +
.../indexing/error/InsertTimeOutOfBoundsFault.java | 66 +
.../msq/indexing/error/InvalidNullByteFault.java | 71 +
.../druid/msq/indexing/error/MSQErrorReport.java | 200 ++
.../druid/msq/indexing/error/MSQException.java | 51 +
.../apache/druid/msq/indexing/error/MSQFault.java | 49 +
.../error/MSQWarningReportLimiterPublisher.java | 96 +
.../indexing/error/MSQWarningReportPublisher.java | 35 +
.../error/MSQWarningReportSimplePublisher.java | 72 +
.../druid/msq/indexing/error/MSQWarnings.java | 36 +
.../msq/indexing/error/NotEnoughMemoryFault.java | 108 +
.../msq/indexing/error/QueryNotSupportedFault.java | 41 +
.../druid/msq/indexing/error/RowTooLargeFault.java | 69 +
.../msq/indexing/error/TaskStartTimeoutFault.java | 76 +
.../msq/indexing/error/TooManyBucketsFault.java | 77 +
.../msq/indexing/error/TooManyColumnsFault.java | 80 +
.../msq/indexing/error/TooManyInputFilesFault.java | 102 +
.../msq/indexing/error/TooManyPartitionsFault.java | 74 +
.../msq/indexing/error/TooManyWarningsFault.java | 80 +
.../msq/indexing/error/TooManyWorkersFault.java | 89 +
.../druid/msq/indexing/error/UnknownFault.java | 84 +
.../msq/indexing/error/WorkerFailedFault.java | 86 +
.../msq/indexing/error/WorkerRpcFailedFault.java | 69 +
.../msq/indexing/report/MSQResultsReport.java | 84 +
.../druid/msq/indexing/report/MSQStagesReport.java | 248 ++
.../druid/msq/indexing/report/MSQStatusReport.java | 135 ++
.../druid/msq/indexing/report/MSQTaskReport.java | 64 +
.../msq/indexing/report/MSQTaskReportPayload.java | 85 +
.../org/apache/druid/msq/input/InputSlice.java | 40 +
.../apache/druid/msq/input/InputSliceReader.java | 50 +
.../org/apache/druid/msq/input/InputSlices.java | 65 +
.../java/org/apache/druid/msq/input/InputSpec.java | 30 +
.../apache/druid/msq/input/InputSpecSlicer.java | 50 +
.../druid/msq/input/InputSpecSlicerFactory.java | 36 +
.../org/apache/druid/msq/input/InputSpecs.java | 50 +
.../druid/msq/input/MapInputSliceReader.java | 70 +
.../apache/druid/msq/input/MapInputSpecSlicer.java | 73 +
.../org/apache/druid/msq/input/NilInputSlice.java | 60 +
.../druid/msq/input/NilInputSliceReader.java | 55 +
.../org/apache/druid/msq/input/NilInputSource.java | 90 +
.../org/apache/druid/msq/input/ReadableInput.java | 112 +
.../org/apache/druid/msq/input/ReadableInputs.java | 92 +
.../org/apache/druid/msq/input/SlicerUtils.java | 129 +
.../msq/input/external/ExternalInputSlice.java | 111 +
.../input/external/ExternalInputSliceReader.java | 243 ++
.../msq/input/external/ExternalInputSpec.java | 106 +
.../input/external/ExternalInputSpecSlicer.java | 166 ++
.../input/stage/CollectedReadablePartitions.java | 126 +
.../input/stage/CombinedReadablePartitions.java | 111 +
.../druid/msq/input/stage/InputChannels.java | 42 +
.../druid/msq/input/stage/ReadablePartition.java | 118 +
.../druid/msq/input/stage/ReadablePartitions.java | 100 +
.../druid/msq/input/stage/StageInputSlice.java | 96 +
.../msq/input/stage/StageInputSliceReader.java | 96 +
.../druid/msq/input/stage/StageInputSpec.java | 75 +
.../msq/input/stage/StageInputSpecSlicer.java | 82 +
.../msq/input/stage/StripedReadablePartitions.java | 132 ++
.../msq/input/table/RichSegmentDescriptor.java | 119 +
.../msq/input/table/SegmentWithDescriptor.java | 78 +
.../druid/msq/input/table/SegmentsInputSlice.java | 103 +
.../msq/input/table/SegmentsInputSliceReader.java | 100 +
.../druid/msq/input/table/TableInputSpec.java | 130 ++
.../msq/input/table/TableInputSpecSlicer.java | 196 ++
.../apache/druid/msq/kernel/ExtraInfoHolder.java | 80 +
.../org/apache/druid/msq/kernel/FrameContext.java | 60 +
.../druid/msq/kernel/FrameProcessorFactory.java | 105 +
.../druid/msq/kernel/MaxCountShuffleSpec.java | 137 ++
.../druid/msq/kernel/NilExtraInfoHolder.java | 40 +
.../druid/msq/kernel/ProcessorsAndChannels.java | 54 +
.../apache/druid/msq/kernel/QueryDefinition.java | 169 ++
.../druid/msq/kernel/QueryDefinitionBuilder.java | 87 +
.../org/apache/druid/msq/kernel/ShuffleSpec.java | 72 +
.../apache/druid/msq/kernel/StageDefinition.java | 353 +++
.../druid/msq/kernel/StageDefinitionBuilder.java | 126 +
.../java/org/apache/druid/msq/kernel/StageId.java | 115 +
.../apache/druid/msq/kernel/StagePartition.java | 86 +
.../druid/msq/kernel/TargetSizeShuffleSpec.java | 132 ++
.../org/apache/druid/msq/kernel/WorkOrder.java | 143 ++
.../druid/msq/kernel/WorkerAssignmentStrategy.java | 119 +
.../kernel/controller/ControllerQueryKernel.java | 546 +++++
.../kernel/controller/ControllerStagePhase.java | 118 +
.../kernel/controller/ControllerStageTracker.java | 412 ++++
.../druid/msq/kernel/controller/WorkerInputs.java | 179 ++
.../druid/msq/kernel/worker/WorkerStageKernel.java | 217 ++
.../druid/msq/kernel/worker/WorkerStagePhase.java | 87 +
.../msq/querykit/BaseFrameProcessorFactory.java | 72 +
.../druid/msq/querykit/BaseLeafFrameProcessor.java | 216 ++
.../querykit/BaseLeafFrameProcessorFactory.java | 307 +++
.../druid/msq/querykit/BroadcastJoinHelper.java | 205 ++
.../druid/msq/querykit/DataSegmentProvider.java | 37 +
.../msq/querykit/DataSegmentTimelineView.java | 49 +
.../apache/druid/msq/querykit/DataSourcePlan.java | 384 +++
.../druid/msq/querykit/InputNumberDataSource.java | 116 +
.../druid/msq/querykit/LazyResourceHolder.java | 73 +
.../apache/druid/msq/querykit/MultiQueryKit.java | 68 +
.../org/apache/druid/msq/querykit/QueryKit.java | 52 +
.../apache/druid/msq/querykit/QueryKitUtils.java | 222 ++
.../druid/msq/querykit/ShuffleSpecFactories.java | 51 +
.../druid/msq/querykit/ShuffleSpecFactory.java | 35 +
.../querykit/common/OffsetLimitFrameProcessor.java | 168 ++
.../common/OffsetLimitFrameProcessorFactory.java | 162 ++
.../groupby/GroupByPostShuffleFrameProcessor.java | 324 +++
.../GroupByPostShuffleFrameProcessorFactory.java | 131 ++
.../groupby/GroupByPreShuffleFrameProcessor.java | 245 ++
.../GroupByPreShuffleFrameProcessorFactory.java | 80 +
.../msq/querykit/groupby/GroupByQueryKit.java | 302 +++
.../msq/querykit/scan/ScanQueryFrameProcessor.java | 316 +++
.../scan/ScanQueryFrameProcessorFactory.java | 96 +
.../druid/msq/querykit/scan/ScanQueryKit.java | 173 ++
.../druid/msq/rpc/CoordinatorServiceClient.java | 40 +
.../msq/rpc/CoordinatorServiceClientImpl.java | 90 +
.../shuffle/DurableStorageInputChannelFactory.java | 122 +
.../DurableStorageOutputChannelFactory.java | 142 ++
.../msq/shuffle/WorkerInputChannelFactory.java | 101 +
.../java/org/apache/druid/msq/sql/MSQMode.java | 81 +
.../apache/druid/msq/sql/MSQTaskQueryMaker.java | 298 +++
.../org/apache/druid/msq/sql/MSQTaskSqlEngine.java | 299 +++
.../org/apache/druid/msq/sql/SqlTaskResource.java | 336 +++
.../org/apache/druid/msq/sql/SqlTaskStatus.java | 104 +
.../statistics/ClusterByStatisticsCollector.java | 97 +
.../ClusterByStatisticsCollectorImpl.java | 440 ++++
.../statistics/ClusterByStatisticsSnapshot.java | 133 ++
.../msq/statistics/DelegateOrMinKeyCollector.java | 170 ++
.../DelegateOrMinKeyCollectorFactory.java | 122 +
.../DelegateOrMinKeyCollectorSnapshot.java | 87 +
.../druid/msq/statistics/DistinctKeyCollector.java | 305 +++
.../statistics/DistinctKeyCollectorFactory.java | 87 +
.../druid/msq/statistics/DistinctKeySnapshot.java | 94 +
.../apache/druid/msq/statistics/KeyCollector.java | 77 +
.../druid/msq/statistics/KeyCollectorFactory.java | 46 +
.../druid/msq/statistics/KeyCollectorSnapshot.java | 27 +
.../KeyCollectorSnapshotDeserializerModule.java | 34 +
.../apache/druid/msq/statistics/KeyCollectors.java | 51 +
.../statistics/QuantilesSketchKeyCollector.java | 168 ++
.../QuantilesSketchKeyCollectorFactory.java | 149 ++
.../QuantilesSketchKeyCollectorSnapshot.java | 61 +
.../msq/statistics/TooManyBucketsException.java | 38 +
.../druid/msq/util/DecoratedExecutorService.java | 162 ++
.../druid/msq/util/DimensionSchemaUtils.java | 70 +
.../org/apache/druid/msq/util/IntervalUtils.java | 64 +
.../org/apache/druid/msq/util/MSQFutureUtils.java | 70 +
.../druid/msq/util/MultiStageQueryContext.java | 237 ++
.../druid/msq/util/PassthroughAggregator.java | 78 +
.../msq/util/PassthroughAggregatorFactory.java | 208 ++
.../org/apache/druid/msq/util/SequenceUtils.java | 44 +
.../apache/druid/msq/util/SupplierIterator.java | 57 +
.../org.apache.druid.initialization.DruidModule | 21 +
.../src/main/resources/log4j2.xml | 38 +
.../apache/druid/msq/TestArrayStorageAdapter.java | 56 +
.../msq/counters/CountersSnapshotTreeTest.java | 49 +
.../org/apache/druid/msq/exec/MSQInsertTest.java | 661 ++++++
.../org/apache/druid/msq/exec/MSQReplaceTest.java | 506 ++++
.../org/apache/druid/msq/exec/MSQSelectTest.java | 1122 +++++++++
.../org/apache/druid/msq/exec/MSQTasksTest.java | 247 ++
.../apache/druid/msq/exec/QueryValidatorTest.java | 144 ++
.../druid/msq/exec/WorkerMemoryParametersTest.java | 116 +
.../druid/msq/indexing/ColumnMappingTest.java | 36 +
.../msq/indexing/DataSourceMSQDestinationTest.java | 37 +
.../msq/indexing/IndexerWorkerContextTest.java | 87 +
.../msq/indexing/MSQPartitionAssignmentTest.java | 57 +
.../org/apache/druid/msq/indexing/MSQSpecTest.java | 36 +
.../druid/msq/indexing/MSQTuningConfigTest.java | 64 +
.../error/InsertLockPreemptedFaultTest.java | 74 +
.../msq/indexing/error/MSQFaultSerdeTest.java | 97 +
.../druid/msq/indexing/error/MSQWarningsTest.java | 404 ++++
.../msq/indexing/report/MSQTaskReportTest.java | 214 ++
.../org/apache/druid/msq/input/InputSpecsTest.java | 43 +
.../apache/druid/msq/input/NilInputSliceTest.java | 50 +
.../msq/input/external/ExternalInputSliceTest.java | 65 +
.../external/ExternalInputSpecSlicerTest.java | 320 +++
.../msq/input/external/ExternalInputSpecTest.java | 63 +
.../stage/CollectedReadablePartitionsTest.java | 83 +
.../stage/CombinedReadablePartitionsTest.java | 95 +
.../msq/input/stage/ReadablePartitionTest.java | 32 +
.../druid/msq/input/stage/StageInputSliceTest.java | 54 +
.../msq/input/stage/StageInputSpecSlicerTest.java | 120 +
.../druid/msq/input/stage/StageInputSpecTest.java | 51 +
.../input/stage/StripedReadablePartitionsTest.java | 91 +
.../msq/input/table/RichSegmentDescriptorTest.java | 88 +
.../msq/input/table/SegmentWithDescriptorTest.java | 32 +
.../msq/input/table/SegmentsInputSliceTest.java | 63 +
.../msq/input/table/TableInputSpecSlicerTest.java | 493 ++++
.../druid/msq/input/table/TableInputSpecTest.java | 78 +
.../druid/msq/kernel/QueryDefinitionTest.java | 76 +
.../druid/msq/kernel/StageDefinitionTest.java | 35 +
.../org/apache/druid/msq/kernel/StageIdTest.java | 76 +
.../org/apache/druid/msq/kernel/WorkOrderTest.java | 35 +
.../controller/BaseControllerQueryKernelTest.java | 320 +++
.../controller/ControllerQueryKernelTests.java | 383 +++
.../controller/ControllerTestInputSlice.java | 31 +
.../kernel/controller/ControllerTestInputSpec.java | 26 +
.../controller/ControllerTestInputSpecSlicer.java | 57 +
.../controller/MockQueryDefinitionBuilder.java | 221 ++
.../msq/kernel/controller/WorkerInputsTest.java | 32 +
.../msq/querykit/BroadcastJoinHelperTest.java | 278 +++
.../java/org/apache/druid/msq/sql/MSQModeTest.java | 57 +
.../druid/msq/sql/MSQTaskQueryMakerTest.java | 53 +
.../apache/druid/msq/sql/SqlTaskStatusTest.java | 60 +
.../ClusterByStatisticsCollectorImplTest.java | 951 ++++++++
.../statistics/DelegateOrMinKeyCollectorTest.java | 152 ++
.../msq/statistics/DistinctKeyCollectorTest.java | 243 ++
.../msq/statistics/KeyCollectorTestUtils.java | 296 +++
.../QuantilesSketchKeyCollectorTest.java | 200 ++
.../org/apache/druid/msq/test/MSQTestBase.java | 1068 +++++++++
.../druid/msq/test/MSQTestControllerClient.java | 94 +
.../druid/msq/test/MSQTestControllerContext.java | 261 +++
.../msq/test/MSQTestDelegateDataSegmentPusher.java | 72 +
.../msq/test/MSQTestOverlordServiceClient.java | 119 +
.../druid/msq/test/MSQTestSegmentManager.java | 84 +
.../druid/msq/test/MSQTestTaskActionClient.java | 98 +
.../apache/druid/msq/test/MSQTestWorkerClient.java | 128 +
.../druid/msq/test/MSQTestWorkerContext.java | 183 ++
.../apache/druid/msq/util/IntervalUtilsTest.java | 91 +
.../druid/msq/util/MultiStageQueryContextTest.java | 191 ++
.../msq/util/PassthroughAggregatorFactoryTest.java | 77 +
.../src/test/resources/unparseable.gz | Bin 0 -> 538 bytes
.../resources/wikipedia-sampled-unparsable.json | 3 +
.../src/test/resources/wikipedia-sampled.json | 20 +
.../metadata/storage/mysql/MySQLConnector.java | 2 +-
.../storage/mysql/MySQLConnectorDriverConfig.java | 5 +-
.../s3/output/S3StorageConnectorProvider.java | 23 +-
.../storage/s3/S3StorageConnectorProviderTest.java | 158 ++
.../testing-tools}/.gitignore | 0
.../common/IngestionStatsAndErrorsTaskReport.java | 11 -
.../common/MultipleFileTaskReportFileWriter.java | 6 +-
.../common/SingleFileTaskReportFileWriter.java | 31 +-
.../druid/indexing/common/config/TaskConfig.java | 3 +-
.../druid/indexing/common/task/AbstractTask.java | 2 +-
.../apache/druid/indexing/overlord/TaskQueue.java | 4 +
.../overlord/sampler/InputSourceSampler.java | 45 +-
.../indexing/overlord/sampler/SamplerConfig.java | 54 +-
.../supervisor/SeekableStreamSupervisor.java | 2 +-
.../indexing/common/task/TaskReportSerdeTest.java | 23 +-
.../sampler/CsvInputSourceSamplerTest.java | 3 +-
.../overlord/sampler/InputSourceSamplerTest.java | 119 +-
integration-tests-ex/README.md | 115 +-
integration-tests-ex/{ => cases}/.gitignore | 0
integration-tests-ex/{ => cases}/assets/log4j2.xml | 0
integration-tests-ex/cases/cluster.sh | 201 ++
.../cases/cluster/BatchIndex/docker-compose.yaml | 98 +
.../cases/cluster/Common/dependencies.yaml | 166 ++
.../cases/cluster/Common/druid.yaml | 177 ++
.../cluster/Common/environment-configs/auth.env | 53 +
.../cluster/Common/environment-configs/broker.env | 53 +
.../cluster/Common/environment-configs/common.env | 117 +
.../Common/environment-configs/coordinator.env | 39 +
.../Common/environment-configs/historical.env | 30 +
.../cluster/Common/environment-configs/indexer.env | 35 +
.../Common/environment-configs/middlemanager.env | 37 +
.../Common/environment-configs/overlord.env | 30 +
.../cluster/Common/environment-configs/router.env | 37 +
.../cluster/HighAvailability/docker-compose.yaml | 157 ++
integration-tests-ex/cases/pom.xml | 374 +++
integration-tests-ex/cases/resources/README.md | 42 +
.../batch_index/avro/wikipedia_index_data1.avro | Bin
.../batch_index/avro/wikipedia_index_data2.avro | Bin
.../batch_index/avro/wikipedia_index_data3.avro | Bin
.../data/batch_index/csv/wikipedia_index_data1.csv | 0
.../data/batch_index/csv/wikipedia_index_data2.csv | 0
.../data/batch_index/csv/wikipedia_index_data3.csv | 0
.../data/batch_index/hadoop_tsv/batch_hadoop.data | 0
.../batch_index/json/wikipedia_index_data1.json | 0
.../batch_index/json/wikipedia_index_data2.json | 0
.../batch_index/json/wikipedia_index_data3.json | 0
.../data/batch_index/orc/wikipedia_index_data1.orc | Bin
.../data/batch_index/orc/wikipedia_index_data2.orc | Bin
.../data/batch_index/orc/wikipedia_index_data3.orc | Bin
.../parquet/wikipedia_index_data1.parquet | Bin
.../parquet/wikipedia_index_data2.parquet | Bin
.../parquet/wikipedia_index_data3.parquet | Bin
.../data/batch_index/tsv/wikipedia_index_data1.tsv | 0
.../data/batch_index/tsv/wikipedia_index_data2.tsv | 0
.../data/batch_index/tsv/wikipedia_index_data3.tsv | 0
.../indexer/wikipedia_combining_index_data.json | 0
.../wikipedia_index_queries_only_data3.json | 0
.../indexer/wikipedia_realtime_index_data.json | 0
.../druid/testsEx/categories/BatchIndex.java | 25 +
.../druid/testsEx/categories/HighAvailability.java | 25 +
.../druid/testsEx/cluster/DruidClusterClient.java | 340 +++
.../apache/druid/testsEx/cluster/KafkaClient.java | 83 +
.../druid/testsEx/cluster/MetastoreClient.java | 88 +
.../druid/testsEx/cluster/ZooKeeperClient.java | 89 +
.../org/apache/druid/testsEx/config/Cluster.java | 48 +
.../apache/druid/testsEx/config/ClusterConfig.java | 342 +++
.../druid/testsEx/config/ClusterConfigTest.java | 123 +
.../org/apache/druid/testsEx/config/Configure.java | 42 +
.../druid/testsEx/config/DruidTestRunner.java | 208 ++
.../apache/druid/testsEx/config/Initializer.java | 590 +++++
.../testsEx/config/IntegrationTestingConfigEx.java | 421 ++++
.../apache/druid/testsEx/config/KafkaConfig.java | 37 +
.../druid/testsEx/config/MetastoreConfig.java | 121 +
.../apache/druid/testsEx/config/MetastoreStmt.java | 78 +
.../druid/testsEx/config/ResolvedConfig.java | 406 ++++
.../druid/testsEx/config/ResolvedDruidService.java | 145 ++
.../druid/testsEx/config/ResolvedMetastore.java | 128 +
.../druid/testsEx/config/ResolvedService.java | 219 ++
.../apache/druid/testsEx/config/ServiceConfig.java | 116 +
.../druid/testsEx/config/ServiceInstance.java | 124 +
.../apache/druid/testsEx/config/TestConfigs.java | 66 +
.../testsEx/indexer/AbstractITBatchIndexTest.java | 502 ++++
.../druid/testsEx/indexer/AbstractIndexerTest.java | 188 ++
.../AbstractLocalInputSourceParallelIndexTest.java | 115 +
.../ITBestEffortRollupParallelIndexTest.java | 250 ++
.../ITCombiningFirehoseFactoryIndexTest.java | 101 +
.../ITCombiningInputSourceParallelIndexTest.java | 130 ++
.../druid/testsEx/indexer/ITIndexerTest.java | 386 +++
.../testsEx/indexer/ITOverwriteBatchIndexTest.java | 166 ++
.../indexer/ITSystemTableBatchIndexTaskTest.java | 72 +
.../druid/testsEx/indexer/ITTransformTest.java | 125 +
.../testsEx/leadership/ITHighAvailabilityTest.java | 246 ++
.../testsEx/utils/DruidClusterAdminClient.java | 328 +++
.../resources/cluster/AzureDeepStorage/docker.yaml | 58 +
.../test/resources/cluster/BatchIndex/docker.yaml | 40 +
.../src/test/resources/cluster/Common/kafka.yaml | 22 +
.../resources/cluster/Common/zk-metastore.yaml | 28 +
.../resources/cluster/HighAvailability/docker.yaml | 204 ++
.../cluster/HighAvailability/queries/sys.json | 0
.../cases/src/test/resources/config-test/test.yaml | 85 +
.../indexer/broadcast_join_index_task.json | 0
.../resources/indexer/json_path_index_queries.json | 0
.../resources/indexer/json_path_index_task.json | 0
.../resources/indexer/segment_metadata_query.json | 0
.../indexer/sparse_column_index_queries.json | 0
.../indexer/sparse_column_index_task.json | 0
.../sparse_column_with_dim_compaction_task.json | 0
.../sparse_column_without_dim_compaction_task.json | 0
.../indexer/sys_segment_batch_index_queries.json | 0
.../indexer/wikipedia_cloud_index_task.json | 0
.../indexer/wikipedia_cloud_simple_index_task.json | 0
...wikipedia_combining_firehose_index_queries.json | 0
.../wikipedia_combining_firehose_index_task.json | 0
...combining_input_source_index_parallel_task.json | 0
.../indexer/wikipedia_compaction_task.json | 0
...edia_compaction_task_with_granularity_spec.json | 0
...a_compaction_task_with_segment_granularity.json | 0
...ingestion_non_perfect_rollup_index_queries.json | 0
...ble_ingestion_perfect_rollup_index_queries.json | 0
.../wikipedia_http_inputsource_queries.json | 0
.../indexer/wikipedia_http_inputsource_task.json | 0
.../resources/indexer/wikipedia_index_queries.json | 0
...pedia_index_queries_hour_query_granularity.json | 0
.../wikipedia_index_queries_with_transform.json | 0
...pedia_index_queries_year_query_granularity.json | 0
.../indexer/wikipedia_index_rollup_queries.json | 0
.../resources/indexer/wikipedia_index_task.json | 0
.../wikipedia_index_task_with_dimension_spec.json | 0
...wikipedia_index_task_with_granularity_spec.json | 0
...edia_index_task_with_inputsource_transform.json | 0
.../wikipedia_index_task_with_transform.json | 0
...kipedia_index_with_merge_column_limit_task.json | 0
.../wikipedia_local_input_source_index_task.json | 0
.../indexer/wikipedia_merge_index_queries.json | 0
.../indexer/wikipedia_merge_index_task.json | 0
...edia_merge_reindex_druid_input_source_task.json | 0
.../indexer/wikipedia_merge_reindex_task.json | 0
.../wikipedia_override_credentials_index_task.json | 0
...dia_parallel_druid_input_source_index_task.json | 0
.../indexer/wikipedia_parallel_index_queries.json | 0
.../indexer/wikipedia_parallel_index_task.json | 0
...a_parallel_index_using_sqlinputsource_task.json | 0
...kipedia_parallel_ingest_segment_index_task.json | 0
.../wikipedia_parallel_reindex_queries.json | 0
.../indexer/wikipedia_parallel_reindex_task.json | 0
...ipedia_realtime_appenderator_index_queries.json | 0
...wikipedia_realtime_appenderator_index_task.json | 0
.../indexer/wikipedia_realtime_index_queries.json | 0
.../indexer/wikipedia_realtime_index_task.json | 0
.../wikipedia_reindex_druid_input_source_task.json | 0
...ex_druid_input_source_task_with_transforms.json | 0
.../indexer/wikipedia_reindex_queries.json | 0
.../wikipedia_reindex_queries_with_transforms.json | 0
.../resources/indexer/wikipedia_reindex_task.json | 0
.../wikipedia_reindex_task_with_transforms.json | 0
.../indexer/wikipedia_union_index_task.json | 0
.../wikipedia_with_timestamp_index_task.json | 0
.../resources/indexer/wikiticker_index_task.json | 0
integration-tests-ex/check-results.sh | 89 -
integration-tests-ex/docs/compose.md | 238 ++
integration-tests-ex/docs/conversion.md | 292 +++
integration-tests-ex/docs/debugging.md | 159 ++
integration-tests-ex/docs/dependencies.md | 239 ++
integration-tests-ex/docs/docker.md | 302 +++
integration-tests-ex/docs/druid-config.md | 138 ++
integration-tests-ex/docs/guide.md | 241 ++
integration-tests-ex/docs/history.md | 96 +
integration-tests-ex/docs/maven.md | 255 ++
integration-tests-ex/docs/next-steps.md | 77 +
integration-tests-ex/docs/quickstart.md | 201 ++
integration-tests-ex/docs/runtime.md | 105 +
integration-tests-ex/docs/scripts.md | 74 +
integration-tests-ex/docs/test-config.md | 588 +++++
integration-tests-ex/docs/tests.md | 411 ++++
integration-tests-ex/docs/travis.md | 168 ++
.../{it-image => image}/build-image.sh | 0
.../{it-image => image}/docker-build.sh | 0
.../{it-image => image}/docker/Dockerfile | 0
.../{it-image => image}/docker/druid.sh | 0
integration-tests-ex/image/docker/launch.sh | 130 ++
.../{it-image => image}/docker/test-setup.sh | 0
integration-tests-ex/image/pom.xml | 232 ++
.../{it-image => image}/rebuild.sh | 0
integration-tests-ex/it-image/docker/launch.sh | 104 -
integration-tests-ex/it-image/pom.xml | 231 --
.../it-image/scripts/build-shared.sh | 40 -
integration-tests-ex/it-tools/pom.xml | 155 --
integration-tests-ex/{it-tools => tools}/README.md | 0
integration-tests-ex/tools/pom.xml | 156 ++
.../druid/testing/tools/CliCustomNodeRole.java | 0
.../tools/CliHistoricalForQueryErrorTest.java | 0
.../testing/tools/CustomNodeRoleClientModule.java | 0
.../tools/CustomNodeRoleCommandCreator.java | 0
.../tools/QueryRetryTestCommandCreator.java | 0
.../tools/ServerManagerForQueryErrorTest.java | 0
.../apache/druid/testing/tools/SleepExprMacro.java | 0
.../apache/druid/testing/tools/SleepModule.java | 0
.../testing/tools/SleepOperatorConversion.java | 0
.../org/apache/druid/testing/tools/package.java | 0
.../org.apache.druid.cli.CliCommandCreator | 0
.../org.apache.druid.initialization.DruidModule | 0
integration-tests/README.md | 20 +-
integration-tests/pom.xml | 1 +
.../druid/cli/CustomNodeRoleCommandCreator.java | 1 +
.../druid/testing/ConfigFileConfigProvider.java | 3 +-
.../testing/IntegrationTestingConfigProvider.java | 1 +
.../clients/OverlordResourceTestClient.java | 2 +
.../druid/testing/guice/DruidTestModule.java | 2 +-
.../druid/tests/indexer/AbstractIndexerTest.java | 4 +
it.sh | 130 ++
licenses.yaml | 14 +-
licenses/bin/zustand.MIT | 21 +
owasp-dependency-check-suppressions.xml | 1 +
pom.xml | 25 +-
.../apache/druid/frame/write/FrameWriterUtils.java | 6 +-
.../druid/segment/filter/ExpressionFilter.java | 12 +-
.../segment/transform/ExpressionTransform.java | 8 +-
.../ExpressionMultiValueDimensionSelector.java | 44 +-
.../druid/segment/virtual/ExpressionSelectors.java | 94 +-
.../segment/virtual/ExpressionVirtualColumn.java | 8 +
.../java/org/apache/druid/query/QueriesTest.java | 24 +-
.../segment/virtual/ExpressionSelectorsTest.java | 19 +-
.../druid/discovery/BaseNodeRoleWatcher.java | 10 +-
.../apache/druid/guice/DruidInjectorBuilder.java | 40 +-
.../apache/druid/guice/MetadataConfigModule.java | 4 +-
.../initialization/ExtensionInjectorBuilder.java | 2 +-
.../query/lookup/LookupReferencesManager.java | 6 +-
.../server/initialization/TLSServerConfig.java | 18 +
.../initialization/jetty/JettyServerModule.java | 6 +
.../druid/server/log/DefaultRequestLogEvent.java | 32 +-
.../server/initialization/JettyCertRenewTest.java | 401 ++++
.../druid/server/log/AlertEventSerdeTest.java | 65 +
.../server/log/DefaultRequestLogEventTest.java | 177 ++
.../server/log/ServiceMetricEventSerdeTest.java | 58 +
server/src/test/resources/server-new.jks | Bin 0 -> 4047 bytes
server/src/test/resources/truststore-new.jks | Bin 0 -> 3248 bytes
.../java/org/apache/druid/cli/GuiceRunnable.java | 4 +-
.../builtin/ArrayContainsOperatorConversion.java | 7 +-
.../builtin/ArrayOverlapOperatorConversion.java | 8 +-
.../MultiValueStringOperatorConversions.java | 8 +-
.../sql/calcite/planner/DruidRexExecutor.java | 24 +-
.../druid/sql/calcite/planner/PlannerConfig.java | 2 +-
.../druid/sql/calcite/run/NativeQueryMaker.java | 19 +-
.../druid/sql/avatica/DruidAvaticaHandlerTest.java | 5 +-
.../druid/sql/calcite/CalciteExplainQueryTest.java | 25 +-
.../druid/sql/calcite/CalciteInsertDmlTest.java | 2 +-
.../calcite/CalciteMultiValueStringQueryTest.java | 16 +-
.../druid/sql/calcite/CalciteReplaceDmlTest.java | 2 +-
.../druid/sql/calcite/CalciteSelectQueryTest.java | 5 +
.../sql/calcite/run/NativeQueryMakerTest.java | 116 +
.../org/apache/druid/sql/http/SqlResourceTest.java | 14 +-
.../e2e-tests/component/datasources/overview.ts | 2 +-
.../e2e-tests/component/ingestion/overview.ts | 4 +-
.../e2e-tests/component/load-data/data-loader.ts | 2 +-
web-console/e2e-tests/component/query/overview.ts | 13 +-
.../e2e-tests/component/workbench/overview.ts | 47 +
web-console/e2e-tests/multi-stage-query.spec.ts | 72 +
web-console/lib/keywords.js | 7 +
web-console/lib/sql-docs.d.ts | 2 +-
web-console/package-lock.json | 421 ++--
web-console/package.json | 10 +-
web-console/script/create-sql-docs.js | 8 +-
web-console/script/druid | 2 +-
web-console/script/mv | 75 +
web-console/src/ace-modes/dsql.js | 4 +-
web-console/src/bootstrap/react-table-defaults.tsx | 2 +-
.../src/components/braced-text/braced-text.scss | 1 +
.../__snapshots__/click-to-copy.spec.tsx.snap | 11 +
.../click-to-copy/click-to-copy.spec.tsx | 31 +
.../src/components/click-to-copy/click-to-copy.tsx | 46 +
.../datasource-columns-table.spec.tsx.snap | 668 ------
.../datasource-columns-table.scss | 49 -
.../datasource-columns-table.spec.tsx | 78 -
.../datasource-columns-table.tsx | 86 -
.../components/fancy-tab-pane/fancy-tab-pane.scss | 62 +
.../components/fancy-tab-pane/fancy-tab-pane.tsx | 83 +
.../form-group-with-info/form-group-with-info.tsx | 2 +-
.../__snapshots__/header-bar.spec.tsx.snap | 163 +-
.../src/components/header-bar/header-bar.scss | 11 +-
.../src/components/header-bar/header-bar.spec.tsx | 2 +-
.../src/components/header-bar/header-bar.tsx | 152 +-
web-console/src/components/index.ts | 12 +
.../components/interval-input/interval-input.tsx | 2 +-
.../__snapshots__/learn-more.spec.tsx.snap | 0
.../learn-more/learn-more.spec.tsx | 0
.../src/components/learn-more/learn-more.tsx | 35 +
.../lookup-values-table/lookup-values-table.tsx | 87 -
.../src/components/menu-checkbox/menu-checkbox.tsx | 5 +-
.../__snapshots__/menu-tristate.spec.tsx.snap | 103 +
.../menu-tristate/menu-tristate.spec.tsx | 50 +
.../src/components/menu-tristate/menu-tristate.tsx | 71 +
.../__snapshots__/more-button.spec.tsx.snap | 2 +
.../src/components/more-button/more-button.tsx | 2 +-
.../__snapshots__/query-error-pane.spec.tsx.snap | 9 +
.../query-error-pane/query-error-pane.scss | 28 +
.../query-error-pane/query-error-pane.spec.tsx | 35 +
.../query-error-pane/query-error-pane.tsx | 100 +
.../record-table-pane/record-table-pane.scss | 113 +
.../record-table-pane/record-table-pane.tsx | 282 +++
web-console/src/components/show-json/show-json.tsx | 2 +-
.../supervisor-statistics-table.spec.tsx | 108 -
.../supervisor-statistics-table.tsx | 159 --
.../table-cell-unparseable.scss | 3 +
.../table-clickable-cell/table-clickable-cell.tsx | 7 +-
web-console/src/console-application.tsx | 127 +-
.../async-action-dialog/async-action-dialog.tsx | 2 +-
.../__snapshots__/compaction-dialog.spec.tsx.snap | 56 +
...coordinator-dynamic-config-dialog.spec.tsx.snap | 2 +-
.../datasource-table-action-dialog.spec.tsx.snap | 75 +-
.../datasource-columns-table.spec.tsx.snap | 648 +++++
.../datasource-columns-table.scss | 39 +
.../datasource-columns-table.spec.tsx | 78 +
.../datasource-columns-table.tsx | 85 +
.../datasource-preview-pane.scss | 29 +
.../datasource-preview-pane.tsx | 65 +
.../datasource-table-action-dialog.spec.tsx | 2 +-
.../datasource-table-action-dialog.tsx | 35 +-
.../edit-context-dialog/edit-context-dialog.tsx | 2 +-
.../src/dialogs/history-dialog/history-dialog.tsx | 2 +-
web-console/src/dialogs/index.ts | 3 +
.../lookup-table-action-dialog.tsx | 3 +-
.../lookup-values-table.spec.tsx.snap | 0
.../lookup-values-table/lookup-values-table.scss | 0
.../lookup-values-table.spec.tsx | 0
.../lookup-values-table/lookup-values-table.tsx | 87 +
.../numeric-input-dialog/numeric-input-dialog.tsx | 79 +
.../overload-dynamic-config-dialog.spec.tsx.snap | 2 +-
.../query-history-dialog/query-history-dialog.scss | 39 -
.../query-history-dialog/query-history-dialog.tsx | 88 -
.../__snapshots__/retention-dialog.spec.tsx.snap | 2 +-
.../segment-table-action-dialog.spec.tsx.snap | 27 +
.../segment-table-action-dialog.tsx | 12 +-
.../parse-segement-id.spec.ts | 65 +
.../segments-preview-pane.scss | 30 +
.../segments-preview-pane.tsx | 119 +
.../dialogs/status-dialog/status-dialog.spec.tsx | 16 +-
.../src/dialogs/status-dialog/status-dialog.tsx | 72 +-
.../string-input-dialog/string-input-dialog.tsx | 61 +
.../supervisor-statistics-table.spec.tsx.snap | 0
.../supervisor-statistics-table.scss | 0
.../supervisor-statistics-table.spec.tsx | 108 +
.../supervisor-statistics-table.tsx | 159 ++
.../supervisor-table-action-dialog.tsx | 3 +-
.../table-action-dialog/table-action-dialog.tsx | 2 +-
.../task-table-action-dialog.tsx | 6 +-
web-console/src/druid-models/compaction-config.tsx | 291 ---
.../compaction-config/compaction-config.tsx | 308 +++
.../src/druid-models/compaction-status.spec.ts | 87 -
web-console/src/druid-models/compaction-status.ts | 73 -
.../compaction-status/compaction-status.spec.ts | 88 +
.../compaction-status/compaction-status.ts | 73 +
.../druid-models/coordinator-dynamic-config.tsx | 270 ---
.../coordinator-dynamic-config.tsx | 270 +++
.../src/druid-models/dimension-spec.spec.ts | 84 -
web-console/src/druid-models/dimension-spec.ts | 98 -
.../dimension-spec/dimension-spec.spec.ts | 85 +
.../druid-models/dimension-spec/dimension-spec.ts | 97 +
.../src/druid-models/druid-engine/druid-engine.ts | 27 +
.../execution/execution-ingest-complete.mock.ts | 285 +++
.../execution/execution-ingest-error.mock.ts | 290 +++
.../src/druid-models/execution/execution.spec.ts | 530 +++++
.../src/druid-models/execution/execution.ts | 467 ++++
.../external-config/external-config.ts | 192 ++
web-console/src/druid-models/filter.tsx | 185 --
web-console/src/druid-models/filter/filter.tsx | 184 ++
web-console/src/druid-models/flatten-spec.spec.ts | 75 -
web-console/src/druid-models/flatten-spec.tsx | 132 --
.../druid-models/flatten-spec/flatten-spec.spec.ts | 75 +
.../src/druid-models/flatten-spec/flatten-spec.tsx | 132 ++
web-console/src/druid-models/index.ts | 38 +-
.../ingest-query-pattern.spec.ts | 53 +
.../ingest-query-pattern/ingest-query-pattern.ts | 314 +++
.../src/druid-models/ingestion-spec.spec.ts | 833 -------
web-console/src/druid-models/ingestion-spec.tsx | 2419 -------------------
.../ingestion-spec/ingestion-spec.spec.ts | 871 +++++++
.../druid-models/ingestion-spec/ingestion-spec.tsx | 2464 ++++++++++++++++++++
web-console/src/druid-models/input-format.tsx | 175 --
.../src/druid-models/input-format/input-format.tsx | 174 ++
web-console/src/druid-models/input-source.tsx | 91 -
.../src/druid-models/input-source/input-source.tsx | 590 +++++
web-console/src/druid-models/lookup-spec.tsx | 452 ----
.../{ => lookup-spec}/lookup-spec.spec.ts | 0
.../src/druid-models/lookup-spec/lookup-spec.tsx | 452 ++++
web-console/src/druid-models/metric-spec.spec.ts | 73 -
web-console/src/druid-models/metric-spec.tsx | 370 ---
.../druid-models/metric-spec/metric-spec.spec.ts | 74 +
.../src/druid-models/metric-spec/metric-spec.tsx | 369 +++
web-console/src/druid-models/mocks.ts | 20 +
.../src/druid-models/overlord-dynamic-config.tsx | 35 -
.../overlord-dynamic-config.tsx | 35 +
.../druid-models/query-context/query-context.tsx | 217 ++
web-console/src/druid-models/stages/stages.spec.ts | 881 +++++++
web-console/src/druid-models/stages/stages.ts | 524 +++++
web-console/src/druid-models/test-fixtures.ts | 189 --
web-console/src/druid-models/time.ts | 92 -
.../src/druid-models/{ => time}/time.spec.ts | 0
web-console/src/druid-models/time/time.ts | 92 +
web-console/src/druid-models/timestamp-spec.tsx | 168 --
.../druid-models/timestamp-spec/timestamp-spec.tsx | 167 ++
web-console/src/druid-models/transform-spec.tsx | 112 -
.../{ => transform-spec}/transform-spec.spec.ts | 0
.../druid-models/transform-spec/transform-spec.tsx | 111 +
.../workbench-query/workbench-query-part.ts | 256 ++
.../workbench-query/workbench-query.spec.ts | 592 +++++
.../workbench-query/workbench-query.ts | 665 ++++++
web-console/src/entry.ts | 2 +-
web-console/src/helpers/execution/general.ts | 70 +
.../src/helpers/execution/sql-task-execution.ts | 264 +++
web-console/src/helpers/index.ts | 21 +
web-console/src/helpers/spec-conversion.spec.ts | 452 ++++
web-console/src/helpers/spec-conversion.ts | 455 ++++
web-console/src/hooks/use-query-manager.ts | 23 +-
web-console/src/index.ts | 27 +
web-console/src/links.ts | 2 +-
.../src/react-table/react-table-base-styles.scss | 7 -
web-console/src/react-table/react-table-extra.scss | 2 +-
.../react-table-pagination.tsx | 11 +-
.../src/singletons/ace-editor-state-cache.ts | 48 +
web-console/src/singletons/api.spec.ts | 2 +-
web-console/src/singletons/api.ts | 6 +-
.../src/singletons/execution-state-cache.ts | 42 +
web-console/src/singletons/workbench-history.ts | 73 +
.../src/singletons/workbench-running-promises.ts | 50 +
web-console/src/utils/capabilities.ts | 27 +
web-console/src/utils/data-type-utils.ts | 94 -
.../src/utils/download-query-detail-archive.ts | 61 +
web-console/src/utils/download.spec.ts | 30 +
web-console/src/utils/download.ts | 92 +
web-console/src/utils/druid-query.spec.ts | 37 +-
web-console/src/utils/druid-query.ts | 54 +-
web-console/src/utils/general.tsx | 56 +-
web-console/src/utils/index.tsx | 6 +-
web-console/src/utils/local-storage-keys.tsx | 10 +
web-console/src/utils/query-context.tsx | 86 -
web-console/src/utils/query-manager.tsx | 30 +-
web-console/src/utils/query-state.ts | 3 +
web-console/src/utils/sample-query.spec.tsx | 60 +
web-console/src/utils/sample-query.tsx | 81 +
web-console/src/utils/sampler.mock.ts | 189 ++
web-console/src/utils/sql.ts | 60 +
web-console/src/utils/types.ts | 128 +
.../__snapshots__/datasources-view.spec.tsx.snap | 7 +-
.../views/datasources-view/datasources-view.tsx | 29 +-
.../__snapshots__/home-view.spec.tsx.snap | 12 +
.../home-view/services-card/services-card.tsx | 2 +-
.../src/views/home-view/tasks-card/tasks-card.tsx | 2 +-
web-console/src/views/index.ts | 2 +
.../__snapshots__/ingestion-view.spec.tsx.snap | 32 +-
.../views/ingestion-view/ingestion-view.spec.tsx | 4 +-
.../src/views/ingestion-view/ingestion-view.tsx | 133 +-
.../__snapshots__/load-data-view.spec.tsx.snap | 464 ++--
.../src/views/load-data-view/info-messages.tsx | 4 +-
.../views/load-data-view/learn-more/learn-more.tsx | 35 -
.../src/views/load-data-view/load-data-view.scss | 71 +-
.../views/load-data-view/load-data-view.spec.tsx | 9 +-
.../src/views/load-data-view/load-data-view.tsx | 163 +-
.../parse-data-table/parse-data-table.tsx | 3 +-
.../parse-time-table/parse-time-table.tsx | 3 +-
.../__snapshots__/query-view.spec.tsx.snap | 10 +-
.../query-view/column-tree/column-tree.spec.tsx | 4 +-
.../views/query-view/column-tree/column-tree.tsx | 13 +-
.../__snapshots__/explain-dialog.spec.tsx.snap | 117 +-
.../query-view/explain-dialog/explain-dialog.scss | 2 +
.../explain-dialog/explain-dialog.spec.tsx | 5 +-
.../query-view/explain-dialog/explain-dialog.tsx | 94 +-
.../live-query-mode-button.spec.tsx.snap | 153 ++
.../live-query-mode-button.scss | 40 +
.../live-query-mode-button.spec.tsx | 48 +
.../live-query-mode-button.tsx | 80 +
.../live-query-mode-selector.spec.tsx.snap | 159 --
.../live-query-mode-selector.scss | 40 -
.../live-query-mode-selector.spec.tsx | 48 -
.../live-query-mode-selector.tsx | 78 -
.../__snapshots__/query-error.spec.tsx.snap | 9 -
.../views/query-view/query-error/query-error.scss | 36 -
.../query-view/query-error/query-error.spec.tsx | 35 -
.../views/query-view/query-error/query-error.tsx | 107 -
.../query-history-dialog.spec.tsx.snap | 0
.../query-history-dialog/query-history-dialog.scss | 39 +
.../query-history-dialog.spec.tsx | 0
.../query-history-dialog/query-history-dialog.tsx | 88 +
.../views/query-view/query-input/query-input.tsx | 14 +-
.../views/query-view/query-output/query-output.tsx | 16 +-
.../src/views/query-view/query-view.spec.tsx | 9 -
web-console/src/views/query-view/query-view.tsx | 75 +-
.../src/views/query-view/run-button/run-button.tsx | 18 +-
.../src/views/segments-view/segments-view.tsx | 50 +-
.../src/views/services-view/services-view.spec.tsx | 4 +-
.../src/views/services-view/services-view.tsx | 6 +-
.../column-actions/column-actions.scss | 36 +
.../column-actions/column-actions.tsx | 283 +++
.../column-editor/column-editor.scss | 53 +
.../column-editor/column-editor.tsx | 219 ++
.../destination-dialog/destination-dialog.scss | 23 +
.../destination-dialog/destination-dialog.tsx | 89 +
.../destination-form/destination-form.scss | 24 +
.../destination-form/destination-form.tsx | 128 +
.../expression-editor-dialog.scss | 41 +
.../expression-editor-dialog.tsx | 107 +
.../ingestion-progress-dialog.scss | 39 +
.../ingestion-progress-dialog.tsx | 132 ++
.../schema-step/column-list/column-list.scss | 61 +
.../schema-step/column-list/column-list.tsx | 156 ++
.../expression-entry/expression-entry.scss | 82 +
.../expression-entry/expression-entry.tsx | 70 +
.../schema-step/preview-error/preview-error.scss | 35 +
.../schema-step/preview-error/preview-error.tsx | 41 +
.../schema-step/preview-table/preview-table.scss | 146 ++
.../schema-step/preview-table/preview-table.tsx | 222 ++
.../rollup-analysis-pane/rollup-analysis-pane.scss | 35 +
.../rollup-analysis-pane/rollup-analysis-pane.tsx | 342 +++
.../schema-step/schema-step.scss | 147 ++
.../schema-step/schema-step.tsx | 983 ++++++++
.../sql-data-loader-view/sql-data-loader-view.scss | 85 +
.../sql-data-loader-view/sql-data-loader-view.tsx | 201 ++
.../title-frame/title-frame.scss | 55 +
.../title-frame/title-frame.tsx | 44 +
.../cancel-query-dialog/cancel-query-dialog.tsx | 48 +
.../connect-external-data-dialog.scss | 36 +
.../connect-external-data-dialog.tsx | 87 +
.../src/views/workbench-view/demo-queries.ts | 312 +++
.../execution-details-dialog.scss | 35 +
.../execution-details-dialog.tsx | 58 +
.../execution-details-pane-loader.tsx | 71 +
.../execution-details-pane.scss | 28 +
.../execution-details-pane.tsx | 147 ++
.../execution-error-pane.spec.tsx.snap | 40 +
.../execution-error-pane/execution-error-pane.scss | 32 +
.../execution-error-pane.spec.tsx | 32 +
.../execution-error-pane/execution-error-pane.tsx | 93 +
.../execution-progress-bar-pane.spec.tsx.snap | 23 +
.../execution-progress-bar-pane.scss | 40 +
.../execution-progress-bar-pane.spec.tsx | 34 +
.../execution-progress-bar-pane.tsx | 95 +
.../execution-progress-pane.scss | 73 +
.../execution-progress-pane.tsx | 62 +
.../execution-stages-pane-loader.tsx | 62 +
.../execution-stages-pane.spec.tsx.snap | 427 ++++
.../execution-stages-pane.scss | 104 +
.../execution-stages-pane.spec.tsx | 34 +
.../execution-stages-pane.tsx | 649 ++++++
.../execution-submit-dialog.scss | 31 +
.../execution-submit-dialog.tsx | 139 ++
.../execution-summary-panel.scss | 22 +
.../execution-summary-panel.tsx | 100 +
.../execution-timer-panel.spec.tsx.snap | 59 +
.../execution-timer-panel.scss | 23 +
.../execution-timer-panel.spec.tsx | 49 +
.../execution-timer-panel.tsx | 71 +
.../execution-warnings-pane.scss | 23 +
.../execution-warnings-pane.tsx | 45 +
.../execution-warnings-pane/warning-callout.scss | 23 +
.../execution-warnings-pane/warning-callout.tsx | 53 +
.../flexible-query-input.spec.tsx.snap | 111 +
.../flexible-query-input/flexible-query-input.scss | 27 +
.../flexible-query-input.spec.tsx | 47 +
.../flexible-query-input/flexible-query-input.tsx | 336 +++
.../workbench-view/helper-query/helper-query.scss | 100 +
.../workbench-view/helper-query/helper-query.tsx | 408 ++++
.../ingest-success-pane.spec.tsx.snap | 30 +
.../ingest-success-pane/ingest-success-pane.scss | 32 +
.../ingest-success-pane.spec.tsx | 38 +
.../ingest-success-pane/ingest-success-pane.tsx | 82 +
.../input-format-step/input-format-step.scss | 70 +
.../input-format-step/input-format-step.tsx | 259 ++
.../input-source-step/example-inputs.ts | 159 ++
.../input-source-step/input-source-info.tsx | 78 +
.../input-source-step/input-source-step.scss | 131 ++
.../input-source-step/input-source-step.tsx | 343 +++
.../__snapshots__/max-tasks-button.spec.tsx.snap | 205 ++
.../max-tasks-button/max-tasks-button.spec.tsx | 30 +
.../max-tasks-button/max-tasks-button.tsx | 115 +
.../workbench-view/metadata-change-detector.tsx | 39 +
.../views/workbench-view/metadata-state-store.ts | 29 +
.../views/workbench-view/query-tab/query-tab.scss | 147 ++
.../views/workbench-view/query-tab/query-tab.tsx | 457 ++++
.../recent-query-task-panel.scss | 121 +
.../recent-query-task-panel.tsx | 275 +++
.../result-table-pane/result-table-pane.scss | 117 +
.../result-table-pane/result-table-pane.tsx | 778 ++++++
.../views/workbench-view/run-panel/run-panel.scss | 26 +
.../views/workbench-view/run-panel/run-panel.tsx | 422 ++++
.../tab-rename-dialog/tab-rename-dialog.tsx | 70 +
.../time-floor-menu-item/time-floor-menu-item.tsx | 102 +
.../src/views/workbench-view/work-state-store.ts | 29 +
.../workbench-history-dialog.scss | 79 +
.../workbench-history-dialog.tsx | 134 ++
.../src/views/workbench-view/workbench-view.scss | 122 +
.../src/views/workbench-view/workbench-view.tsx | 805 +++++++
website/.spelling | 6 +
website/script/fix-path.js | 7 +
website/sidebars.json | 1 +
968 files changed, 90715 insertions(+), 10737 deletions(-)
create mode 100644
core/src/main/java/org/apache/druid/java/util/emitter/core/EventMap.java
create mode 100644
core/src/main/java/org/apache/druid/java/util/emitter/core/EventMapSerializer.java
create mode 100644 docs/assets/tutorial-theta-01.png
create mode 100644 docs/assets/tutorial-theta-02.png
create mode 100644 docs/assets/tutorial-theta-03.png
create mode 100644 docs/assets/tutorial-theta-04.png
create mode 100644 docs/assets/tutorial-theta-05.png
create mode 100644 docs/assets/tutorial-theta-06.png
create mode 100644 docs/assets/tutorial-theta-07.png
create mode 100644 docs/assets/tutorial-theta-08.png
create mode 100644 docs/assets/tutorial-theta-09.png
create mode 100644 docs/assets/tutorial-theta-10.png
create mode 100644 docs/assets/tutorial-theta-11.png
create mode 100644 docs/tutorials/tutorial-sketches-theta.md
create mode 100644 extensions-core/multi-stage-query/README.md
create mode 100644 extensions-core/multi-stage-query/pom.xml
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/ChannelCounters.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterNames.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterSnapshots.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterSnapshotsSerializer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterSnapshotsTree.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/CounterTracker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/QueryCounter.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/QueryCounterSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/SuperSorterProgressTrackerCounter.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/counters/WarningCounters.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/Controller.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ExceptionWrappingWorkerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/Limits.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/MSQTasks.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/QueryValidator.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/TaskDataSegmentProvider.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/Worker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerManagerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerMemoryParameters.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQDurableStorageModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQExternalDataSourceModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQIndexingModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQServiceClientModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQSqlModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MultiStageQuery.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/SqlTaskModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/ColumnMapping.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/ColumnMappings.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/ControllerChatHandler.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/CountableInputSourceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/CountingOutputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/CountingReadableFrameChannel.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/CountingWritableFrameChannel.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/DataSourceMSQDestination.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerFrameContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerManagerClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/InputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/InputChannelsImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/KeyStatisticsCollectionProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQControllerTask.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQDestination.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQPartitionAssignment.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQTaskList.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQTuningConfig.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQWorkerTask.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/MSQWorkerTaskLauncher.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/SegmentGeneratorFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/SegmentGeneratorFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/TaskReportMSQDestination.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/WorkerChatHandler.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/BaseMSQFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/BroadcastTablesTooLargeFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/CanceledFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/CannotParseExternalDataFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/ColumnNameRestrictedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/ColumnTypeNotSupportedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/DurableStorageConfigurationFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/FaultsExceededChecker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotAllocateSegmentFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotBeEmptyFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotOrderByDescendingFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertCannotReplaceExistingSegmentFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertLockPreemptedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertTimeNullFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InsertTimeOutOfBoundsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/InvalidNullByteFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQErrorReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQException.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportLimiterPublisher.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportPublisher.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarningReportSimplePublisher.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/MSQWarnings.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/NotEnoughMemoryFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/QueryNotSupportedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/RowTooLargeFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TaskStartTimeoutFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyBucketsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyColumnsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyInputFilesFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyPartitionsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyWarningsFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/TooManyWorkersFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/UnknownFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/WorkerFailedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/error/WorkerRpcFailedFault.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQResultsReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQStagesReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQStatusReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQTaskReport.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/report/MSQTaskReportPayload.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSlices.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpecSlicerFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/InputSpecs.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/MapInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/MapInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/NilInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/NilInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/NilInputSource.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/ReadableInput.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/ReadableInputs.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/SlicerUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/external/ExternalInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/external/ExternalInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/external/ExternalInputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/external/ExternalInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/CollectedReadablePartitions.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/CombinedReadablePartitions.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/InputChannels.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/ReadablePartition.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/ReadablePartitions.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StageInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StageInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StageInputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StageInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/stage/StripedReadablePartitions.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/RichSegmentDescriptor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/SegmentWithDescriptor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/SegmentsInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/SegmentsInputSliceReader.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/TableInputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/input/table/TableInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/ExtraInfoHolder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/FrameContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/FrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/MaxCountShuffleSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/NilExtraInfoHolder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/ProcessorsAndChannels.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/QueryDefinition.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/QueryDefinitionBuilder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/ShuffleSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageDefinition.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageDefinitionBuilder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageId.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StagePartition.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/TargetSizeShuffleSpec.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/WorkOrder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/WorkerAssignmentStrategy.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernel.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStagePhase.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/WorkerInputs.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/worker/WorkerStageKernel.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/worker/WorkerStagePhase.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BaseLeafFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/BroadcastJoinHelper.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/DataSegmentProvider.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/DataSegmentTimelineView.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/DataSourcePlan.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/InputNumberDataSource.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/LazyResourceHolder.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/MultiQueryKit.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/QueryKit.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/QueryKitUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/ShuffleSpecFactories.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/ShuffleSpecFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/common/OffsetLimitFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/common/OffsetLimitFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPostShuffleFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPostShuffleFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPreShuffleFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByPreShuffleFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/groupby/GroupByQueryKit.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryFrameProcessor.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryFrameProcessorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/querykit/scan/ScanQueryKit.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/CoordinatorServiceClient.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/rpc/CoordinatorServiceClientImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/DurableStorageInputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/DurableStorageOutputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/shuffle/WorkerInputChannelFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/MSQMode.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/MSQTaskQueryMaker.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/MSQTaskSqlEngine.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/SqlTaskResource.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/sql/SqlTaskStatus.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollectorImpl.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/ClusterByStatisticsSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DistinctKeyCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DistinctKeyCollectorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/DistinctKeySnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollectorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollectorSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollectorSnapshotDeserializerModule.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/KeyCollectors.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollector.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorSnapshot.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/statistics/TooManyBucketsException.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/DecoratedExecutorService.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/DimensionSchemaUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/IntervalUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MSQFutureUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/PassthroughAggregator.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/PassthroughAggregatorFactory.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/SequenceUtils.java
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/util/SupplierIterator.java
create mode 100644
extensions-core/multi-stage-query/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
create mode 100644
extensions-core/multi-stage-query/src/main/resources/log4j2.xml
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/TestArrayStorageAdapter.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/counters/CountersSnapshotTreeTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQInsertTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQReplaceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQSelectTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/MSQTasksTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/QueryValidatorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/exec/WorkerMemoryParametersTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/ColumnMappingTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/DataSourceMSQDestinationTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/IndexerWorkerContextTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/MSQPartitionAssignmentTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/MSQSpecTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/MSQTuningConfigTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/InsertLockPreemptedFaultTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/MSQFaultSerdeTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/MSQWarningsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/report/MSQTaskReportTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/InputSpecsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/NilInputSliceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/external/ExternalInputSliceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/external/ExternalInputSpecSlicerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/external/ExternalInputSpecTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/CollectedReadablePartitionsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/CombinedReadablePartitionsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/ReadablePartitionTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/StageInputSliceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/StageInputSpecSlicerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/StageInputSpecTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/stage/StripedReadablePartitionsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/RichSegmentDescriptorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/SegmentWithDescriptorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/SegmentsInputSliceTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/TableInputSpecSlicerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/input/table/TableInputSpecTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/QueryDefinitionTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/StageDefinitionTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/StageIdTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/WorkOrderTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/BaseControllerQueryKernelTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernelTests.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSlice.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSpec.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/ControllerTestInputSpecSlicer.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/MockQueryDefinitionBuilder.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/kernel/controller/WorkerInputsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/querykit/BroadcastJoinHelperTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/sql/MSQModeTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/sql/MSQTaskQueryMakerTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/sql/SqlTaskStatusTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/ClusterByStatisticsCollectorImplTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/DelegateOrMinKeyCollectorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/DistinctKeyCollectorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/KeyCollectorTestUtils.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/statistics/QuantilesSketchKeyCollectorTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestBase.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestControllerClient.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestControllerContext.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestDelegateDataSegmentPusher.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestOverlordServiceClient.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestSegmentManager.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestTaskActionClient.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestWorkerClient.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestWorkerContext.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/util/IntervalUtilsTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/util/MultiStageQueryContextTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/util/PassthroughAggregatorFactoryTest.java
create mode 100644
extensions-core/multi-stage-query/src/test/resources/unparseable.gz
create mode 100644
extensions-core/multi-stage-query/src/test/resources/wikipedia-sampled-unparsable.json
create mode 100644
extensions-core/multi-stage-query/src/test/resources/wikipedia-sampled.json
create mode 100644
extensions-core/s3-extensions/src/test/java/org/apache/druid/storage/s3/S3StorageConnectorProviderTest.java
copy {integration-tests-ex => extensions-core/testing-tools}/.gitignore (100%)
copy integration-tests-ex/{ => cases}/.gitignore (100%)
rename integration-tests-ex/{ => cases}/assets/log4j2.xml (100%)
create mode 100755 integration-tests-ex/cases/cluster.sh
create mode 100644
integration-tests-ex/cases/cluster/BatchIndex/docker-compose.yaml
create mode 100644 integration-tests-ex/cases/cluster/Common/dependencies.yaml
create mode 100644 integration-tests-ex/cases/cluster/Common/druid.yaml
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/auth.env
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/broker.env
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/common.env
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/coordinator.env
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/historical.env
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/indexer.env
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/middlemanager.env
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/overlord.env
create mode 100644
integration-tests-ex/cases/cluster/Common/environment-configs/router.env
create mode 100644
integration-tests-ex/cases/cluster/HighAvailability/docker-compose.yaml
create mode 100644 integration-tests-ex/cases/pom.xml
create mode 100644 integration-tests-ex/cases/resources/README.md
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/avro/wikipedia_index_data1.avro
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/avro/wikipedia_index_data2.avro
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/avro/wikipedia_index_data3.avro
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/csv/wikipedia_index_data1.csv
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/csv/wikipedia_index_data2.csv
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/csv/wikipedia_index_data3.csv
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/hadoop_tsv/batch_hadoop.data
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/json/wikipedia_index_data1.json
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/json/wikipedia_index_data2.json
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/json/wikipedia_index_data3.json
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/orc/wikipedia_index_data1.orc
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/orc/wikipedia_index_data2.orc
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/orc/wikipedia_index_data3.orc
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/parquet/wikipedia_index_data1.parquet
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/parquet/wikipedia_index_data2.parquet
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/parquet/wikipedia_index_data3.parquet
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/tsv/wikipedia_index_data1.tsv
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/tsv/wikipedia_index_data2.tsv
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/data/batch_index/tsv/wikipedia_index_data3.tsv
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/indexer/wikipedia_combining_index_data.json
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/indexer/wikipedia_index_queries_only_data3.json
(100%)
copy {integration-tests/src/test =>
integration-tests-ex/cases}/resources/indexer/wikipedia_realtime_index_data.json
(100%)
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/categories/BatchIndex.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/categories/HighAvailability.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/cluster/DruidClusterClient.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/cluster/KafkaClient.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/cluster/MetastoreClient.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/cluster/ZooKeeperClient.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/Cluster.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/ClusterConfig.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/ClusterConfigTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/Configure.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/DruidTestRunner.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/Initializer.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/IntegrationTestingConfigEx.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/KafkaConfig.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/MetastoreConfig.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/MetastoreStmt.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/ResolvedConfig.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/ResolvedDruidService.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/ResolvedMetastore.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/ResolvedService.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/ServiceConfig.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/ServiceInstance.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/config/TestConfigs.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/AbstractITBatchIndexTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/AbstractIndexerTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/AbstractLocalInputSourceParallelIndexTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/ITBestEffortRollupParallelIndexTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/ITCombiningFirehoseFactoryIndexTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/ITCombiningInputSourceParallelIndexTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/ITIndexerTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/ITOverwriteBatchIndexTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/ITSystemTableBatchIndexTaskTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/indexer/ITTransformTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/leadership/ITHighAvailabilityTest.java
create mode 100644
integration-tests-ex/cases/src/test/java/org/apache/druid/testsEx/utils/DruidClusterAdminClient.java
create mode 100644
integration-tests-ex/cases/src/test/resources/cluster/AzureDeepStorage/docker.yaml
create mode 100644
integration-tests-ex/cases/src/test/resources/cluster/BatchIndex/docker.yaml
create mode 100644
integration-tests-ex/cases/src/test/resources/cluster/Common/kafka.yaml
create mode 100644
integration-tests-ex/cases/src/test/resources/cluster/Common/zk-metastore.yaml
create mode 100644
integration-tests-ex/cases/src/test/resources/cluster/HighAvailability/docker.yaml
copy integration-tests/src/test/resources/queries/high_availability_sys.json
=>
integration-tests-ex/cases/src/test/resources/cluster/HighAvailability/queries/sys.json
(100%)
create mode 100644
integration-tests-ex/cases/src/test/resources/config-test/test.yaml
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/broadcast_join_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/json_path_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/json_path_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/segment_metadata_query.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/sparse_column_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/sparse_column_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/sparse_column_with_dim_compaction_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/sparse_column_without_dim_compaction_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/sys_segment_batch_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_cloud_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_cloud_simple_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_combining_firehose_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_combining_firehose_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_combining_input_source_index_parallel_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_compaction_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_compaction_task_with_granularity_spec.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_compaction_task_with_segment_granularity.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_double_ingestion_non_perfect_rollup_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_double_ingestion_perfect_rollup_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_http_inputsource_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_http_inputsource_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_queries_hour_query_granularity.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_queries_with_transform.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_queries_year_query_granularity.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_rollup_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_task_with_dimension_spec.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_task_with_granularity_spec.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_task_with_inputsource_transform.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_task_with_transform.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_index_with_merge_column_limit_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_local_input_source_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_merge_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_merge_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_merge_reindex_druid_input_source_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_merge_reindex_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_override_credentials_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_parallel_druid_input_source_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_parallel_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_parallel_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_parallel_index_using_sqlinputsource_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_parallel_ingest_segment_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_parallel_reindex_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_parallel_reindex_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_realtime_appenderator_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_realtime_appenderator_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_realtime_index_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_realtime_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_reindex_druid_input_source_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_reindex_druid_input_source_task_with_transforms.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_reindex_queries.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_reindex_queries_with_transforms.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_reindex_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_reindex_task_with_transforms.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_union_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikipedia_with_timestamp_index_task.json
(100%)
copy {integration-tests =>
integration-tests-ex/cases}/src/test/resources/indexer/wikiticker_index_task.json
(100%)
delete mode 100755 integration-tests-ex/check-results.sh
create mode 100644 integration-tests-ex/docs/compose.md
create mode 100644 integration-tests-ex/docs/conversion.md
create mode 100644 integration-tests-ex/docs/debugging.md
create mode 100644 integration-tests-ex/docs/dependencies.md
create mode 100644 integration-tests-ex/docs/docker.md
create mode 100644 integration-tests-ex/docs/druid-config.md
create mode 100644 integration-tests-ex/docs/guide.md
create mode 100644 integration-tests-ex/docs/history.md
create mode 100644 integration-tests-ex/docs/maven.md
create mode 100644 integration-tests-ex/docs/next-steps.md
create mode 100644 integration-tests-ex/docs/quickstart.md
create mode 100644 integration-tests-ex/docs/runtime.md
create mode 100644 integration-tests-ex/docs/scripts.md
create mode 100644 integration-tests-ex/docs/test-config.md
create mode 100644 integration-tests-ex/docs/tests.md
create mode 100644 integration-tests-ex/docs/travis.md
rename integration-tests-ex/{it-image => image}/build-image.sh (100%)
rename integration-tests-ex/{it-image => image}/docker-build.sh (100%)
rename integration-tests-ex/{it-image => image}/docker/Dockerfile (100%)
rename integration-tests-ex/{it-image => image}/docker/druid.sh (100%)
create mode 100644 integration-tests-ex/image/docker/launch.sh
rename integration-tests-ex/{it-image => image}/docker/test-setup.sh (100%)
create mode 100644 integration-tests-ex/image/pom.xml
rename integration-tests-ex/{it-image => image}/rebuild.sh (100%)
delete mode 100644 integration-tests-ex/it-image/docker/launch.sh
delete mode 100644 integration-tests-ex/it-image/pom.xml
delete mode 100644 integration-tests-ex/it-image/scripts/build-shared.sh
delete mode 100644 integration-tests-ex/it-tools/pom.xml
rename integration-tests-ex/{it-tools => tools}/README.md (100%)
create mode 100644 integration-tests-ex/tools/pom.xml
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/CliCustomNodeRole.java
(100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/CliHistoricalForQueryErrorTest.java
(100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/CustomNodeRoleClientModule.java
(100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/CustomNodeRoleCommandCreator.java
(100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/QueryRetryTestCommandCreator.java
(100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/ServerManagerForQueryErrorTest.java
(100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/SleepExprMacro.java (100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/SleepModule.java (100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/SleepOperatorConversion.java
(100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/java/org/apache/druid/testing/tools/package.java (100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/resources/META-INF/services/org.apache.druid.cli.CliCommandCreator
(100%)
rename integration-tests-ex/{it-tools =>
tools}/src/main/resources/META-INF/services/org.apache.druid.initialization.DruidModule
(100%)
create mode 100755 it.sh
create mode 100644 licenses/bin/zustand.MIT
create mode 100644
server/src/test/java/org/apache/druid/server/initialization/JettyCertRenewTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/log/AlertEventSerdeTest.java
create mode 100644
server/src/test/java/org/apache/druid/server/log/ServiceMetricEventSerdeTest.java
create mode 100644 server/src/test/resources/server-new.jks
create mode 100644 server/src/test/resources/truststore-new.jks
create mode 100644
sql/src/test/java/org/apache/druid/sql/calcite/run/NativeQueryMakerTest.java
create mode 100644 web-console/e2e-tests/component/workbench/overview.ts
create mode 100644 web-console/e2e-tests/multi-stage-query.spec.ts
create mode 100755 web-console/script/mv
create mode 100644
web-console/src/components/click-to-copy/__snapshots__/click-to-copy.spec.tsx.snap
create mode 100644
web-console/src/components/click-to-copy/click-to-copy.spec.tsx
create mode 100644 web-console/src/components/click-to-copy/click-to-copy.tsx
delete mode 100644
web-console/src/components/datasource-columns-table/__snapshots__/datasource-columns-table.spec.tsx.snap
delete mode 100644
web-console/src/components/datasource-columns-table/datasource-columns-table.scss
delete mode 100644
web-console/src/components/datasource-columns-table/datasource-columns-table.spec.tsx
delete mode 100644
web-console/src/components/datasource-columns-table/datasource-columns-table.tsx
create mode 100644
web-console/src/components/fancy-tab-pane/fancy-tab-pane.scss
create mode 100644 web-console/src/components/fancy-tab-pane/fancy-tab-pane.tsx
rename web-console/src/{views/load-data-view =>
components}/learn-more/__snapshots__/learn-more.spec.tsx.snap (100%)
rename web-console/src/{views/load-data-view =>
components}/learn-more/learn-more.spec.tsx (100%)
create mode 100644 web-console/src/components/learn-more/learn-more.tsx
delete mode 100644
web-console/src/components/lookup-values-table/lookup-values-table.tsx
create mode 100644
web-console/src/components/menu-tristate/__snapshots__/menu-tristate.spec.tsx.snap
create mode 100644
web-console/src/components/menu-tristate/menu-tristate.spec.tsx
create mode 100644 web-console/src/components/menu-tristate/menu-tristate.tsx
create mode 100644
web-console/src/components/query-error-pane/__snapshots__/query-error-pane.spec.tsx.snap
create mode 100644
web-console/src/components/query-error-pane/query-error-pane.scss
create mode 100644
web-console/src/components/query-error-pane/query-error-pane.spec.tsx
create mode 100644
web-console/src/components/query-error-pane/query-error-pane.tsx
create mode 100644
web-console/src/components/record-table-pane/record-table-pane.scss
create mode 100644
web-console/src/components/record-table-pane/record-table-pane.tsx
delete mode 100644
web-console/src/components/supervisor-statistics-table/supervisor-statistics-table.spec.tsx
delete mode 100644
web-console/src/components/supervisor-statistics-table/supervisor-statistics-table.tsx
create mode 100644
web-console/src/dialogs/datasource-table-action-dialog/datasource-columns-table/__snapshots__/datasource-columns-table.spec.tsx.snap
create mode 100644
web-console/src/dialogs/datasource-table-action-dialog/datasource-columns-table/datasource-columns-table.scss
create mode 100644
web-console/src/dialogs/datasource-table-action-dialog/datasource-columns-table/datasource-columns-table.spec.tsx
create mode 100644
web-console/src/dialogs/datasource-table-action-dialog/datasource-columns-table/datasource-columns-table.tsx
create mode 100644
web-console/src/dialogs/datasource-table-action-dialog/datasource-preview-pane/datasource-preview-pane.scss
create mode 100644
web-console/src/dialogs/datasource-table-action-dialog/datasource-preview-pane/datasource-preview-pane.tsx
rename web-console/src/{components =>
dialogs/lookup-table-action-dialog}/lookup-values-table/__snapshots__/lookup-values-table.spec.tsx.snap
(100%)
rename web-console/src/{components =>
dialogs/lookup-table-action-dialog}/lookup-values-table/lookup-values-table.scss
(100%)
rename web-console/src/{components =>
dialogs/lookup-table-action-dialog}/lookup-values-table/lookup-values-table.spec.tsx
(100%)
create mode 100644
web-console/src/dialogs/lookup-table-action-dialog/lookup-values-table/lookup-values-table.tsx
create mode 100644
web-console/src/dialogs/numeric-input-dialog/numeric-input-dialog.tsx
delete mode 100644
web-console/src/dialogs/query-history-dialog/query-history-dialog.scss
delete mode 100644
web-console/src/dialogs/query-history-dialog/query-history-dialog.tsx
create mode 100644
web-console/src/dialogs/segments-table-action-dialog/segments-preview-pane/parse-segement-id.spec.ts
create mode 100644
web-console/src/dialogs/segments-table-action-dialog/segments-preview-pane/segments-preview-pane.scss
create mode 100644
web-console/src/dialogs/segments-table-action-dialog/segments-preview-pane/segments-preview-pane.tsx
create mode 100644
web-console/src/dialogs/string-input-dialog/string-input-dialog.tsx
rename web-console/src/{components =>
dialogs/supervisor-table-action-dialog}/supervisor-statistics-table/__snapshots__/supervisor-statistics-table.spec.tsx.snap
(100%)
rename web-console/src/{components =>
dialogs/supervisor-table-action-dialog}/supervisor-statistics-table/supervisor-statistics-table.scss
(100%)
create mode 100644
web-console/src/dialogs/supervisor-table-action-dialog/supervisor-statistics-table/supervisor-statistics-table.spec.tsx
create mode 100644
web-console/src/dialogs/supervisor-table-action-dialog/supervisor-statistics-table/supervisor-statistics-table.tsx
delete mode 100644 web-console/src/druid-models/compaction-config.tsx
create mode 100644
web-console/src/druid-models/compaction-config/compaction-config.tsx
delete mode 100644 web-console/src/druid-models/compaction-status.spec.ts
delete mode 100644 web-console/src/druid-models/compaction-status.ts
create mode 100644
web-console/src/druid-models/compaction-status/compaction-status.spec.ts
create mode 100644
web-console/src/druid-models/compaction-status/compaction-status.ts
delete mode 100644 web-console/src/druid-models/coordinator-dynamic-config.tsx
create mode 100644
web-console/src/druid-models/coordinator-dynamic-config/coordinator-dynamic-config.tsx
delete mode 100644 web-console/src/druid-models/dimension-spec.spec.ts
delete mode 100644 web-console/src/druid-models/dimension-spec.ts
create mode 100644
web-console/src/druid-models/dimension-spec/dimension-spec.spec.ts
create mode 100644
web-console/src/druid-models/dimension-spec/dimension-spec.ts
create mode 100644 web-console/src/druid-models/druid-engine/druid-engine.ts
create mode 100644
web-console/src/druid-models/execution/execution-ingest-complete.mock.ts
create mode 100644
web-console/src/druid-models/execution/execution-ingest-error.mock.ts
create mode 100644 web-console/src/druid-models/execution/execution.spec.ts
create mode 100644 web-console/src/druid-models/execution/execution.ts
create mode 100644
web-console/src/druid-models/external-config/external-config.ts
delete mode 100644 web-console/src/druid-models/filter.tsx
create mode 100644 web-console/src/druid-models/filter/filter.tsx
delete mode 100644 web-console/src/druid-models/flatten-spec.spec.ts
delete mode 100644 web-console/src/druid-models/flatten-spec.tsx
create mode 100644
web-console/src/druid-models/flatten-spec/flatten-spec.spec.ts
create mode 100644 web-console/src/druid-models/flatten-spec/flatten-spec.tsx
create mode 100644
web-console/src/druid-models/ingest-query-pattern/ingest-query-pattern.spec.ts
create mode 100644
web-console/src/druid-models/ingest-query-pattern/ingest-query-pattern.ts
delete mode 100644 web-console/src/druid-models/ingestion-spec.spec.ts
delete mode 100644 web-console/src/druid-models/ingestion-spec.tsx
create mode 100644
web-console/src/druid-models/ingestion-spec/ingestion-spec.spec.ts
create mode 100644
web-console/src/druid-models/ingestion-spec/ingestion-spec.tsx
delete mode 100644 web-console/src/druid-models/input-format.tsx
create mode 100644 web-console/src/druid-models/input-format/input-format.tsx
delete mode 100644 web-console/src/druid-models/input-source.tsx
create mode 100644 web-console/src/druid-models/input-source/input-source.tsx
delete mode 100644 web-console/src/druid-models/lookup-spec.tsx
rename web-console/src/druid-models/{ => lookup-spec}/lookup-spec.spec.ts
(100%)
create mode 100644 web-console/src/druid-models/lookup-spec/lookup-spec.tsx
delete mode 100644 web-console/src/druid-models/metric-spec.spec.ts
delete mode 100644 web-console/src/druid-models/metric-spec.tsx
create mode 100644 web-console/src/druid-models/metric-spec/metric-spec.spec.ts
create mode 100644 web-console/src/druid-models/metric-spec/metric-spec.tsx
create mode 100644 web-console/src/druid-models/mocks.ts
delete mode 100644 web-console/src/druid-models/overlord-dynamic-config.tsx
create mode 100644
web-console/src/druid-models/overlord-dynamic-config/overlord-dynamic-config.tsx
create mode 100644 web-console/src/druid-models/query-context/query-context.tsx
create mode 100644 web-console/src/druid-models/stages/stages.spec.ts
create mode 100644 web-console/src/druid-models/stages/stages.ts
delete mode 100644 web-console/src/druid-models/test-fixtures.ts
delete mode 100644 web-console/src/druid-models/time.ts
rename web-console/src/druid-models/{ => time}/time.spec.ts (100%)
create mode 100644 web-console/src/druid-models/time/time.ts
delete mode 100644 web-console/src/druid-models/timestamp-spec.tsx
create mode 100644
web-console/src/druid-models/timestamp-spec/timestamp-spec.tsx
delete mode 100644 web-console/src/druid-models/transform-spec.tsx
rename web-console/src/druid-models/{ =>
transform-spec}/transform-spec.spec.ts (100%)
create mode 100644
web-console/src/druid-models/transform-spec/transform-spec.tsx
create mode 100644
web-console/src/druid-models/workbench-query/workbench-query-part.ts
create mode 100644
web-console/src/druid-models/workbench-query/workbench-query.spec.ts
create mode 100644
web-console/src/druid-models/workbench-query/workbench-query.ts
create mode 100644 web-console/src/helpers/execution/general.ts
create mode 100644 web-console/src/helpers/execution/sql-task-execution.ts
create mode 100644 web-console/src/helpers/index.ts
create mode 100644 web-console/src/helpers/spec-conversion.spec.ts
create mode 100644 web-console/src/helpers/spec-conversion.ts
create mode 100644 web-console/src/index.ts
create mode 100644 web-console/src/singletons/ace-editor-state-cache.ts
create mode 100644 web-console/src/singletons/execution-state-cache.ts
create mode 100644 web-console/src/singletons/workbench-history.ts
create mode 100644 web-console/src/singletons/workbench-running-promises.ts
delete mode 100644 web-console/src/utils/data-type-utils.ts
create mode 100644 web-console/src/utils/download-query-detail-archive.ts
create mode 100644 web-console/src/utils/download.spec.ts
create mode 100644 web-console/src/utils/download.ts
delete mode 100644 web-console/src/utils/query-context.tsx
create mode 100644 web-console/src/utils/sample-query.spec.tsx
create mode 100644 web-console/src/utils/sample-query.tsx
create mode 100644 web-console/src/utils/sampler.mock.ts
create mode 100644 web-console/src/utils/sql.ts
create mode 100644 web-console/src/utils/types.ts
delete mode 100644
web-console/src/views/load-data-view/learn-more/learn-more.tsx
create mode 100644
web-console/src/views/query-view/live-query-mode-button/__snapshots__/live-query-mode-button.spec.tsx.snap
create mode 100644
web-console/src/views/query-view/live-query-mode-button/live-query-mode-button.scss
create mode 100644
web-console/src/views/query-view/live-query-mode-button/live-query-mode-button.spec.tsx
create mode 100644
web-console/src/views/query-view/live-query-mode-button/live-query-mode-button.tsx
delete mode 100644
web-console/src/views/query-view/live-query-mode-selector/__snapshots__/live-query-mode-selector.spec.tsx.snap
delete mode 100644
web-console/src/views/query-view/live-query-mode-selector/live-query-mode-selector.scss
delete mode 100644
web-console/src/views/query-view/live-query-mode-selector/live-query-mode-selector.spec.tsx
delete mode 100644
web-console/src/views/query-view/live-query-mode-selector/live-query-mode-selector.tsx
delete mode 100644
web-console/src/views/query-view/query-error/__snapshots__/query-error.spec.tsx.snap
delete mode 100644
web-console/src/views/query-view/query-error/query-error.scss
delete mode 100644
web-console/src/views/query-view/query-error/query-error.spec.tsx
delete mode 100644 web-console/src/views/query-view/query-error/query-error.tsx
rename web-console/src/{dialogs =>
views/query-view}/query-history-dialog/__snapshots__/query-history-dialog.spec.tsx.snap
(100%)
create mode 100644
web-console/src/views/query-view/query-history-dialog/query-history-dialog.scss
rename web-console/src/{dialogs =>
views/query-view}/query-history-dialog/query-history-dialog.spec.tsx (100%)
create mode 100644
web-console/src/views/query-view/query-history-dialog/query-history-dialog.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/column-actions/column-actions.scss
create mode 100644
web-console/src/views/sql-data-loader-view/column-actions/column-actions.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/column-editor/column-editor.scss
create mode 100644
web-console/src/views/sql-data-loader-view/column-editor/column-editor.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/destination-dialog/destination-dialog.scss
create mode 100644
web-console/src/views/sql-data-loader-view/destination-dialog/destination-dialog.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/destination-form/destination-form.scss
create mode 100644
web-console/src/views/sql-data-loader-view/destination-form/destination-form.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/expression-editor-dialog/expression-editor-dialog.scss
create mode 100644
web-console/src/views/sql-data-loader-view/expression-editor-dialog/expression-editor-dialog.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/ingestion-progress-dialog/ingestion-progress-dialog.scss
create mode 100644
web-console/src/views/sql-data-loader-view/ingestion-progress-dialog/ingestion-progress-dialog.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/column-list/column-list.scss
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/column-list/column-list.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/column-list/expression-entry/expression-entry.scss
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/column-list/expression-entry/expression-entry.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/preview-error/preview-error.scss
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/preview-error/preview-error.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/preview-table/preview-table.scss
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/preview-table/preview-table.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/rollup-analysis-pane/rollup-analysis-pane.scss
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/rollup-analysis-pane/rollup-analysis-pane.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/schema-step.scss
create mode 100644
web-console/src/views/sql-data-loader-view/schema-step/schema-step.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/sql-data-loader-view.scss
create mode 100644
web-console/src/views/sql-data-loader-view/sql-data-loader-view.tsx
create mode 100644
web-console/src/views/sql-data-loader-view/title-frame/title-frame.scss
create mode 100644
web-console/src/views/sql-data-loader-view/title-frame/title-frame.tsx
create mode 100644
web-console/src/views/workbench-view/cancel-query-dialog/cancel-query-dialog.tsx
create mode 100644
web-console/src/views/workbench-view/connect-external-data-dialog/connect-external-data-dialog.scss
create mode 100644
web-console/src/views/workbench-view/connect-external-data-dialog/connect-external-data-dialog.tsx
create mode 100644 web-console/src/views/workbench-view/demo-queries.ts
create mode 100644
web-console/src/views/workbench-view/execution-details-dialog/execution-details-dialog.scss
create mode 100644
web-console/src/views/workbench-view/execution-details-dialog/execution-details-dialog.tsx
create mode 100644
web-console/src/views/workbench-view/execution-details-pane-loader/execution-details-pane-loader.tsx
create mode 100644
web-console/src/views/workbench-view/execution-details-pane/execution-details-pane.scss
create mode 100644
web-console/src/views/workbench-view/execution-details-pane/execution-details-pane.tsx
create mode 100644
web-console/src/views/workbench-view/execution-error-pane/__snapshots__/execution-error-pane.spec.tsx.snap
create mode 100644
web-console/src/views/workbench-view/execution-error-pane/execution-error-pane.scss
create mode 100644
web-console/src/views/workbench-view/execution-error-pane/execution-error-pane.spec.tsx
create mode 100644
web-console/src/views/workbench-view/execution-error-pane/execution-error-pane.tsx
create mode 100644
web-console/src/views/workbench-view/execution-progress-bar-pane/__snapshots__/execution-progress-bar-pane.spec.tsx.snap
create mode 100644
web-console/src/views/workbench-view/execution-progress-bar-pane/execution-progress-bar-pane.scss
create mode 100644
web-console/src/views/workbench-view/execution-progress-bar-pane/execution-progress-bar-pane.spec.tsx
create mode 100644
web-console/src/views/workbench-view/execution-progress-bar-pane/execution-progress-bar-pane.tsx
create mode 100644
web-console/src/views/workbench-view/execution-progress-pane/execution-progress-pane.scss
create mode 100644
web-console/src/views/workbench-view/execution-progress-pane/execution-progress-pane.tsx
create mode 100644
web-console/src/views/workbench-view/execution-stages-pane-loader/execution-stages-pane-loader.tsx
create mode 100644
web-console/src/views/workbench-view/execution-stages-pane/__snapshots__/execution-stages-pane.spec.tsx.snap
create mode 100644
web-console/src/views/workbench-view/execution-stages-pane/execution-stages-pane.scss
create mode 100644
web-console/src/views/workbench-view/execution-stages-pane/execution-stages-pane.spec.tsx
create mode 100644
web-console/src/views/workbench-view/execution-stages-pane/execution-stages-pane.tsx
create mode 100644
web-console/src/views/workbench-view/execution-submit-dialog/execution-submit-dialog.scss
create mode 100644
web-console/src/views/workbench-view/execution-submit-dialog/execution-submit-dialog.tsx
create mode 100644
web-console/src/views/workbench-view/execution-summary-panel/execution-summary-panel.scss
create mode 100644
web-console/src/views/workbench-view/execution-summary-panel/execution-summary-panel.tsx
create mode 100644
web-console/src/views/workbench-view/execution-timer-panel/__snapshots__/execution-timer-panel.spec.tsx.snap
create mode 100644
web-console/src/views/workbench-view/execution-timer-panel/execution-timer-panel.scss
create mode 100644
web-console/src/views/workbench-view/execution-timer-panel/execution-timer-panel.spec.tsx
create mode 100644
web-console/src/views/workbench-view/execution-timer-panel/execution-timer-panel.tsx
create mode 100644
web-console/src/views/workbench-view/execution-warnings-pane/execution-warnings-pane.scss
create mode 100644
web-console/src/views/workbench-view/execution-warnings-pane/execution-warnings-pane.tsx
create mode 100644
web-console/src/views/workbench-view/execution-warnings-pane/warning-callout.scss
create mode 100644
web-console/src/views/workbench-view/execution-warnings-pane/warning-callout.tsx
create mode 100644
web-console/src/views/workbench-view/flexible-query-input/__snapshots__/flexible-query-input.spec.tsx.snap
create mode 100644
web-console/src/views/workbench-view/flexible-query-input/flexible-query-input.scss
create mode 100644
web-console/src/views/workbench-view/flexible-query-input/flexible-query-input.spec.tsx
create mode 100644
web-console/src/views/workbench-view/flexible-query-input/flexible-query-input.tsx
create mode 100644
web-console/src/views/workbench-view/helper-query/helper-query.scss
create mode 100644
web-console/src/views/workbench-view/helper-query/helper-query.tsx
create mode 100644
web-console/src/views/workbench-view/ingest-success-pane/__snapshots__/ingest-success-pane.spec.tsx.snap
create mode 100644
web-console/src/views/workbench-view/ingest-success-pane/ingest-success-pane.scss
create mode 100644
web-console/src/views/workbench-view/ingest-success-pane/ingest-success-pane.spec.tsx
create mode 100644
web-console/src/views/workbench-view/ingest-success-pane/ingest-success-pane.tsx
create mode 100644
web-console/src/views/workbench-view/input-format-step/input-format-step.scss
create mode 100644
web-console/src/views/workbench-view/input-format-step/input-format-step.tsx
create mode 100644
web-console/src/views/workbench-view/input-source-step/example-inputs.ts
create mode 100644
web-console/src/views/workbench-view/input-source-step/input-source-info.tsx
create mode 100644
web-console/src/views/workbench-view/input-source-step/input-source-step.scss
create mode 100644
web-console/src/views/workbench-view/input-source-step/input-source-step.tsx
create mode 100644
web-console/src/views/workbench-view/max-tasks-button/__snapshots__/max-tasks-button.spec.tsx.snap
create mode 100644
web-console/src/views/workbench-view/max-tasks-button/max-tasks-button.spec.tsx
create mode 100644
web-console/src/views/workbench-view/max-tasks-button/max-tasks-button.tsx
create mode 100644
web-console/src/views/workbench-view/metadata-change-detector.tsx
create mode 100644 web-console/src/views/workbench-view/metadata-state-store.ts
create mode 100644
web-console/src/views/workbench-view/query-tab/query-tab.scss
create mode 100644 web-console/src/views/workbench-view/query-tab/query-tab.tsx
create mode 100644
web-console/src/views/workbench-view/recent-query-task-panel/recent-query-task-panel.scss
create mode 100644
web-console/src/views/workbench-view/recent-query-task-panel/recent-query-task-panel.tsx
create mode 100644
web-console/src/views/workbench-view/result-table-pane/result-table-pane.scss
create mode 100644
web-console/src/views/workbench-view/result-table-pane/result-table-pane.tsx
create mode 100644
web-console/src/views/workbench-view/run-panel/run-panel.scss
create mode 100644 web-console/src/views/workbench-view/run-panel/run-panel.tsx
create mode 100644
web-console/src/views/workbench-view/tab-rename-dialog/tab-rename-dialog.tsx
create mode 100644
web-console/src/views/workbench-view/time-floor-menu-item/time-floor-menu-item.tsx
create mode 100644 web-console/src/views/workbench-view/work-state-store.ts
create mode 100644
web-console/src/views/workbench-view/workbench-history-dialog/workbench-history-dialog.scss
create mode 100644
web-console/src/views/workbench-view/workbench-history-dialog/workbench-history-dialog.tsx
create mode 100644 web-console/src/views/workbench-view/workbench-view.scss
create mode 100644 web-console/src/views/workbench-view/workbench-view.tsx
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
