Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -154,7 +154,7 @@ public static JoinWindows ofTimeDifferenceWithNoGrace(final Duration timeDiffere
* @param timeDifference join window interval
* @return a new JoinWindows object with the window definition with and grace period (default to 24 hours minus {@code timeDifference})
* @throws IllegalArgumentException if {@code timeDifference} is negative or can't be represented as {@code long milliseconds}
* @deprecated Since 3.0. Use {@link #ofTimeDifferenceWithNoGrace(Duration)}} instead.
* @deprecated Since 3.0. Use {@link #ofTimeDifferenceWithNoGrace(Duration)} instead.
*/
@Deprecated
public static JoinWindows of(final Duration timeDifference) throws IllegalArgumentException {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -114,7 +114,7 @@ public static <K, V> Produced<K, V> keySerde(final Serde<K> keySerde) {

/**
* Create a Produced instance with provided valueSerde.
* @param valueSerde Serde to use for serializing the key
* @param valueSerde Serde to use for serializing the value
* @param <K> key type
* @param <V> value type
* @return A new {@link Produced} instance configured with valueSerde
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -183,7 +183,7 @@ default KeyValueIterator<Windowed<K>, V> backwardAll() {
}

/**
* Gets all the key-value pairs that belong to the windows within in the given time range.
* Gets all the key-value pairs that belong to the windows within the given time range.
*
* @param timeFrom the beginning of the time slot from which to search (inclusive), where iteration starts.
* @param timeTo the end of the time slot from which to search (inclusive), where iteration ends.
Expand All @@ -195,7 +195,7 @@ default KeyValueIterator<Windowed<K>, V> backwardAll() {
KeyValueIterator<Windowed<K>, V> fetchAll(Instant timeFrom, Instant timeTo) throws IllegalArgumentException;

/**
* Gets all the key-value pairs that belong to the windows within in the given time range in backward order
* Gets all the key-value pairs that belong to the windows within the given time range in backward order
* with respect to time (from end to beginning of time).
*
* @param timeFrom the beginning of the time slot from which to search (inclusive), where iteration ends.
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -162,7 +162,7 @@ default KeyValueIterator<Windowed<K>, V> backwardFetch(final K keyFrom,
}

/**
* Gets all the key-value pairs that belong to the windows within in the given time range.
* Gets all the key-value pairs that belong to the windows within the given time range.
*
* @param timeFrom the beginning of the time slot from which to search (inclusive)
* @param timeTo the end of the time slot from which to search (inclusive)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ public interface SegmentedBytesStore extends StateStore {
KeyValueIterator<Bytes, byte[]> backwardAll();

/**
* Gets all the key-value pairs that belong to the windows within in the given time range.
* Gets all the key-value pairs that belong to the windows within the given time range.
*
* @param from the beginning of the time slot from which to search (inclusive)
* @param to the end of the time slot from which to search (inclusive)
Expand Down
Loading