org
.
apache
.
spark
.
streaming
.
kafka
producer
package
producer
Linear Supertypes
AnyRef
,
Any
Ordering
Alphabetic
By Inheritance
Inherited
producer
AnyRef
Any
Hide All
Show All
Visibility
Public
All
Type Members
class
KafkaCallback
extends
Callback
with
Serializable
class
KafkaRDDWriter
[
K
,
V
,
KS <:
Serializer
[
K
]
,
VS <:
Serializer
[
V
]
]
extends
Serializable
with
Logging
class
PairRDDFunctions
[
K
,
V
]
extends
Serializable
class
PairStreamFunctions
[
K
,
V
]
extends
Serializable
case class
ProducerConf
(
bootstrapServers:
List
[
String
] =
List("localhost:9092")
,
acks:
String
=
"1"
,
bufferMemory:
Long
=
33554432L
,
compressionType:
Option
[
String
] =
None
,
retries:
Int
=
0
,
batchSize:
Int
=
16384
,
linger:
Long
=
0
,
others:
Map
[
String
,
String
] =
Map.empty[String, String]
)
extends
Product
with
Serializable
class
RDDFunctions
[
T
]
extends
Serializable
class
StreamFunctions
[
T
]
extends
Serializable
Value Members
object
ProducerConf
extends
Serializable
implicit
def
toPairRDDFunctions
[
K
,
V
]
(
rdd:
RDD
[(
K
,
V
)]
)
(
implicit
arg0:
ClassTag
[
K
]
,
arg1:
ClassTag
[
V
]
)
:
PairRDDFunctions
[
K
,
V
]
implicit
def
toPairStreamingFunctions
[
K
,
V
]
(
dStream:
DStream
[(
K
,
V
)]
)
(
implicit
arg0:
ClassTag
[
K
]
,
arg1:
ClassTag
[
V
]
)
:
PairStreamFunctions
[
K
,
V
]
implicit
def
toRDDFunctions
[
T
]
(
rdd:
RDD
[
T
]
)
(
implicit
arg0:
ClassTag
[
T
]
)
:
RDDFunctions
[
T
]
implicit
def
toStreamingFunctions
[
T
]
(
dStream:
DStream
[
T
]
)
(
implicit
arg0:
ClassTag
[
T
]
)
:
StreamFunctions
[
T
]
Inherited from
AnyRef
Inherited from
Any
Ungrouped