Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Adding a flag for multi value dimension selector

This commit is contained in:
Soumyava Das 2023-07-13 15:18:54 -07:00
parent 6cae4901e3
commit ef87989166
3 changed files with 1 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
processing/src/main/java/org/apache/druid/query/aggregation/first/SingleStringFirstDimensionVectorAggregator.java
View File

@ -67,10 +67,6 @@ public class SingleStringFirstDimensionVectorAggregator implements VectorAggrega
final int[] valueVector = valueDimensionVectorSelector.getRowVector(); final int[] valueVector = valueDimensionVectorSelector.getRowVector();
firstTime = buf.getLong(position); firstTime = buf.getLong(position);
int index = startRow; int index = startRow;
for (int i = startRow; i < endRow; i++) {
index = i;
break;
}
final long earliestTime = timeVector[index]; final long earliestTime = timeVector[index];
if (earliestTime < firstTime) { if (earliestTime < firstTime) {

5
processing/src/main/java/org/apache/druid/query/aggregation/first/StringFirstAggregatorFactory.java
View File

@ -288,11 +288,6 @@ public class StringFirstAggregatorFactory extends AggregatorFactory
return getFirstElementFromMvd; return getFirstElementFromMvd;
} }
public void setGetFirstElementFromMvd(boolean getFirstElementFromMvd)
{
this.getFirstElementFromMvd = getFirstElementFromMvd;
}
@Override @Override
public byte[] getCacheKey() public byte[] getCacheKey()
{ {

1
sql/src/test/java/org/apache/druid/sql/calcite/CalciteQueryTest.java
View File

@ -1270,6 +1270,7 @@ public class CalciteQueryTest extends BaseCalciteQueryTest
@Test @Test
public void testStringEarliestSingleStringDim() public void testStringEarliestSingleStringDim()
{ {
notMsqCompatible();
testQuery( testQuery(
"SELECT dim2, EARLIEST(dim1,10) AS val FROM foo GROUP BY dim2", "SELECT dim2, EARLIEST(dim1,10) AS val FROM foo GROUP BY dim2",
ImmutableList.of( ImmutableList.of(