Skip to content

Commit 4196d7b

Browse files
HeartSaVioRdongjoon-hyun
authored andcommitted
[SPARK-28199][SS][FOLLOWUP] Remove unnecessary annotations for private API
## What changes were proposed in this pull request? SPARK-28199 (apache#24996) hid implementations of Triggers into `private[sql]` and encourage end users to use `Trigger.xxx` methods instead. As I got some post review comment on apache@7548a88#r34366934 we could remove annotations which are meant to be used with public API. ## How was this patch tested? N/A Closes apache#25200 from HeartSaVioR/SPARK-28199-FOLLOWUP. Authored-by: Jungtaek Lim (HeartSaVioR) <[email protected]> Signed-off-by: Dongjoon Hyun <[email protected]>
1 parent 453cbf3 commit 4196d7b

File tree

1 file changed

+0
-5
lines changed
  • sql/core/src/main/scala/org/apache/spark/sql/execution/streaming

1 file changed

+0
-5
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/Triggers.scala

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@ import java.util.concurrent.TimeUnit
2121

2222
import scala.concurrent.duration.Duration
2323

24-
import org.apache.spark.annotation.{Evolving, Experimental}
2524
import org.apache.spark.sql.streaming.Trigger
2625
import org.apache.spark.unsafe.types.CalendarInterval
2726

@@ -47,15 +46,12 @@ private object Triggers {
4746
* A [[Trigger]] that processes only one batch of data in a streaming query then terminates
4847
* the query.
4948
*/
50-
@Experimental
51-
@Evolving
5249
private[sql] case object OneTimeTrigger extends Trigger
5350

5451
/**
5552
* A [[Trigger]] that runs a query periodically based on the processing time. If `interval` is 0,
5653
* the query will run as fast as possible.
5754
*/
58-
@Evolving
5955
private[sql] case class ProcessingTimeTrigger(intervalMs: Long) extends Trigger {
6056
Triggers.validate(intervalMs)
6157
}
@@ -84,7 +80,6 @@ private[sql] object ProcessingTimeTrigger {
8480
* A [[Trigger]] that continuously processes streaming data, asynchronously checkpointing at
8581
* the specified interval.
8682
*/
87-
@Evolving
8883
private[sql] case class ContinuousTrigger(intervalMs: Long) extends Trigger {
8984
Triggers.validate(intervalMs)
9085
}

0 commit comments

Comments
 (0)