Home
last modified time | relevance | path

Searched refs:encoderFor (Results 1 – 25 of 49) sorted by relevance

12

/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/
H A DEncoders.scala27 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 Dobject.scala33 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 DKeyValueGroupedDataset.scala24 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 DColumn.scala25 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 DForeachSink.scala22 import org.apache.spark.sql.catalyst.encoders.encoderFor
46 val encoder = encoderFor[T].resolveAndBind(
H A Dmemory.scala28 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 DAggregator.scala22 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 DTypedAggregateExpression.scala24 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 Dpackage.scala29 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 DExpressionEncoderSuite.scala182 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 DStreamTest.scala38 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DThreadLocalCoders.java130 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 DCharset.java847 return ThreadLocalCoders.encoderFor(this)
/dports/java/openjdk8/jdk8u-jdk8u312-b07.1/jdk/src/share/classes/java/nio/charset/
H A DCharset.java840 return ThreadLocalCoders.encoderFor(this)
/dports/java/openjdk13/jdk13u-jdk-13.0.10-1-1/src/java.base/share/classes/java/nio/charset/
H A DCharset.java845 return ThreadLocalCoders.encoderFor(this)
/dports/java/openjdk16/jdk16u-jdk-16.0.2-7-1/src/java.base/share/classes/java/nio/charset/
H A DCharset.java844 return ThreadLocalCoders.encoderFor(this)

12