spark-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From EarthsonLu <>
Subject [SparkSQL] Why this AttributeReference.exprId is not setted?
Date Tue, 25 Nov 2014 02:08:11 GMT

I can't understand this code, it seems to be a "bug", but group by of
SparkSQL just works fine.

with code below, some expressions are mapping to AttributeReferences, then
"bindReference" method will find there references. But resultAttribute's
exprId is new, I don't think it can find the true reference(But it does,
Why? How?)

  private[this] val resultExpressions = { agg =>
    agg.transform {
      case e: Expression if resultMap.contains(e) => resultMap(e)

I'm trying to write a DSL with Catalyst

View this message in context:
Sent from the Apache Spark Developers List mailing list archive at

To unsubscribe, e-mail:
For additional commands, e-mail:

View raw message