This is an automated email from the ASF dual-hosted git repository.
gian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
from cc1fdf8f8c9 Add coordinator client implementation for
LookupReferenceManager (#18192)
add b6bbf567fe8 Fix ordering for certain floats in row-based frames.
(#18181)
No new revisions were added by this update.
Summary of changes:
.../druid/benchmark/MsqSketchesBenchmark.java | 20 ++-
.../frame/FrameChannelMergerBenchmark.java | 5 +-
.../druid/benchmark/query/SqlBaseBenchmark.java | 4 +-
.../druid/msq/dart/worker/DartFrameContext.java | 10 ++
.../druid/msq/dart/worker/DartWorkerContext.java | 2 +
.../org/apache/druid/msq/exec/ControllerImpl.java | 25 ++--
.../org/apache/druid/msq/exec/FrameContext.java | 5 +
.../org/apache/druid/msq/exec/FrameWriterSpec.java | 73 ++++++++++
.../org/apache/druid/msq/exec/RunWorkOrder.java | 5 +-
.../msq/exec/std/StandardShuffleOperations.java | 24 ++--
.../druid/msq/exec/std/StandardStageProcessor.java | 7 +-
.../msq/indexing/IndexerControllerContext.java | 3 +
.../druid/msq/indexing/IndexerFrameContext.java | 10 ++
.../druid/msq/indexing/IndexerWorkerContext.java | 2 +
.../druid/msq/indexing/InputChannelsImpl.java | 14 +-
.../KeyStatisticsCollectionProcessor.java | 7 +-
.../processor/SegmentGeneratorStageProcessor.java | 3 +-
.../apache/druid/msq/kernel/QueryDefinition.java | 7 -
.../apache/druid/msq/kernel/StageDefinition.java | 24 +++-
.../kernel/controller/ControllerQueryKernel.java | 7 +
.../kernel/controller/ControllerStageTracker.java | 21 ++-
.../druid/msq/querykit/BaseLeafStageProcessor.java | 16 ++-
.../WindowOperatorQueryStageProcessor.java | 8 +-
.../querykit/common/OffsetLimitStageProcessor.java | 5 +-
.../common/SortMergeJoinFrameProcessor.java | 5 +-
.../common/SortMergeJoinStageProcessor.java | 8 +-
.../groupby/GroupByPostShuffleStageProcessor.java | 8 +-
.../results/ExportResultsStageProcessor.java | 3 +-
.../results/QueryResultStageProcessor.java | 3 +-
.../apache/druid/msq/sql/MSQTaskQueryMaker.java | 8 ++
.../ClusterByStatisticsCollectorImpl.java | 4 +-
.../druid/msq/util/MultiStageQueryContext.java | 26 ++++
.../druid/msq/kernel/StageDefinitionTest.java | 18 ++-
.../controller/BaseControllerQueryKernelTest.java | 8 +-
.../BroadcastJoinSegmentMapFnProcessorTest.java | 4 +-
.../druid/msq/querykit/FrameProcessorTestBase.java | 4 +-
.../WindowOperatorQueryFrameProcessorTest.java | 10 +-
.../common/SortMergeJoinFrameProcessorTest.java | 4 +-
.../results/QueryResultsFrameProcessorTest.java | 15 ++-
.../querykit/scan/ScanQueryFrameProcessorTest.java | 8 +-
.../druid/msq/rpc/BaseWorkerClientImplTest.java | 2 +-
.../output/ChannelStageOutputReaderTest.java | 12 +-
.../druid/msq/statistics/ByteRowKeySerdeTest.java | 3 +-
.../ClusterByStatisticsCollectorImplTest.java | 29 +++-
.../statistics/DelegateOrMinKeyCollectorTest.java | 2 +
.../msq/statistics/KeyCollectorTestUtils.java | 3 +-
.../QuantilesSketchKeyCollectorTest.java | 5 +-
.../serde/KeyCollectorSnapshotSerializerTest.java | 11 +-
.../org/apache/druid/msq/test/MSQTestBase.java | 2 +
.../druid/msq/test/MSQTestWorkerContext.java | 21 ++-
.../msq1.iq | 5 +-
.../msqJoinHint.iq | 3 +
.../msqNestedJoinHint.iq | 3 +
.../druid/collections/QueueNonBlockingPool.java | 8 ++
.../main/java/org/apache/druid/frame/Frame.java | 28 +++-
.../java/org/apache/druid/frame/FrameType.java | 67 ++++++++--
.../frame/allocation/MemoryAllocatorFactory.java | 2 +-
.../druid/frame/field/DoubleArrayFieldReader.java | 10 +-
.../druid/frame/field/DoubleFieldReader.java | 32 +++--
.../druid/frame/field/DoubleFieldWriter.java | 20 ++-
.../org/apache/druid/frame/field/FieldReaders.java | 11 +-
.../org/apache/druid/frame/field/FieldWriters.java | 30 +++--
.../druid/frame/field/FloatArrayFieldReader.java | 10 +-
.../apache/druid/frame/field/FloatFieldReader.java | 31 +++--
.../apache/druid/frame/field/FloatFieldWriter.java | 19 ++-
.../druid/frame/field/NumericArrayFieldWriter.java | 15 ++-
.../org/apache/druid/frame/field/RowReader.java | 3 +-
.../apache/druid/frame/field/TransformUtils.java | 125 +++++++++++++++++-
.../java/org/apache/druid/frame/key/ClusterBy.java | 5 +-
.../druid/frame/key/FrameComparisonWidgetImpl.java | 9 +-
.../org/apache/druid/frame/key/RowKeyReader.java | 13 +-
.../processor/FrameChannelHashPartitioner.java | 24 +++-
.../druid/frame/processor/FrameChannelMerger.java | 4 +-
.../apache/druid/frame/processor/SuperSorter.java | 9 +-
.../org/apache/druid/frame/read/FrameReader.java | 143 +++++++++++++-------
.../apache/druid/frame/read/FrameReaderUtils.java | 47 ++++---
.../columnar/ColumnarFrameCursorFactory.java | 3 +-
.../segment/columnar/FrameQueryableIndex.java | 3 +-
.../frame/segment/row/CursorFrameRowPointer.java | 3 +-
.../segment/row/FrameColumnSelectorFactory.java | 74 ++++++++---
.../frame/segment/row/RowFrameCursorFactory.java | 3 +-
.../org/apache/druid/frame/write/FrameWriter.java | 2 +-
.../org/apache/druid/frame/write/FrameWriters.java | 21 ++-
.../druid/frame/write/RowBasedFrameWriter.java | 7 +-
.../frame/write/RowBasedFrameWriterFactory.java | 18 ++-
.../frame/write/columnar/ColumnarFrameWriter.java | 2 +-
.../write/columnar/ColumnarFrameWriterFactory.java | 2 +-
.../druid/query/rowsandcols/RowsAndColumns.java | 3 +-
.../concrete/ColumnBasedFrameRowsAndColumns.java | 3 +-
.../concrete/RowBasedFrameRowsAndColumns.java | 5 +-
.../java/org/apache/druid/frame/FrameTest.java | 8 +-
.../ReadableByteChunksFrameChannelTest.java | 4 +-
.../channel/ReadableConcatFrameChannelTest.java | 2 +-
.../ReadableInputStreamFrameChannelTest.java | 7 +-
.../frame/field/DoubleArrayFieldReaderTest.java | 45 +++++--
.../druid/frame/field/DoubleFieldReaderTest.java | 48 +++++--
.../druid/frame/field/FieldReaderRACTest.java | 2 +-
.../frame/field/FloatArrayFieldReaderTest.java | 48 +++++--
.../druid/frame/field/FloatFieldReaderTest.java | 48 +++++--
.../frame/field/StringArrayFieldWriterTest.java | 4 +-
.../druid/frame/field/StringFieldWriterTest.java | 4 +-
.../druid/frame/field/TransformUtilsTest.java | 147 ++++++++++++++++-----
.../file/FrameFileHttpResponseHandlerTest.java | 2 +-
.../druid/frame/file/FrameFileWriterTest.java | 2 +-
.../druid/frame/key/ByteRowKeyComparatorTest.java | 5 +-
.../frame/key/FrameComparisonWidgetImplTest.java | 23 +++-
.../org/apache/druid/frame/key/KeyTestUtils.java | 5 +-
.../druid/frame/key/RowKeyComparatorTest.java | 5 +-
.../apache/druid/frame/key/RowKeyReaderTest.java | 12 +-
.../org/apache/druid/frame/key/RowKeyTest.java | 47 +++----
.../processor/FrameProcessorExecutorTest.java | 4 +-
.../frame/processor/OutputChannelFactoryTest.java | 2 +-
.../processor/ReadableFileFrameChannelTest.java | 2 +-
.../frame/processor/RunAllFullyWidgetTest.java | 2 +-
.../druid/frame/processor/SuperSorterTest.java | 86 +++++++-----
.../processor/test/TestFrameProcessorUtils.java | 2 +-
.../frame/segment/FrameCursorFactoryTest.java | 4 +-
.../druid/frame/testutil/FrameSequenceBuilder.java | 25 +---
.../apache/druid/frame/write/FrameWriterTest.java | 62 +++++----
.../druid/frame/write/FrameWriterTestData.java | 109 ++++++++-------
.../apache/druid/frame/write/FrameWritersTest.java | 26 +++-
.../druid/frame/write/RowBasedFrameWriterTest.java | 5 +-
.../FrameBasedInlineDataSourceSerializerTest.java | 4 +-
.../concrete/RowBasedFrameRowsAndColumnsTest.java | 4 +-
.../druid/segment/filter/BaseFilterTest.java | 4 +-
.../segment/virtual/ExpressionSelectorsTest.java | 4 +-
.../qaArray/sql_explain.msq.iq | 22 +++
.../funcs_and_sql_func_json_keys.03.msq.iq | 3 +
.../funcs_and_sql_func_json_object.03.msq.iq | 2 +
.../funcs_and_sql_func_json_paths.03.msq.iq | 1 +
.../funcs_and_sql_func_json_query.04.msq.iq | 3 +
.../funcs_and_sql_func_json_value.04.msq.iq | 1 +
.../funcs_and_sql_func_parse_json.02.msq.iq | 1 +
.../funcs_and_sql_func_to_json_string.02.msq.iq | 1 +
.../funcs_and_sql_func_try_parse_json.02.msq.iq | 1 +
.../qaUnnest/array_sql_explain.msq.iq | 4 +
.../qaUnnest/mv_sql_explain.msq.iq | 4 +
.../qaWin/sql_explain.msq.iq | 4 +
138 files changed, 1615 insertions(+), 603 deletions(-)
create mode 100644
extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/exec/FrameWriterSpec.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
