public interface StreamSourceProvider
Source
for a specific format or system.Modifier and Type | Method and Description |
---|---|
org.apache.spark.sql.execution.streaming.Source |
createSource(SQLContext sqlContext,
java.lang.String metadataPath,
scala.Option<StructType> schema,
java.lang.String providerName,
scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters) |
scala.Tuple2<java.lang.String,StructType> |
sourceSchema(SQLContext sqlContext,
scala.Option<StructType> schema,
java.lang.String providerName,
scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters)
Returns the name and schema of the source that can be used to continually read data.
|
scala.Tuple2<java.lang.String,StructType> sourceSchema(SQLContext sqlContext, scala.Option<StructType> schema, java.lang.String providerName, scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters)
org.apache.spark.sql.execution.streaming.Source createSource(SQLContext sqlContext, java.lang.String metadataPath, scala.Option<StructType> schema, java.lang.String providerName, scala.collection.immutable.Map<java.lang.String,java.lang.String> parameters)