You should use the get method:
val table = tenv
.fromDataStream(stream)
.select($"context".get("url"), $"name")Best, Dawid On 10/11/2020 10:15, Ori Popowski wrote: > > How can I access nested fields e.g. in select statements? > > For example, this won't work: > > val table = tenv > .fromDataStream(stream) > .select($"context.url", $"name") > > What is the correct way? > > Thanks.
signature.asc
Description: OpenPGP digital signature
