join.time() function

join.time() joins two table streams together exclusively on the _time column.

This function calls join.tables() with the on parameter set to (l, r) => l._time == r._time.

Function type signature
    <-left: stream[{A with _time: B}],
    as: (l: {A with _time: B}, r: {C with _time: D}) => E,
    right: stream[{C with _time: D}],
    ?method: string,
) => stream[E] where B: Equatable, D: Equatable, E: Record
For more information, see Function type signatures.



Left input stream. Default is piped-forward data (<-).

(Required) Right input stream.


(Required) Function that takes a left and a right record (l and r respectively), and returns a record. The returned record is included in the final output.


String that specifies the join method. Default is inner.

Supported methods:

  • inner
  • left
  • right
  • full


Join two tables by timestamp

import "sampledata"
import "join"

ints =
strings = sampledata.string()

join.time(left: ints, right: strings, as: (l, r) => ({l with label: r._value}))

View example output

Was this page helpful?

Thank you for your feedback!

Upgrade to InfluxDB Cloud or InfluxDB 2.0!

InfluxDB Cloud and InfluxDB OSS 2.0 ready for production.