flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Thomas FOURNIER <thomasfournier...@gmail.com>
Subject Left outer join
Date Tue, 08 Nov 2016 21:58:44 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message