https://pinot.apache.org/ logo
Join Slack
Powered by
# troubleshooting
  • d

    Damiano

    05/05/2020, 1:40 PM
    hmm ok, i try
  • m

    Mayank

    05/05/2020, 1:44 PM
    No, likely you won't be able to just take one file.
  • m

    Mayank

    05/05/2020, 1:44 PM
    You should have your changes on top of this PR, I think Kishore sent you a link on how to do that in the #CDRCA57FC channel
  • d

    Damiano

    05/05/2020, 1:45 PM
    @Mayank at the moment instead of loading the entire PR i am trying to change the files i mentioned and see what happen
  • m

    Mayank

    05/05/2020, 1:45 PM
    ok
  • m

    Mayank

    05/05/2020, 1:46 PM
    do you know why you are not getting the columns? See how the blockValMap is created in DefaultGroupByExecutor
  • m

    Mayank

    05/05/2020, 1:46 PM
    May be you need to do the same hack you did in DefaultAggregationExecutor
  • d

    Damiano

    05/05/2020, 1:47 PM
    if i will be able to run correctly this indicator i will do tons of other useful aggregators that i will share with you
  • d

    Damiano

    05/05/2020, 1:47 PM
    @Mayank yes but as you can see in GroupBy there is not about DISTINCT, do you remember?
  • d

    Damiano

    05/05/2020, 1:48 PM
    Copy code
    if (AggregationFunctionUtils.isDistinct(functionContexts) || AggregationFunctionUtils.isDrawdown(functionContexts)) { .. }
  • d

    Damiano

    05/05/2020, 1:48 PM
    we added that OR with a simple return true in isDrawdown() method
  • d

    Damiano

    05/05/2020, 1:48 PM
    in groupby i did not find anything similar
  • d

    Damiano

    05/05/2020, 1:49 PM
    i lose the secondo columns where:
    _aggregationExpressions[i] = TransformExpressionTree.compileToExpressionTree(functionContexts[i].getColumnName());
  • d

    Damiano

    05/05/2020, 1:49 PM
    column name here is col1:col2
  • d

    Damiano

    05/05/2020, 1:50 PM
    but then in the aggregationExpressions i only see the reference to the first column only
  • m

    Mayank

    05/05/2020, 1:53 PM
    hmm
  • m

    Mayank

    05/05/2020, 1:53 PM
    Sorry I cannot think of an easy hack for this one
  • d

    Damiano

    05/05/2020, 1:54 PM
    now iam starting copying your code and see what happen
  • m

    Mayank

    05/05/2020, 1:55 PM
    I don't think it will work
  • m

    Mayank

    05/05/2020, 1:55 PM
    You should properly apply the PR patch
  • m

    Mayank

    05/05/2020, 1:58 PM
    Ok, one hack:
  • m

    Mayank

    05/05/2020, 1:58 PM
    Copy code
    if (AggregationFunctionUtils.isDistinct(functionContexts)) {
          // handle distinct (col1, col2..) function
          // unlike other aggregate functions, distinct can work on multiple columns
          // so we need to build expression tree for each column
          _functions[0] = functionContexts[0].getAggregationFunction();
          _resultHolders[0] = _functions[0].createAggregationResultHolder();
    
          List<String> expressions = functionContexts[0].getExpressions();
          _expressions = new TransformExpressionTree[expressions.size()];
    
          for (int i = 0; i < _expressions.length; i++) {
            _expressions[i] = TransformExpressionTree.compileToExpressionTree(expressions.get(i));
    
          }
  • m

    Mayank

    05/05/2020, 1:58 PM
    This is from aggregationExecutor
  • m

    Mayank

    05/05/2020, 1:59 PM
    If your query has only one aggregation function, you can pass the columns in _expression[0] and _expression[1] -> the same way as previous case
  • d

    Damiano

    05/05/2020, 2:01 PM
    no it could have many
  • d

    Damiano

    05/05/2020, 2:01 PM
    you changed 17 files
  • d

    Damiano

    05/05/2020, 2:02 PM
    but many are for your custom code..
  • d

    Damiano

    05/05/2020, 2:10 PM
    @Mayank what is StarTreeGroupByExecutor exactly?
  • d

    Damiano

    05/05/2020, 2:10 PM
    for yours code only?
  • d

    Damiano

    05/05/2020, 2:13 PM
    nevermind
1...979899...166Latest