You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2016/09/22 03:59:49 UTC
spark git commit: [SPARK-17627] Mark Streaming Providers Experimental
Repository: spark
Updated Branches:
refs/heads/master 6902edab7 -> 3497ebe51
[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 <mi...@databricks.com>
Closes #15188 from marmbrus/experimentalApi.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/3497ebe5
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/3497ebe5
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/3497ebe5
Branch: refs/heads/master
Commit: 3497ebe511fee67e66387e9e737c843a2939ce45
Parents: 6902eda
Author: Michael Armbrust <mi...@databricks.com>
Authored: Wed Sep 21 20:59:46 2016 -0700
Committer: Reynold Xin <rx...@databricks.com>
Committed: Wed Sep 21 20:59:46 2016 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/spark/sql/sources/interfaces.scala | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/3497ebe5/sql/core/src/main/scala/org/apache/spark/sql/sources/interfaces.scala
----------------------------------------------------------------------
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 a16d7ed..6484c78 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,
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org