pyspark.sql.SparkSession.interruptTag¶
-
SparkSession.interruptTag(tag: str) → List[str][source]¶ Interrupt all operations of this session with the given operation tag.
New in version 3.5.0.
- Returns
- list of str
List of operationIds of interrupted operations.
Notes
There is still a possibility of operation finishing just as it is interrupted.