union() function
union() merges two or more input streams into a single output stream.
The output schemas of union() is the union of all input schemas.
union() does not preserve the sort order of the rows within tables.
Use sort() if you need a specific sort order.
Union vs join
union() does not modify data in rows, but unions separate streams of tables
into a single stream of tables and groups rows of data based on existing group keys.
join() creates new rows based on common values in one or more specified columns.
Output rows also contain the differing values from each of the joined streams.
Function type signature
(tables: [stream[A]]) => stream[A] where A: Record
Parameters
tables
(Required) List of two or more streams of tables to union together.
Examples
- Union two streams of tables with unique group keys
- Union two streams of tables with empty group keys
Union two streams of tables with unique group keys
import "generate"
t1 =
generate.from(
count: 4,
fn: (n) => n + 1,
start: 2022-01-01T00:00:00Z,
stop: 2022-01-05T00:00:00Z,
)
|> set(key: "tag", value: "foo")
|> group(columns: ["tag"])
t2 =
generate.from(
count: 4,
fn: (n) => n * (-1),
start: 2022-01-01T00:00:00Z,
stop: 2022-01-05T00:00:00Z,
)
|> set(key: "tag", value: "bar")
|> group(columns: ["tag"])
union(tables: [t1, t2])
Union two streams of tables with empty group keys
import "generate"
t1 =
generate.from(
count: 4,
fn: (n) => n + 1,
start: 2021-01-01T00:00:00Z,
stop: 2021-01-05T00:00:00Z,
)
|> set(key: "tag", value: "foo")
|> group()
t2 =
generate.from(
count: 4,
fn: (n) => n * (-1),
start: 2021-01-01T00:00:00Z,
stop: 2021-01-05T00:00:00Z,
)
|> set(key: "tag", value: "bar")
|> group()
union(tables: [t1, t2])
Was this page helpful?
Thank you for your feedback!
Support and feedback
Thank you for being part of our community! We welcome and encourage your feedback and bug reports for Flux and this documentation. To find support, use the following resources:
Customers with an annual or support contract can contact InfluxData Support.