...
| Code Block |
|---|
| language | java |
|---|
| title | WindowedSerdes |
|---|
| linenumbers | true |
|---|
|
@Deprecated
public TimeWindowedSerde(final Serde<T> inner) {
super(new TimeWindowedSerializer<>(inner.serializer()), new TimeWindowedDeserializer<>(inner.deserializer()));
} |
| Code Block |
|---|
| language | java |
|---|
| title | TimeWindowedDeserializer |
|---|
| linenumbers | true |
|---|
|
@Deprecated
public TimeWindowedDeserializer(final Deserializer<T> inner) {
this(inner, Long.MAX_VALUE);
}
/**
* Construct a {@code TimeWindowedSerde} object for the specified inner class type.
*/
@Deprecated
static public <T> Serde<Windowed<T>> timeWindowedSerdeFrom(final Class<T> type) {
return new TimeWindowedSerde<>(Serdes.serdeFrom(type));
} |
| Code Block |
|---|
| language | java |
|---|
| title | TimeWindowedDeserializer |
|---|
| linenumbers | true |
|---|
|
@Deprecated
public TimeWindowedDeserializer(final Deserializer<T> inner) {
this(inner, Long.MAX_VALUE);
} |
Proposed Changes
Add window.size.ms to the StreamsConfigs class to ensure that the desired window size is set when the consumer creates the TimeWindowedDeserializer instance. This is relevant for consuming TimeWindowed records directly, which is helpful when testing windowed aggregations. Without this change, all windows will have a size and end time of Long.MAX_VALUE.
...