/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/ |
H A D | Encoders.scala | 27 import org.apache.spark.sql.catalyst.encoders.{encoderFor, ExpressionEncoder} 228 ExpressionEncoder.tuple(encoderFor(e1), encoderFor(e2)) 240 ExpressionEncoder.tuple(encoderFor(e1), encoderFor(e2), encoderFor(e3)) 253 ExpressionEncoder.tuple(encoderFor(e1), encoderFor(e2), encoderFor(e3), encoderFor(e4)) 268 encoderFor(e1), encoderFor(e2), encoderFor(e3), encoderFor(e4), encoderFor(e5))
|
/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/ |
H A D | object.scala | 33 val deserializer = UnresolvedDeserializer(encoderFor[T].deserializer) 38 SerializeFromObject(encoderFor[T].namedExpressions, child) 42 val enc = encoderFor[T] 185 UnresolvedDeserializer(encoderFor[T].deserializer), 232 UnresolvedDeserializer(encoderFor[T].deserializer), 233 encoderFor[U].namedExpressions, 246 encoderFor[U].namedExpressions, 293 UnresolvedDeserializer(encoderFor[T].deserializer, dataAttributes), 384 UnresolvedDeserializer(encoderFor[K].deserializer, leftGroup), 385 UnresolvedDeserializer(encoderFor[L].deserializer, leftAttr), [all …]
|
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/ |
H A D | KeyValueGroupedDataset.scala | 24 import org.apache.spark.sql.catalyst.encoders.{encoderFor, ExpressionEncoder} 48 private implicit val kExprEnc = encoderFor(kEncoder) 49 private implicit val vExprEnc = encoderFor(vEncoder) 63 encoderFor[L], 86 encoderFor[K], 87 encoderFor[W], 229 val vEncoder = encoderFor[V]
|
H A D | Column.scala | 25 import org.apache.spark.sql.catalyst.encoders.{encoderFor, ExpressionEncoder} 201 def as[U : Encoder]: TypedColumn[Any, U] = new TypedColumn[Any, U](expr, encoderFor[U])
|
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ |
H A D | ForeachSink.scala | 22 import org.apache.spark.sql.catalyst.encoders.encoderFor 46 val encoder = encoderFor[T].resolveAndBind(
|
H A D | memory.scala | 28 import org.apache.spark.sql.catalyst.encoders.encoderFor 51 protected val encoder = encoderFor[A]
|
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/expressions/ |
H A D | Aggregator.scala | 22 import org.apache.spark.sql.catalyst.encoders.encoderFor 109 new TypedColumn[IN, OUT](expr, encoderFor[OUT])
|
/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/aggregate/ |
H A D | TypedAggregateExpression.scala | 24 import org.apache.spark.sql.catalyst.encoders.encoderFor 34 val bufferEncoder = encoderFor[BUF] 40 val outputEncoder = encoderFor[OUT]
|
/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ |
H A D | package.scala | 29 def encoderFor[A : Encoder]: ExpressionEncoder[A] = implicitly[Encoder[A]] match { method
|
/dports/devel/spark/spark-2.1.1/sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/encoders/ |
H A D | ExpressionEncoderSuite.scala | 182 encodeDecodeTest("hello", "kryo string")(encoderFor(Encoders.kryo[String])) 184 encoderFor(Encoders.kryo[KryoSerializable])) 187 encodeDecodeTest("hello", "java string")(encoderFor(Encoders.javaSerialization[String])) 189 encoderFor(Encoders.javaSerialization[JavaSerializable]))
|
/dports/devel/spark/spark-2.1.1/sql/core/src/test/scala/org/apache/spark/sql/streaming/ |
H A D | StreamTest.scala | 38 import org.apache.spark.sql.catalyst.encoders.{encoderFor, ExpressionEncoder, RowEncoder} 119 val encoder = encoderFor[A] 140 val encoder = encoderFor[A]
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk11-jre/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk17/jdk17u-jdk-17.0.1-12-1/src/java.base/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk12/openjdk-jdk12u-jdk-12.0.2-10-4/src/java.base/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk15/jdk15u-jdk-15.0.6-1-1/src/java.base/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk14/jdk14u-jdk-14.0.2-12-1/src/java.base/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk8-jre/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/sun/nio/cs/ |
H A D | ThreadLocalCoders.java | 130 public static CharsetEncoder encoderFor(Object name) { in encoderFor() method in ThreadLocalCoders
|
/dports/java/openjdk11/jdk11u-jdk-11.0.13-8-1/src/java.base/share/classes/java/nio/charset/ |
H A D | Charset.java | 847 return ThreadLocalCoders.encoderFor(this)
|
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/nio/charset/ |
H A D | Charset.java | 840 return ThreadLocalCoders.encoderFor(this)
|
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/share/classes/java/nio/charset/ |
H A D | Charset.java | 845 return ThreadLocalCoders.encoderFor(this)
|
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/java/nio/charset/ |
H A D | Charset.java | 844 return ThreadLocalCoders.encoderFor(this)
|