spark技术分享GroupStateTimeout
GroupStateTimeout represents the possible timeouts that you can use for the state-aware Dataset operations:
GroupStateTimeout is part of org.apache.spark.sql.streaming package.
|
1 2 3 4 5 |
import org.apache.spark.sql.streaming.GroupStateTimeout |
| GroupStateTimeout | Description | ||||
|---|---|---|---|---|---|
|
Timeout based on the processing time.
|
|||||
|
Timeout based on the event time Used when…FIXME |
|||||
|
No timeout Used when…FIXME |
