Hello, I'm facing an issue with leftOuterJoin:

- input is a DataSet[String]
- metrics is a DataSet[(String,Long)]

I'm doing a leftOuterJoin like this:

input
.leftOuterJoin(metrics)
.where(0)
.equalTo(0) {
     (left,right)  =>     ...
}


But I encounter the following error:
Specifying keys via field positions is only valid for tuple data types.
Type: String

What is the correct way to handle this case (where left member has only one
field ?)

Thanks
Regards

Thomas

Reply via email to