Joining data in Arroyo SQL
TUMBLE(interval '1 minute')
will be computed once a minute, and return
all matching elements within that minute. Window completions are triggered by the arrival of watermarks,
as described here.
Window joins default to INNER joins, but you may also specify LEFT
, RIGHT
, or FULL
before the JOIN
keyword.
A full example of a window join looks like this:
debezium_json
format).
An example updating join looks like this:
SET updating_ttl
. See the
updating docs for more
details.
TEMPORARY TABLE
, which
is unmaterialized and backed by the external system. Each record that comes into
the join from the left (stream) side causes a query to the underlying system.
For example, you may have a set of detailed customer records stored in an RDBMS
that you would like to use to enrich an analytics stream.
Currently, Redis is supported as a lookup connector.
An example lookup join looks like this:
lookup.cache.max_bytes
and lookup.cache.ttl
are optional arguments that
control the behavior of the built-in cache, which avoids the need to query the
same keys over and over again.
Lookup joins can be either INNER (the default) or LEFT.