diff options
| author | Michael Armbrust <michael@databricks.com> | 2016-09-21 20:59:46 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-09-21 20:59:46 -0700 |
| commit | 3497ebe511fee67e66387e9e737c843a2939ce45 (patch) | |
| tree | 353e095e544303a95263d4e6cae0bc1ac63bd361 /sql/core/src | |
| parent | 6902edab7e80e96e3f57cf80f26cefb209d4d63c (diff) | |
| download | spark-3497ebe511fee67e66387e9e737c843a2939ce45.tar.gz spark-3497ebe511fee67e66387e9e737c843a2939ce45.tar.bz2 spark-3497ebe511fee67e66387e9e737c843a2939ce45.zip | |
[SPARK-17627] Mark Streaming Providers Experimental
All of structured streaming is experimental in its first release. We missed the annotation on two of the APIs.
Author: Michael Armbrust <michael@databricks.com>
Closes #15188 from marmbrus/experimentalApi.
Diffstat (limited to 'sql/core/src')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala b/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala index a16d7ed0a7..6484c782b5 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala @@ -112,8 +112,10 @@ trait SchemaRelationProvider { } /** + * ::Experimental:: * Implemented by objects that can produce a streaming [[Source]] for a specific format or system. */ +@Experimental trait StreamSourceProvider { /** Returns the name and schema of the source that can be used to continually read data. */ @@ -132,8 +134,10 @@ trait StreamSourceProvider { } /** + * ::Experimental:: * Implemented by objects that can produce a streaming [[Sink]] for a specific format or system. */ +@Experimental trait StreamSinkProvider { def createSink( sqlContext: SQLContext, |