|
|
|
SPARK-14452
|
SPARK-9999
Explicit APIs in Scala for specifying encoders
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-14451
|
SPARK-9999
Move encoder definition into Aggregator interface
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-12813
|
SPARK-9999
Eliminate serialization for back to back operations
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-12568
|
SPARK-9999
Add BINARY to Encoders
|
Apache Spark
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-12495
|
SPARK-9999
use true as default value for propagateNull in NewInstance
|
Apache Spark
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-12320
|
SPARK-9999
throw exception if the number of fields does not line up for Tuple encoder
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-12274
|
SPARK-9999
WrapOption should not have type constraint for child
|
Apache Spark
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-12252
|
SPARK-9999
refactor MapObjects to make it less hacky
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11970
|
SPARK-9999
Add missing APIs in Dataset
|
Xiao Li
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11954
|
SPARK-9999
Encoder for JavaBeans / POJOs
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11942
|
SPARK-9999
fix encoder life cycle for CoGroup
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11934
|
SPARK-9999
[SQL] Adding joinType into joinWith
|
Unassigned
|
Xiao Li
|
|
Closed |
Duplicate
|
|
|
|
|
|
|
|
SPARK-11921
|
SPARK-9999
fix `nullable` of encoder schema
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11913
|
SPARK-9999
support typed aggregate for complex buffer schema
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11905
|
SPARK-9999
[SQL] Support Persist/Cache and Unpersist in Dataset APIs
|
Xiao Li
|
Xiao Li
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11894
|
SPARK-9999
Incorrect results are returned when using null
|
Wenchen Fan
|
Xiao Li
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11856
|
SPARK-9999
add type cast if the real type is different but compatible with encoder schema
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11833
|
SPARK-9999
Add Java tests for Kryo/Java encoders
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11819
|
SPARK-9999
nice error message for missing encoder
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11810
|
SPARK-9999
Java-based encoder for opaque types
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11803
|
SPARK-9999
Dataset self join returns incorrect result
|
Wenchen Fan
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11802
|
SPARK-9999
Kryo-based encoder for opaque types
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11797
|
SPARK-9999
collect, first, and take should use encoders for serialization
|
Reynold Xin
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11795
|
SPARK-9999
org.apache.spark.sql.AnalysisException: Can't extract value from a#12
|
Wenchen Fan
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11727
|
SPARK-9999
split ExpressionEncoder into FlatEncoder and ProductEncoder
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11656
|
SPARK-9999
support typed aggregate in project list
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11654
|
SPARK-9999
add reduce to GroupedDataset
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11636
|
SPARK-9999
Support as on Classes defined in the REPL
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11625
|
SPARK-9999
add java test for typed aggregate
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11616
|
SPARK-9999
Improve toString Function
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11578
|
SPARK-9999
User facing api for typed aggregation
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11554
|
SPARK-9999
add map/flatMap to GroupedDataset
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11528
|
SPARK-9999
Typed-safe aggregations
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11404
|
SPARK-9999
groupBy on column expressions
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11392
|
SPARK-9999
GroupedIterator's hasNext is not idempotent
|
Unassigned
|
Yin Huai
|
|
Resolved |
Won't Fix
|
|
|
|
|
|
|
|
SPARK-11347
|
SPARK-9999
Support for joining two datasets, returning a tuple of objects
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11313
|
SPARK-9999
Implement cogroup
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11269
|
SPARK-9999
Java API support & test cases
|
Wenchen Fan
|
Reynold Xin
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11216
|
SPARK-9999
add encoder/decoder for external row
|
Wenchen Fan
|
Wenchen Fan
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11116
|
SPARK-9999
Initial API Draft
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-11090
|
SPARK-9999
Initial code generated construction of Product classes from InternalRow
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|
|
|
|
SPARK-10993
|
SPARK-9999
Inital code generated encoder for product types
|
Michael Armbrust
|
Michael Armbrust
|
|
Resolved |
Fixed
|
|
|
|
|