Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Invalid
-
None
-
None
-
None
Description
In the DataStream API a ClassTag is not required, which allows to pass TypeInformation manually if required. In the DataSet API most methods look like:
// DataSet API def fromElements[T: ClassTag : TypeInformation](data: T*): DataSet[T] // DataStream API def fromElements[T: TypeInformation](data: T*): DataStream[T]
I would propose to remove the ClassTag, if possible. This would make it easier e.g. to supply TypeInformation for the Row type. Or is there an easier way in Scala that I don't know?