[FLINK-7691] Remove ClassTag in Scala DataSet API

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Fix Version/s: 2.0.0
• Component/s: API / DataSet
• Assignee: Unassigned
• Reporter: Timo Walther
• Created: 26/Sep/17 12:50
• Updated: 23/Apr/21 13:55

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?