org
.
apache
.
spark
.
sql
.
streaming
jdbc
package
jdbc
Visibility
Public
All
Type Members
case class
JDBCSource
(
sqlContext:
SQLContext
,
parameters:
Map
[
String
,
String
]
,
spec:
SourceSpec
)
extends
Source
with
Logging
with
Product
with
Serializable
class
JDBCStreamBuilder
extends
AnyRef
class
JdbcStreamProvider
extends
StreamSourceProvider
with
DataSourceRegister
case class
LSN
(
json:
String
)
extends
Offset
with
Product
with
Serializable
case class
SnappyStoreSink
(
snappySession:
SnappySession
,
parameters:
Map
[
String
,
String
]
,
sink:
SnappyStreamSink
)
extends
Sink
with
Product
with
Serializable
class
SnappyStoreSinkProvider
extends
StreamSinkProvider
with
DataSourceRegister
trait
SnappyStreamSink
extends
AnyRef
trait
SourceSpec
extends
AnyRef
class
SqlServerSpec
extends
SourceSpec
Value Members
object
StreamConf
Ungrouped