| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/analysis/ |
| H A D | TestRelations.scala | 28 AttributeReference("a", StringType)(),
29 AttributeReference("b", StringType)(),
30 AttributeReference("c", DoubleType)(),
31 AttributeReference("d", DecimalType(10, 2))(),
32 AttributeReference("e", ShortType)())
35 AttributeReference("e", ShortType)(),
36 AttributeReference("f", StringType)(),
37 AttributeReference("g", DoubleType)(),
38 AttributeReference("h", DecimalType(10, 2))())
41 AttributeReference("top", StructType(
[all …]
|
| H A D | TypeCoercionSuite.scala | 698 AttributeReference("b", ByteType)(),
699 AttributeReference("d", DoubleType)())
701 AttributeReference("s", StringType)(),
703 AttributeReference("f", FloatType)(),
704 AttributeReference("l", LongType)())
727 AttributeReference("b", ByteType)(),
732 AttributeReference("f", FloatType)(),
733 AttributeReference("l", LongType)())
737 AttributeReference("p", FloatType)(),
742 AttributeReference("p", ByteType)(),
[all …]
|
| H A D | DecimalPrecisionSuite.scala | 39 AttributeReference("i", IntegerType)(),
40 AttributeReference("d1", DecimalType(2, 1))(),
41 AttributeReference("d2", DecimalType(5, 2))(),
42 AttributeReference("u", DecimalType.SYSTEM_DEFAULT)(),
43 AttributeReference("f", FloatType)(),
44 AttributeReference("b", DoubleType)()
191 val int = AttributeReference("a", dt)()
227 val int = AttributeReference("a", dt)()
273 val testRelation = LocalRelation(AttributeReference("a", IntegerType)())
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/dsl/ |
| H A D | package.scala | 202 def boolean: AttributeReference = AttributeReference(s, BooleanType, nullable = true)()
205 def byte: AttributeReference = AttributeReference(s, ByteType, nullable = true)()
208 def short: AttributeReference = AttributeReference(s, ShortType, nullable = true)()
211 def int: AttributeReference = AttributeReference(s, IntegerType, nullable = true)()
214 def long: AttributeReference = AttributeReference(s, LongType, nullable = true)()
217 def float: AttributeReference = AttributeReference(s, FloatType, nullable = true)()
220 def double: AttributeReference = AttributeReference(s, DoubleType, nullable = true)()
223 def string: AttributeReference = AttributeReference(s, StringType, nullable = true)()
226 def date: AttributeReference = AttributeReference(s, DateType, nullable = true)()
240 def binary: AttributeReference = AttributeReference(s, BinaryType, nullable = true)()
[all …]
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/ |
| H A D | namedExpressions.scala | 167 AttributeReference(name, child.dataType, child.nullable, metadata)(
212 case class AttributeReference( caseClass
225 def sameRef(other: AttributeReference): Boolean = this.exprId == other.exprId
228 case ar: AttributeReference =>
235 case ar: AttributeReference => sameRef(ar)
255 override def newInstance(): AttributeReference =
256 AttributeReference(name, dataType, nullable, metadata)(
262 override def withNullability(newNullability: Boolean): AttributeReference = {
270 override def withName(newName: String): AttributeReference = {
289 def withExprId(newExprId: ExprId): AttributeReference = {
[all …]
|
| H A D | windowExpressions.scala | 449 protected val rowNumber = AttributeReference("rowNumber", IntegerType, nullable = false)()
450 override val aggBufferAttributes: Seq[AttributeReference] = rowNumber :: Nil
463 val n: AttributeReference = SizeBasedWindowFunction.n
467 val n = AttributeReference("window__partition__size", IntegerType, nullable = false)()
557 private val bucket = AttributeReference("bucket", IntegerType, nullable = false)()
559 AttributeReference("bucketThreshold", IntegerType, nullable = false)()
560 private val bucketSize = AttributeReference("bucketSize", IntegerType, nullable = false)()
562 AttributeReference("bucketsWithPadding", IntegerType, nullable = false)()
607 AttributeReference(expr.sql, expr.dataType)()
617 protected val rank = AttributeReference("rank", IntegerType, nullable = false)()
[all …]
|
| H A D | AttributeSet.scala | 23 case ar: AttributeReference => ar.exprId.hashCode()
28 case (a1: AttributeReference, a2: AttributeReference) => a1.exprId == a2.exprId
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/ |
| H A D | InMemoryTableScanExec.scala | 63 case EqualTo(a: AttributeReference, l: Literal) =>
65 case EqualTo(l: Literal, a: AttributeReference) =>
68 case EqualNullSafe(a: AttributeReference, l: Literal) =>
70 case EqualNullSafe(l: Literal, a: AttributeReference) =>
73 case LessThan(a: AttributeReference, l: Literal) => statsFor(a).lowerBound < l
74 case LessThan(l: Literal, a: AttributeReference) => l < statsFor(a).upperBound
76 case LessThanOrEqual(a: AttributeReference, l: Literal) => statsFor(a).lowerBound <= l
77 case LessThanOrEqual(l: Literal, a: AttributeReference) => l <= statsFor(a).upperBound
79 case GreaterThan(a: AttributeReference, l: Literal) => l < statsFor(a).upperBound
80 case GreaterThan(l: Literal, a: AttributeReference) => statsFor(a).lowerBound < l
[all …]
|
| H A D | ColumnStats.scala | 21 import org.apache.spark.sql.catalyst.expressions.{Attribute, AttributeMap, AttributeReference, Gene…
26 val upperBound = AttributeReference(a.name + ".upperBound", a.dataType, nullable = true)()
27 val lowerBound = AttributeReference(a.name + ".lowerBound", a.dataType, nullable = true)()
28 val nullCount = AttributeReference(a.name + ".nullCount", IntegerType, nullable = false)()
29 val count = AttributeReference(a.name + ".count", IntegerType, nullable = false)()
30 val sizeInBytes = AttributeReference(a.name + ".sizeInBytes", LongType, nullable = false)()
36 val (forAttribute: AttributeMap[ColumnStatisticsSchema], schema: Seq[AttributeReference]) = {
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/aggregate/ |
| H A D | interfaces.scala | 96 AttributeReference(
167 def aggBufferAttributes: Seq[AttributeReference]
174 def inputAggBufferAttributes: Seq[AttributeReference]
374 final lazy val inputAggBufferAttributes: Seq[AttributeReference] =
384 implicit class RichAttribute(a: AttributeReference) {
386 def left: AttributeReference = a
389 def right: AttributeReference = inputAggBufferAttributes(aggBufferAttributes.indexOf(a))
532 final override lazy val aggBufferAttributes: Seq[AttributeReference] = {
534 Seq(AttributeReference("buf", BinaryType)())
537 final override lazy val inputAggBufferAttributes: Seq[AttributeReference] =
|
| H A D | Corr.scala | 42 protected val n = AttributeReference("n", DoubleType, nullable = false)()
43 protected val xAvg = AttributeReference("xAvg", DoubleType, nullable = false)()
44 protected val yAvg = AttributeReference("yAvg", DoubleType, nullable = false)()
45 protected val ck = AttributeReference("ck", DoubleType, nullable = false)()
46 protected val xMk = AttributeReference("xMk", DoubleType, nullable = false)()
47 protected val yMk = AttributeReference("yMk", DoubleType, nullable = false)()
49 override val aggBufferAttributes: Seq[AttributeReference] = Seq(n, xAvg, yAvg, ck, xMk, yMk)
|
| H A D | Last.scala | 59 private lazy val last = AttributeReference("last", child.dataType)()
61 private lazy val valueSet = AttributeReference("valueSet", BooleanType)()
63 override lazy val aggBufferAttributes: Seq[AttributeReference] = last :: valueSet :: Nil
92 override lazy val evaluateExpression: AttributeReference = last
|
| H A D | First.scala | 59 private lazy val first = AttributeReference("first", child.dataType)()
61 private lazy val valueSet = AttributeReference("valueSet", BooleanType)()
63 override lazy val aggBufferAttributes: Seq[AttributeReference] = first :: valueSet :: Nil
94 override lazy val evaluateExpression: AttributeReference = first
|
| H A D | Covariance.scala | 35 protected val n = AttributeReference("n", DoubleType, nullable = false)()
36 protected val xAvg = AttributeReference("xAvg", DoubleType, nullable = false)()
37 protected val yAvg = AttributeReference("yAvg", DoubleType, nullable = false)()
38 protected val ck = AttributeReference("ck", DoubleType, nullable = false)()
40 override val aggBufferAttributes: Seq[AttributeReference] = Seq(n, xAvg, yAvg, ck)
|
| H A D | Max.scala | 42 private lazy val max = AttributeReference("max", child.dataType)()
44 override lazy val aggBufferAttributes: Seq[AttributeReference] = max :: Nil
60 override lazy val evaluateExpression: AttributeReference = max
|
| H A D | Min.scala | 42 private lazy val min = AttributeReference("min", child.dataType)()
44 override lazy val aggBufferAttributes: Seq[AttributeReference] = min :: Nil
60 override lazy val evaluateExpression: AttributeReference = min
|
| H A D | CentralMomentAgg.scala | 57 protected val n = AttributeReference("n", DoubleType, nullable = false)()
58 protected val avg = AttributeReference("avg", DoubleType, nullable = false)()
59 protected val m2 = AttributeReference("m2", DoubleType, nullable = false)()
60 protected val m3 = AttributeReference("m3", DoubleType, nullable = false)()
61 protected val m4 = AttributeReference("m4", DoubleType, nullable = false)()
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/ |
| H A D | AttributeSetSuite.scala | 25 val aUpper = AttributeReference("A", IntegerType)(exprId = ExprId(1))
26 val aLower = AttributeReference("a", IntegerType)(exprId = ExprId(1))
27 val fakeA = AttributeReference("a", IntegerType)(exprId = ExprId(3))
30 val bUpper = AttributeReference("B", IntegerType)(exprId = ExprId(2))
31 val bLower = AttributeReference("b", IntegerType)(exprId = ExprId(2))
|
| H A D | ExpressionSetSuite.scala | 26 val aUpper = AttributeReference("A", IntegerType)(exprId = ExprId(1))
27 val aLower = AttributeReference("a", IntegerType)(exprId = ExprId(1))
28 val fakeA = AttributeReference("a", IntegerType)(exprId = ExprId(3))
30 val bUpper = AttributeReference("B", IntegerType)(exprId = ExprId(2))
31 val bLower = AttributeReference("b", IntegerType)(exprId = ExprId(2))
|
| /dports/devel/spark/spark-2.1.1/sql/hive/src/test/scala/org/apache/spark/sql/hive/execution/ |
| H A D | ScriptTransformationSuite.scala | 26 import org.apache.spark.sql.catalyst.expressions.{Attribute, AttributeReference}
59 output = Seq(AttributeReference("a", StringType)()),
73 output = Seq(AttributeReference("a", StringType)()),
88 output = Seq(AttributeReference("a", StringType)()),
105 output = Seq(AttributeReference("a", StringType)()),
122 output = Seq(AttributeReference("a", StringType)()),
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/expressions/aggregate/ |
| H A D | ApproximatePercentileSuite.scala | 26 import org.apache.spark.sql.catalyst.expressions.{Alias, AttributeReference, BoundReference, Cast, …
213 val attribute = AttributeReference("a", DoubleType)()
217 accuracyExpression = AttributeReference("b", IntegerType)())
237 AttributeReference("a", DoubleType)(),
253 AttributeReference("a", DoubleType)(),
269 AttributeReference("a", DoubleType)(),
|
| /dports/devel/spark/spark-2.1.1/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/plans/ |
| H A D | LogicalPlanSuite.scala | 21 import org.apache.spark.sql.catalyst.expressions.{Attribute, AttributeReference}
75 val relation = LocalRelation(AttributeReference("a", IntegerType, nullable = true)())
77 Seq(AttributeReference("a", IntegerType, nullable = true)())) {
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/ |
| H A D | LogicalRelation.scala | 21 import org.apache.spark.sql.catalyst.expressions.{Attribute, AttributeMap, AttributeReference}
39 override val output: Seq[AttributeReference] = {
81 val attributeMap: AttributeMap[AttributeReference] = AttributeMap(output.map(o => (o, o)))
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/command/ |
| H A D | resources.scala | 26 import org.apache.spark.sql.catalyst.expressions.{Attribute, AttributeReference}
61 AttributeReference("Results", StringType, nullable = false)() :: Nil
88 AttributeReference("Results", StringType, nullable = false)() :: Nil
|
| /dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/ |
| H A D | TypedAggregateExpression.scala | 91 override lazy val aggBufferAttributes: Seq[AttributeReference] =
92 bufferSerializer.map(_.toAttribute.asInstanceOf[AttributeReference])
111 case a: AttributeReference => a.left
114 case a: AttributeReference => a.right
|