Skip to content

Commit 583d407

Browse files
petrosaggpetrosagg
committed
adapter: fix monotonicity information for tables of sources
Signed-off-by: Petros Angelatos <[email protected]>
1 parent 9989ec8 commit 583d407

File tree

7 files changed

+36
-213
lines changed

7 files changed

+36
-213
lines changed

‎src/adapter/src/optimize/dataflows.rs‎

Lines changed: 10 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@ use chrono::{DateTime, Utc};
2020
use maplit::{btreemap, btreeset};
2121
use tracing::warn;
2222

23-
use mz_catalog::memory::objects::{CatalogItem, DataSourceDesc, Index, Source, View};
23+
use mz_catalog::memory::objects::{CatalogItem, DataSourceDesc, Index, TableDataSource, View};
2424
use mz_compute_client::controller::error::InstanceMissing;
2525
use mz_compute_types::ComputeInstanceId;
2626
use mz_compute_types::dataflows::{DataflowDesc, DataflowDescription, IndexDesc};
@@ -297,8 +297,8 @@ impl<'a> DataflowBuilder<'a> {
297297
}
298298

299299
/// Determine the given source's monotonicity.
300-
fn monotonic_source(&self, source: &Source) -> bool {
301-
match &source.data_source {
300+
fn monotonic_source(&self, data_source: &DataSourceDesc) -> bool {
301+
match data_source {
302302
DataSourceDesc::Ingestion { .. } => false,
303303
DataSourceDesc::OldSyntaxIngestion {
304304
desc, data_config, ..
@@ -352,7 +352,13 @@ impl<'a> DataflowBuilder<'a> {
352352

353353
let monotonic = self.checked_recur(|_| {
354354
match self.catalog.get_entry(&id).item() {
355-
CatalogItem::Source(source) => Ok(self.monotonic_source(source)),
355+
CatalogItem::Source(source) => Ok(self.monotonic_source(&source.data_source)),
356+
CatalogItem::Table(table) => match &table.data_source {
357+
TableDataSource::TableWrites { .. } => Ok(false),
358+
TableDataSource::DataSource { desc, timeline: _ } => {
359+
Ok(self.monotonic_source(desc))
360+
}
361+
},
356362
CatalogItem::View(View { optimized_expr, .. }) => {
357363
let view_expr = optimized_expr.as_ref().clone().into_inner();
358364

@@ -393,7 +399,6 @@ impl<'a> DataflowBuilder<'a> {
393399
CatalogItem::Secret(_)
394400
| CatalogItem::Type(_)
395401
| CatalogItem::Connection(_)
396-
| CatalogItem::Table(_)
397402
| CatalogItem::Log(_)
398403
| CatalogItem::MaterializedView(_)
399404
| CatalogItem::Sink(_)

‎test/testdrive/kafka-include-key-sources.td‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -432,7 +432,7 @@ Target cluster: quickstart
432432

433433
? EXPLAIN OPTIMIZED PLAN AS VERBOSE TEXT FOR SELECT DISTINCT named FROM envelope_none_with_key_tbl;
434434
Explained Query:
435-
Distinct project=[#0]
435+
Distinct project=[#0] monotonic
436436
Project (#0)
437437
ReadStorage materialize.public.envelope_none_with_key_tbl
438438

@@ -444,7 +444,7 @@ Target cluster: quickstart
444444

445445
? EXPLAIN OPTIMIZED PLAN AS VERBOSE TEXT FOR SELECT DISTINCT named FROM envelope_none_with_key_tbl;
446446
Explained Query:
447-
Distinct project=[#0]
447+
Distinct project=[#0] monotonic
448448
Project (#0)
449449
ReadIndex on=envelope_none_with_key_tbl envelope_none_with_key_tbl_primary_idx=[*** full scan ***]
450450

‎test/testdrive/materializations.td‎

Lines changed: 4 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -479,38 +479,10 @@ c d
479479
JOIN mz_introspection.mz_dataflow_operator_dataflows mdod ON mash.operator_id = mdod.id
480480
JOIN mz_introspection.mz_compute_exports USING (dataflow_id)
481481
WHERE export_id LIKE 'u%'
482-
"Dataflow: materialize.public.test4" "Arrange ReduceMinsMaxes"
483-
"Dataflow: materialize.public.test4" "Arranged MinsMaxesHierarchical input"
484-
"Dataflow: materialize.public.test4" "Arranged MinsMaxesHierarchical input"
485-
"Dataflow: materialize.public.test4" "Arranged MinsMaxesHierarchical input"
486-
"Dataflow: materialize.public.test4" "Arranged MinsMaxesHierarchical input"
487-
"Dataflow: materialize.public.test4" "Arranged MinsMaxesHierarchical input"
488-
"Dataflow: materialize.public.test4" "Arranged MinsMaxesHierarchical input"
489-
"Dataflow: materialize.public.test4" "Arranged MinsMaxesHierarchical input"
490-
"Dataflow: materialize.public.test4" ReduceMinsMaxes
491-
"Dataflow: materialize.public.test4" "Reduced Fallibly MinsMaxesHierarchical"
492-
"Dataflow: materialize.public.test4" "Reduced Fallibly MinsMaxesHierarchical"
493-
"Dataflow: materialize.public.test4" "Reduced Fallibly MinsMaxesHierarchical"
494-
"Dataflow: materialize.public.test4" "Reduced Fallibly MinsMaxesHierarchical"
495-
"Dataflow: materialize.public.test4" "Reduced Fallibly MinsMaxesHierarchical"
496-
"Dataflow: materialize.public.test4" "Reduced Fallibly MinsMaxesHierarchical"
497-
"Dataflow: materialize.public.test4" "Reduced Fallibly MinsMaxesHierarchical"
498-
"Dataflow: materialize.public.test6" "Arrange ReduceMinsMaxes"
499-
"Dataflow: materialize.public.test6" "Arranged MinsMaxesHierarchical input"
500-
"Dataflow: materialize.public.test6" "Arranged MinsMaxesHierarchical input"
501-
"Dataflow: materialize.public.test6" "Arranged MinsMaxesHierarchical input"
502-
"Dataflow: materialize.public.test6" "Arranged MinsMaxesHierarchical input"
503-
"Dataflow: materialize.public.test6" "Arranged MinsMaxesHierarchical input"
504-
"Dataflow: materialize.public.test6" "Arranged MinsMaxesHierarchical input"
505-
"Dataflow: materialize.public.test6" "Arranged MinsMaxesHierarchical input"
506-
"Dataflow: materialize.public.test6" ReduceMinsMaxes
507-
"Dataflow: materialize.public.test6" "Reduced Fallibly MinsMaxesHierarchical"
508-
"Dataflow: materialize.public.test6" "Reduced Fallibly MinsMaxesHierarchical"
509-
"Dataflow: materialize.public.test6" "Reduced Fallibly MinsMaxesHierarchical"
510-
"Dataflow: materialize.public.test6" "Reduced Fallibly MinsMaxesHierarchical"
511-
"Dataflow: materialize.public.test6" "Reduced Fallibly MinsMaxesHierarchical"
512-
"Dataflow: materialize.public.test6" "Reduced Fallibly MinsMaxesHierarchical"
513-
"Dataflow: materialize.public.test6" "Reduced Fallibly MinsMaxesHierarchical"
482+
"Dataflow: materialize.public.test4" "ArrangeMonotonic [val: empty]"
483+
"Dataflow: materialize.public.test4" "ReduceMonotonic"
484+
"Dataflow: materialize.public.test6" "ArrangeMonotonic [val: empty]"
485+
"Dataflow: materialize.public.test6" "ReduceMonotonic"
514486
"Dataflow: materialize.public.data_view_idx" "ArrangeBy[[Column(0, \"a\")]]"
515487
"Dataflow: materialize.public.data_view_idx" "ArrangeBy[[Column(0, \"a\")]]-errors"
516488
"Dataflow: materialize.public.data_view_primary_idx" "ArrangeBy[[Column(0, \"a\"), Column(1, \"b\")]]"

‎test/testdrive/monotonic.td‎

Lines changed: 7 additions & 63 deletions
Original file line numberDiff line numberDiff line change
@@ -116,7 +116,7 @@ Target cluster: quickstart
116116

117117
? EXPLAIN PHYSICAL PLAN AS VERBOSE TEXT FOR SELECT * FROM v3
118118
Explained Query:
119-
TopK::MonotonicTopK order_by=[#1 asc nulls_last] limit=3 must_consolidate
119+
TopK::MonotonicTopK order_by=[#1 asc nulls_last] limit=3
120120
Get::PassArrangements materialize.public.non_dbz_data_indexed_tbl
121121
raw=true
122122

@@ -218,68 +218,12 @@ Target cluster: quickstart
218218
JOIN mz_introspection.mz_dataflow_operator_dataflows mdod ON mash.operator_id = mdod.id
219219
JOIN mz_introspection.mz_compute_exports USING (dataflow_id)
220220
WHERE export_id LIKE 'u%'
221-
"Dataflow: materialize.public.i6_primary_idx" "Arranged TopK input"
222-
"Dataflow: materialize.public.i6_primary_idx" "Arranged TopK input"
223-
"Dataflow: materialize.public.i6_primary_idx" "Arranged TopK input"
224-
"Dataflow: materialize.public.i6_primary_idx" "Arranged TopK input"
225-
"Dataflow: materialize.public.i6_primary_idx" "Arranged TopK input"
226-
"Dataflow: materialize.public.i6_primary_idx" "Arranged TopK input"
227-
"Dataflow: materialize.public.i6_primary_idx" "Arranged TopK input"
228-
"Dataflow: materialize.public.i6_primary_idx" "Reduced TopK input"
229-
"Dataflow: materialize.public.i6_primary_idx" "Reduced TopK input"
230-
"Dataflow: materialize.public.i6_primary_idx" "Reduced TopK input"
231-
"Dataflow: materialize.public.i6_primary_idx" "Reduced TopK input"
232-
"Dataflow: materialize.public.i6_primary_idx" "Reduced TopK input"
233-
"Dataflow: materialize.public.i6_primary_idx" "Reduced TopK input"
234-
"Dataflow: materialize.public.i6_primary_idx" "Reduced TopK input"
235-
"Dataflow: materialize.public.monotonic_fused" "Arrange ReduceMinsMaxes"
236-
"Dataflow: materialize.public.monotonic_fused" "Arranged MinsMaxesHierarchical input"
237-
"Dataflow: materialize.public.monotonic_fused" "Arranged MinsMaxesHierarchical input"
238-
"Dataflow: materialize.public.monotonic_fused" "Arranged MinsMaxesHierarchical input"
239-
"Dataflow: materialize.public.monotonic_fused" "Arranged MinsMaxesHierarchical input"
240-
"Dataflow: materialize.public.monotonic_fused" "Arranged MinsMaxesHierarchical input"
241-
"Dataflow: materialize.public.monotonic_fused" "Arranged MinsMaxesHierarchical input"
242-
"Dataflow: materialize.public.monotonic_fused" "Arranged MinsMaxesHierarchical input"
243-
"Dataflow: materialize.public.monotonic_fused" ReduceMinsMaxes
244-
"Dataflow: materialize.public.monotonic_fused" "Reduced Fallibly MinsMaxesHierarchical"
245-
"Dataflow: materialize.public.monotonic_fused" "Reduced Fallibly MinsMaxesHierarchical"
246-
"Dataflow: materialize.public.monotonic_fused" "Reduced Fallibly MinsMaxesHierarchical"
247-
"Dataflow: materialize.public.monotonic_fused" "Reduced Fallibly MinsMaxesHierarchical"
248-
"Dataflow: materialize.public.monotonic_fused" "Reduced Fallibly MinsMaxesHierarchical"
249-
"Dataflow: materialize.public.monotonic_fused" "Reduced Fallibly MinsMaxesHierarchical"
250-
"Dataflow: materialize.public.monotonic_fused" "Reduced Fallibly MinsMaxesHierarchical"
251-
"Dataflow: materialize.public.monotonic_max" "Arrange ReduceMinsMaxes"
252-
"Dataflow: materialize.public.monotonic_max" "Arranged MinsMaxesHierarchical input"
253-
"Dataflow: materialize.public.monotonic_max" "Arranged MinsMaxesHierarchical input"
254-
"Dataflow: materialize.public.monotonic_max" "Arranged MinsMaxesHierarchical input"
255-
"Dataflow: materialize.public.monotonic_max" "Arranged MinsMaxesHierarchical input"
256-
"Dataflow: materialize.public.monotonic_max" "Arranged MinsMaxesHierarchical input"
257-
"Dataflow: materialize.public.monotonic_max" "Arranged MinsMaxesHierarchical input"
258-
"Dataflow: materialize.public.monotonic_max" "Arranged MinsMaxesHierarchical input"
259-
"Dataflow: materialize.public.monotonic_max" ReduceMinsMaxes
260-
"Dataflow: materialize.public.monotonic_max" "Reduced Fallibly MinsMaxesHierarchical"
261-
"Dataflow: materialize.public.monotonic_max" "Reduced Fallibly MinsMaxesHierarchical"
262-
"Dataflow: materialize.public.monotonic_max" "Reduced Fallibly MinsMaxesHierarchical"
263-
"Dataflow: materialize.public.monotonic_max" "Reduced Fallibly MinsMaxesHierarchical"
264-
"Dataflow: materialize.public.monotonic_max" "Reduced Fallibly MinsMaxesHierarchical"
265-
"Dataflow: materialize.public.monotonic_max" "Reduced Fallibly MinsMaxesHierarchical"
266-
"Dataflow: materialize.public.monotonic_max" "Reduced Fallibly MinsMaxesHierarchical"
267-
"Dataflow: materialize.public.monotonic_min" "Arrange ReduceMinsMaxes"
268-
"Dataflow: materialize.public.monotonic_min" "Arranged MinsMaxesHierarchical input"
269-
"Dataflow: materialize.public.monotonic_min" "Arranged MinsMaxesHierarchical input"
270-
"Dataflow: materialize.public.monotonic_min" "Arranged MinsMaxesHierarchical input"
271-
"Dataflow: materialize.public.monotonic_min" "Arranged MinsMaxesHierarchical input"
272-
"Dataflow: materialize.public.monotonic_min" "Arranged MinsMaxesHierarchical input"
273-
"Dataflow: materialize.public.monotonic_min" "Arranged MinsMaxesHierarchical input"
274-
"Dataflow: materialize.public.monotonic_min" "Arranged MinsMaxesHierarchical input"
275-
"Dataflow: materialize.public.monotonic_min" ReduceMinsMaxes
276-
"Dataflow: materialize.public.monotonic_min" "Reduced Fallibly MinsMaxesHierarchical"
277-
"Dataflow: materialize.public.monotonic_min" "Reduced Fallibly MinsMaxesHierarchical"
278-
"Dataflow: materialize.public.monotonic_min" "Reduced Fallibly MinsMaxesHierarchical"
279-
"Dataflow: materialize.public.monotonic_min" "Reduced Fallibly MinsMaxesHierarchical"
280-
"Dataflow: materialize.public.monotonic_min" "Reduced Fallibly MinsMaxesHierarchical"
281-
"Dataflow: materialize.public.monotonic_min" "Reduced Fallibly MinsMaxesHierarchical"
282-
"Dataflow: materialize.public.monotonic_min" "Reduced Fallibly MinsMaxesHierarchical"
221+
"Dataflow: materialize.public.monotonic_fused" "ArrangeMonotonic [val: empty]"
222+
"Dataflow: materialize.public.monotonic_fused" "ReduceMonotonic"
223+
"Dataflow: materialize.public.monotonic_max" "ArrangeMonotonic [val: empty]"
224+
"Dataflow: materialize.public.monotonic_max" "ReduceMonotonic"
225+
"Dataflow: materialize.public.monotonic_min" "ArrangeMonotonic [val: empty]"
226+
"Dataflow: materialize.public.monotonic_min" "ReduceMonotonic"
283227
"Dataflow: materialize.public.non_dbz_data_indexed_primary_idx" "ArrangeBy[[Column(0, \"value\")]]"
284228
"Dataflow: materialize.public.non_dbz_data_indexed_primary_idx" "ArrangeBy[[Column(0, \"value\")]]-errors"
285229
"Dataflow: materialize.public.i1_primary_idx" "ArrangeBy[[Column(0, \"b\")]]"

‎test/testdrive/source-linear-operators.td‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,7 @@ Explained Query:
230230
Union
231231
Project (#1, #0)
232232
Map (1)
233-
Reduce aggregates=[sum(#0{b})]
233+
Reduce aggregates=[sum(#0{b})] monotonic
234234
Project (#1)
235235
Filter (#0 = 1)
236236
ReadStorage materialize.public.data_tbl

‎test/testdrive/top-1-monotonic.td‎

Lines changed: 12 additions & 96 deletions
Original file line numberDiff line numberDiff line change
@@ -287,102 +287,18 @@ $ kafka-ingest format=avro topic=top1 schema=${schema} timestamp=5
287287
JOIN mz_introspection.mz_dataflow_operator_dataflows mdod ON mash.operator_id = mdod.id
288288
JOIN mz_introspection.mz_compute_exports USING (dataflow_id)
289289
WHERE export_id LIKE 'u%'
290-
"Dataflow: group_by_in_top_1" "Arranged TopK input"
291-
"Dataflow: group_by_in_top_1" "Arranged TopK input"
292-
"Dataflow: group_by_in_top_1" "Arranged TopK input"
293-
"Dataflow: group_by_in_top_1" "Arranged TopK input"
294-
"Dataflow: group_by_in_top_1" "Arranged TopK input"
295-
"Dataflow: group_by_in_top_1" "Arranged TopK input"
296-
"Dataflow: group_by_in_top_1" "Arranged TopK input"
297-
"Dataflow: group_by_in_top_1" "Arranged TopK input"
298-
"Dataflow: group_by_in_top_1" "Reduced TopK input"
299-
"Dataflow: group_by_in_top_1" "Reduced TopK input"
300-
"Dataflow: group_by_in_top_1" "Reduced TopK input"
301-
"Dataflow: group_by_in_top_1" "Reduced TopK input"
302-
"Dataflow: group_by_in_top_1" "Reduced TopK input"
303-
"Dataflow: group_by_in_top_1" "Reduced TopK input"
304-
"Dataflow: group_by_in_top_1" "Reduced TopK input"
305-
"Dataflow: group_by_in_top_1" "Reduced TopK input"
306-
"Dataflow: group_by_limit" "Arranged TopK input"
307-
"Dataflow: group_by_limit" "Arranged TopK input"
308-
"Dataflow: group_by_limit" "Arranged TopK input"
309-
"Dataflow: group_by_limit" "Arranged TopK input"
310-
"Dataflow: group_by_limit" "Arranged TopK input"
311-
"Dataflow: group_by_limit" "Arranged TopK input"
312-
"Dataflow: group_by_limit" "Arranged TopK input"
313-
"Dataflow: group_by_limit" "Arranged TopK input"
314-
"Dataflow: group_by_limit" "Reduced TopK input"
315-
"Dataflow: group_by_limit" "Reduced TopK input"
316-
"Dataflow: group_by_limit" "Reduced TopK input"
317-
"Dataflow: group_by_limit" "Reduced TopK input"
318-
"Dataflow: group_by_limit" "Reduced TopK input"
319-
"Dataflow: group_by_limit" "Reduced TopK input"
320-
"Dataflow: group_by_limit" "Reduced TopK input"
321-
"Dataflow: group_by_limit" "Reduced TopK input"
322-
"Dataflow: group_by_order_by_in_top_1" "Arranged TopK input"
323-
"Dataflow: group_by_order_by_in_top_1" "Arranged TopK input"
324-
"Dataflow: group_by_order_by_in_top_1" "Arranged TopK input"
325-
"Dataflow: group_by_order_by_in_top_1" "Arranged TopK input"
326-
"Dataflow: group_by_order_by_in_top_1" "Arranged TopK input"
327-
"Dataflow: group_by_order_by_in_top_1" "Arranged TopK input"
328-
"Dataflow: group_by_order_by_in_top_1" "Arranged TopK input"
329-
"Dataflow: group_by_order_by_in_top_1" "Arranged TopK input"
330-
"Dataflow: group_by_order_by_in_top_1" "Reduced TopK input"
331-
"Dataflow: group_by_order_by_in_top_1" "Reduced TopK input"
332-
"Dataflow: group_by_order_by_in_top_1" "Reduced TopK input"
333-
"Dataflow: group_by_order_by_in_top_1" "Reduced TopK input"
334-
"Dataflow: group_by_order_by_in_top_1" "Reduced TopK input"
335-
"Dataflow: group_by_order_by_in_top_1" "Reduced TopK input"
336-
"Dataflow: group_by_order_by_in_top_1" "Reduced TopK input"
337-
"Dataflow: group_by_order_by_in_top_1" "Reduced TopK input"
338-
"Dataflow: limit_only" "Arranged TopK input"
339-
"Dataflow: limit_only" "Arranged TopK input"
340-
"Dataflow: limit_only" "Arranged TopK input"
341-
"Dataflow: limit_only" "Arranged TopK input"
342-
"Dataflow: limit_only" "Arranged TopK input"
343-
"Dataflow: limit_only" "Arranged TopK input"
344-
"Dataflow: limit_only" "Arranged TopK input"
345-
"Dataflow: limit_only" "Arranged TopK input"
346-
"Dataflow: limit_only" "Reduced TopK input"
347-
"Dataflow: limit_only" "Reduced TopK input"
348-
"Dataflow: limit_only" "Reduced TopK input"
349-
"Dataflow: limit_only" "Reduced TopK input"
350-
"Dataflow: limit_only" "Reduced TopK input"
351-
"Dataflow: limit_only" "Reduced TopK input"
352-
"Dataflow: limit_only" "Reduced TopK input"
353-
"Dataflow: limit_only" "Reduced TopK input"
354-
"Dataflow: order_by_desc_limit" "Arranged TopK input"
355-
"Dataflow: order_by_desc_limit" "Arranged TopK input"
356-
"Dataflow: order_by_desc_limit" "Arranged TopK input"
357-
"Dataflow: order_by_desc_limit" "Arranged TopK input"
358-
"Dataflow: order_by_desc_limit" "Arranged TopK input"
359-
"Dataflow: order_by_desc_limit" "Arranged TopK input"
360-
"Dataflow: order_by_desc_limit" "Arranged TopK input"
361-
"Dataflow: order_by_desc_limit" "Arranged TopK input"
362-
"Dataflow: order_by_desc_limit" "Reduced TopK input"
363-
"Dataflow: order_by_desc_limit" "Reduced TopK input"
364-
"Dataflow: order_by_desc_limit" "Reduced TopK input"
365-
"Dataflow: order_by_desc_limit" "Reduced TopK input"
366-
"Dataflow: order_by_desc_limit" "Reduced TopK input"
367-
"Dataflow: order_by_desc_limit" "Reduced TopK input"
368-
"Dataflow: order_by_desc_limit" "Reduced TopK input"
369-
"Dataflow: order_by_desc_limit" "Reduced TopK input"
370-
"Dataflow: order_by_limit" "Arranged TopK input"
371-
"Dataflow: order_by_limit" "Arranged TopK input"
372-
"Dataflow: order_by_limit" "Arranged TopK input"
373-
"Dataflow: order_by_limit" "Arranged TopK input"
374-
"Dataflow: order_by_limit" "Arranged TopK input"
375-
"Dataflow: order_by_limit" "Arranged TopK input"
376-
"Dataflow: order_by_limit" "Arranged TopK input"
377-
"Dataflow: order_by_limit" "Arranged TopK input"
378-
"Dataflow: order_by_limit" "Reduced TopK input"
379-
"Dataflow: order_by_limit" "Reduced TopK input"
380-
"Dataflow: order_by_limit" "Reduced TopK input"
381-
"Dataflow: order_by_limit" "Reduced TopK input"
382-
"Dataflow: order_by_limit" "Reduced TopK input"
383-
"Dataflow: order_by_limit" "Reduced TopK input"
384-
"Dataflow: order_by_limit" "Reduced TopK input"
385-
"Dataflow: order_by_limit" "Reduced TopK input"
290+
"Dataflow: group_by_in_top_1" "Arranged MonotonicTop1 partial [val: empty]"
291+
"Dataflow: group_by_in_top_1" "MonotonicTop1"
292+
"Dataflow: group_by_limit" "Arranged MonotonicTop1 partial [val: empty]"
293+
"Dataflow: group_by_limit" "MonotonicTop1"
294+
"Dataflow: group_by_order_by_in_top_1" "Arranged MonotonicTop1 partial [val: empty]"
295+
"Dataflow: group_by_order_by_in_top_1" "MonotonicTop1"
296+
"Dataflow: limit_only" "Arranged MonotonicTop1 partial [val: empty]"
297+
"Dataflow: limit_only" "MonotonicTop1"
298+
"Dataflow: order_by_desc_limit" "Arranged MonotonicTop1 partial [val: empty]"
299+
"Dataflow: order_by_desc_limit" "MonotonicTop1"
300+
"Dataflow: order_by_limit" "Arranged MonotonicTop1 partial [val: empty]"
301+
"Dataflow: order_by_limit" "MonotonicTop1"
386302
"Dataflow: group_by_in_top_1" "ArrangeBy[[Column(0)]]"
387303
"Dataflow: group_by_in_top_1" "ArrangeBy[[Column(0)]]"
388304
"Dataflow: group_by_in_top_1" "ArrangeBy[[Column(0)]]"

‎test/testdrive/top-k-monotonic.td‎

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -295,17 +295,3 @@ a
295295
"Dataflow: materialize.public.v_other_primary_idx" "ArrangeBy[[Column(0, \"a\")]]-errors"
296296
"Dataflow: materialize.public.v_other_primary_idx" "Arranged TopK input"
297297
"Dataflow: materialize.public.v_other_primary_idx" "Reduced TopK input"
298-
"Dataflow: materialize.public.v_other_primary_idx" "Arranged TopK input"
299-
"Dataflow: materialize.public.v_other_primary_idx" "Arranged TopK input"
300-
"Dataflow: materialize.public.v_other_primary_idx" "Arranged TopK input"
301-
"Dataflow: materialize.public.v_other_primary_idx" "Arranged TopK input"
302-
"Dataflow: materialize.public.v_other_primary_idx" "Arranged TopK input"
303-
"Dataflow: materialize.public.v_other_primary_idx" "Arranged TopK input"
304-
"Dataflow: materialize.public.v_other_primary_idx" "Arranged TopK input"
305-
"Dataflow: materialize.public.v_other_primary_idx" "Reduced TopK input"
306-
"Dataflow: materialize.public.v_other_primary_idx" "Reduced TopK input"
307-
"Dataflow: materialize.public.v_other_primary_idx" "Reduced TopK input"
308-
"Dataflow: materialize.public.v_other_primary_idx" "Reduced TopK input"
309-
"Dataflow: materialize.public.v_other_primary_idx" "Reduced TopK input"
310-
"Dataflow: materialize.public.v_other_primary_idx" "Reduced TopK input"
311-
"Dataflow: materialize.public.v_other_primary_idx" "Reduced TopK input"

0 commit comments

Comments
 (0)