T
- the stream item typepublic interface StreamSource<T>
window
it into finite subsets over which Jet will
perform the aggregation.source factory methods
Modifier and Type | Method and Description |
---|---|
String |
name()
Returns a descriptive name of this source.
|
long |
partitionIdleTimeout()
Returns the value set by
setPartitionIdleTimeout(long) . |
StreamSource<T> |
setPartitionIdleTimeout(long timeoutMillis)
Sets a timeout after which idle partitions will be excluded from
watermark coalescing.
|
boolean |
supportsNativeTimestamps()
Returns true if this source supports native timestamps.
|
boolean supportsNativeTimestamps()
StreamSource<T> setPartitionIdleTimeout(long timeoutMillis)
The default timeout is 60 seconds. Must be a positive number or 0 to disable the feature.
timeoutMillis
- the timeout in milliseconds or zero to disable.long partitionIdleTimeout()
setPartitionIdleTimeout(long)
.Copyright © 2022 Hazelcast, Inc.. All rights reserved.