@PublicEvolving public class StreamQueryConfig extends Object implements QueryConfig
StreamQueryConfig
holds parameters to configure the behavior of streaming queries.Constructor and Description |
---|
StreamQueryConfig() |
Modifier and Type | Method and Description |
---|---|
long |
getMaxIdleStateRetentionTime() |
long |
getMinIdleStateRetentionTime() |
StreamQueryConfig |
withIdleStateRetentionTime(Time minTime,
Time maxTime)
Specifies a minimum and a maximum time interval for how long idle state, i.e., state which
was not updated, will be retained.
|
public StreamQueryConfig withIdleStateRetentionTime(Time minTime, Time maxTime)
When new data arrives for previously cleaned-up state, the new data will be handled as if it was the first data. This can result in previous results being overwritten.
Set to 0 (zero) to never clean-up the state.
NOTE: Cleaning up state requires additional bookkeeping which becomes less expensive for larger differences of minTime and maxTime. The difference between minTime and maxTime must be at least 5 minutes.
minTime
- The minimum time interval for which idle state is retained. Set to 0 (zero) to
never clean-up the state.maxTime
- The maximum time interval for which idle state is retained. Must be at least
5 minutes greater than minTime. Set to 0 (zero) to never clean-up the state.public long getMinIdleStateRetentionTime()
public long getMaxIdleStateRetentionTime()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.