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
PairRDDFunctions
[
K
,
V
]
extends
AnyRef
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
AnyRef
Value Members
object
ProducerConf
extends
Serializable
implicit
def
toPairRDDFunctions
[
K
,
V
]
(
rdd:
RDD
[(
K
,
V
)]
)
:
PairRDDFunctions
[
K
,
V
]
implicit
def
toRDDFunctions
[
T
]
(
rdd:
RDD
[
T
]
)
:
RDDFunctions
[
T
]
Inherited from
AnyRef
Inherited from
Any
Ungrouped