fix compile; add doc

This commit is contained in:
Zoltan Haindrich 2024-12-19 07:27:37 +00:00
parent d1e8ae160c
commit c518b488b6
3 changed files with 5 additions and 2 deletions

View File

@ -103,7 +103,7 @@ public class FrameBasedInlineDataSource implements DataSource
.collect(Collectors.toList()); .collect(Collectors.toList());
return Sequences.simple( return Sequences.simple(
() -> new Iterator<>() () -> new Iterator<Object[]>()
{ {
@Override @Override
public boolean hasNext() public boolean hasNext()

View File

@ -666,7 +666,7 @@ public class QuerySchedulerTest
{ {
return new LazySequence<>(() -> { return new LazySequence<>(() -> {
return new BaseSequence<>( return new BaseSequence<>(
new BaseSequence.IteratorMaker<>() new BaseSequence.IteratorMaker<Integer, Iterator<Integer>>()
{ {
@Override @Override
public Iterator<Integer> make() public Iterator<Integer> make()

View File

@ -99,6 +99,9 @@ public class DruidRelFieldTrimmer extends RelFieldTrimmer
return result(input, mapping); return result(input, mapping);
} }
/**
* Should be unnecesarry in versions having CALCITE-6715
*/
public TrimResult trimFields(LogicalCorrelate correlate, public TrimResult trimFields(LogicalCorrelate correlate,
ImmutableBitSet fieldsUsed, ImmutableBitSet fieldsUsed,
Set<RelDataTypeField> extraFields) Set<RelDataTypeField> extraFields)