TableConfig
.@Deprecated @PublicEvolving public class StreamQueryConfig extends Object implements QueryConfig
StreamQueryConfig
holds parameters to configure the behavior of streaming queries.Constructor and Description |
---|
StreamQueryConfig()
Deprecated.
|
StreamQueryConfig(long minIdleStateRetentionTime,
long maxIdleStateRetentionTime)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
long |
getMaxIdleStateRetentionTime()
Deprecated.
|
long |
getMinIdleStateRetentionTime()
Deprecated.
|
StreamQueryConfig |
withIdleStateRetentionTime(Time minTime,
Time maxTime)
Deprecated.
Specifies a minimum and a maximum time interval for how long idle state, i.e., state which
was not updated, will be retained.
|
@Internal public StreamQueryConfig(long minIdleStateRetentionTime, long maxIdleStateRetentionTime)
public StreamQueryConfig()
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.