public class JoinWindows extends Windows<org.apache.kafka.streams.kstream.internals.TumblingWindow>
Modifier and Type | Method and Description |
---|---|
JoinWindows |
after(long timeDifference)
Specifies that records of the same key are joinable if their timestamp stamps are within
timeDifference, and if the timestamp of a record from the secondary stream is
is later than or equal to the timestamp of a record from the first stream.
|
JoinWindows |
before(long timeDifference)
Specifies that records of the same key are joinable if their timestamp stamps are within
timeDifference, and if the timestamp of a record from the secondary stream is
is earlier than or equal to the timestamp of a record from the first stream.
|
boolean |
equalTo(Windows other) |
static JoinWindows |
of(java.lang.String name) |
java.util.Map<java.lang.Long,org.apache.kafka.streams.kstream.internals.TumblingWindow> |
windowsFor(long timestamp) |
JoinWindows |
within(long timeDifference)
Specifies that records of the same key are joinable if their timestamp stamps are within
timeDifference.
|
emit, emitEveryMs, maintainMs, name, newName, segments, until
public static JoinWindows of(java.lang.String name)
public JoinWindows within(long timeDifference)
timeDifference
- public JoinWindows before(long timeDifference)
timeDifference
- public JoinWindows after(long timeDifference)
timeDifference
- public java.util.Map<java.lang.Long,org.apache.kafka.streams.kstream.internals.TumblingWindow> windowsFor(long timestamp)
windowsFor
in class Windows<org.apache.kafka.streams.kstream.internals.TumblingWindow>