public class StreamQueryConfig extends QueryConfig
StreamQueryConfig
holds parameters to configure the behavior of streaming queries.
An empty StreamQueryConfig
can be generated using the StreamTableEnvironment.queryConfig
method.
Constructor and Description |
---|
StreamQueryConfig() |
Modifier and Type | Method and Description |
---|---|
long |
getMaxIdleStateRetentionTime() |
long |
getMinIdleStateRetentionTime() |
StreamQueryConfig |
withIdleStateRetentionTime(Time time)
Specifies the time interval for how long idle state, i.e., state which was not updated, will
be retained.
|
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 time)
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.
Note: withIdleStateRetentionTime(minTime: Time, maxTime: Time)
allows to set a minimum and
maximum time for state to be retained. This method is more efficient, because the system has
to do less bookkeeping to identify the time at which state must be cleared.
time
- The time interval for how long idle state is retained. Set to 0 (zero) to never
clean-up the state.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.
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. May not be smaller
than than minTime. Set to 0 (zero) to never clean-up the state.public long getMinIdleStateRetentionTime()
public long getMaxIdleStateRetentionTime()
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.