kotlin-spark-api-parent_3.3.2_2.13
1.2.4
jvm
jupyter_3.
3.
2_2.
13
org.
jetbrains.
kotlinx.
spark.
api.
jupyter
Integration
Jupyter
Configuration
Properties
Companion
Spark
Integration
Spark
Streaming
Integration
kotlin-spark-api_3.
3.
2_2.
13
org.
jetbrains.
kotlinx.
spark.
api
&&()
=!=()
==()
===()
aggregate
By
Key()
Aggregator
aggregator
Of()
and()
Arity1
Arity10
Arity11
Arity12
Arity13
Arity14
Arity15
Arity16
Arity17
Arity18
Arity19
Arity2
Arity20
Arity21
Arity22
Arity23
Arity24
Arity25
Arity26
Arity3
Arity4
Arity5
Arity6
Arity7
Arity8
Arity9
as()
as
Kotlin
Collection()
as
Kotlin
Concurrent
Map()
as
Kotlin
Dictionary()
as
Kotlin
Enumeration()
as
Kotlin
Iterable()
as
Kotlin
Iterator()
as
Kotlin
List()
as
Kotlin
Map()
as
Kotlin
Mutable
List()
as
Kotlin
Mutable
Map()
as
Kotlin
Mutable
Set()
as
Kotlin
Set()
as
Scala
Concurrent
Map()
as
Scala
Iterable()
as
Scala
Iterator()
as
Scala
Map()
as
Scala
Mutable
Buffer()
as
Scala
Mutable
Map()
as
Scala
Mutable
Set()
as
Seq()
broadcast()
c()
cogroup()
col()
collect
As
Map()
combine
By
Key()
copy()
count
Approx
Distinct
By
Key()
count
By
Key()
count
By
Key
Approx()
debug()
debug
Codegen()
df
Of()
div()
downcast()
ds
Of()
empty
Mutable
Seq()
empty
Seq()
encoder()
ENCODERS
eq()
filter()
filter
By
Range()
Filtering
Iterator
filter
Not
Null()
flat
Map()
flat
Map
Groups()
flat
Map
Groups
With
State()
flat
Map
Values()
flatten()
fold
By
Key()
for
Each()
for
Each
Batch()
for
Each
Partition()
full
Join()
full
Outer
Join()
generate
Encoder()
geq()
get()
get
Or
Else()
get
Or
Null()
get
Value()
group
By
Key()
group
By
Key
And
Window()
group
With()
gt()
histogram()
inner
Join()
in
Range
Of()
invoke()
join()
keys()
KSpark
Session
KSpark
Streaming
Session
left
Join()
left
Outer
Join()
leq()
lit()
lookup()
lt()
map()
map
Groups()
map
Groups
With
State()
map
Keys()
map
Partitions()
Mapping
Iterator
map
Values()
map
With
State()
max()
mean()
mean
Approx()
min()
mutable
Seq
Of()
Named
User
Defined
Function
Named
User
Defined
Function0
Named
User
Defined
Function1
Named
User
Defined
Function10
Named
User
Defined
Function11
Named
User
Defined
Function12
Named
User
Defined
Function13
Named
User
Defined
Function14
Named
User
Defined
Function15
Named
User
Defined
Function16
Named
User
Defined
Function17
Named
User
Defined
Function18
Named
User
Defined
Function19
Named
User
Defined
Function2
Named
User
Defined
Function20
Named
User
Defined
Function21
Named
User
Defined
Function22
Named
User
Defined
Function3
Named
User
Defined
Function4
Named
User
Defined
Function5
Named
User
Defined
Function6
Named
User
Defined
Function7
Named
User
Defined
Function8
Named
User
Defined
Function9
Named
User
Defined
Function
Vararg
neq()
not()
or()
partition()
partition
By()
Partitioning
Iterator
plus()
pop
Stdev()
pop
Variance()
rdd
Of()
reduce
By
Key()
reduce
By
Key
And
Window()
reduce
By
Key
Locally()
reduce
Groups
K()
reduce
K()
register()
rem()
repartition
And
Sort
Within
Partitions()
right
Join()
right
Outer
Join()
sample
By
Key()
sample
By
Key
Exact()
sample
Stdev()
sample
Variance()
save
As
Hadoop
Dataset()
save
As
Hadoop
File()
save
As
Hadoop
Files()
save
As
New
APIHadoop
Dataset()
save
As
New
APIHadoop
File()
save
As
New
APIHadoop
Files()
schema()
select
Typed()
seq
Of()
set
Log
Level()
set
Value()
show
DS()
single
Col()
sort()
sort
By
Key()
sort
By
Value()
spark
Context
Spark
Log
Level
ALL
DEBUG
ERROR
FATAL
INFO
OFF
TRACE
WARN
stats()
stdev()
subtract
By
Key()
sum()
sum
Approx()
take
Keys()
take
Values()
times()
to()
to
Arity()
to
Array()
to
DF()
to
Double
RDD()
to
DS()
to
Java
Double
RDD()
to
Java
Pair
RDD()
to
List()
to
Option()
to
Optional()
to
Pair()
to
Pair
DStream()
to
RDD()
to
Triple()
to
Tuple()
to
Tuple
DStream()
to
Tuple
RDD()
transform
As
Sequence()
typed()
typed
Lit()
Type
Of
UDFParameter
Not
Supported
Exception
udaf()
udaf
Unnamed()
udf()
UDF0
UDF1
UDF10
UDF11
UDF12
UDF13
UDF14
UDF15
UDF16
UDF17
UDF18
UDF19
UDF2
UDF20
UDF21
UDF22
UDF3
UDF4
UDF5
UDF6
UDF7
UDF8
UDF9
UDFWrapper0
UDFWrapper1
UDFWrapper10
UDFWrapper11
UDFWrapper12
UDFWrapper13
UDFWrapper14
UDFWrapper15
UDFWrapper16
UDFWrapper17
UDFWrapper18
UDFWrapper19
UDFWrapper2
UDFWrapper20
UDFWrapper21
UDFWrapper22
UDFWrapper3
UDFWrapper4
UDFWrapper5
UDFWrapper6
UDFWrapper7
UDFWrapper8
UDFWrapper9
unary
Minus()
un
Wrap()
update
State
By
Key()
User
Defined
Function
User
Defined
Function0
User
Defined
Function1
User
Defined
Function10
User
Defined
Function11
User
Defined
Function12
User
Defined
Function13
User
Defined
Function14
User
Defined
Function15
User
Defined
Function16
User
Defined
Function17
User
Defined
Function18
User
Defined
Function19
User
Defined
Function2
User
Defined
Function20
User
Defined
Function21
User
Defined
Function22
User
Defined
Function3
User
Defined
Function4
User
Defined
Function5
User
Defined
Function6
User
Defined
Function7
User
Defined
Function8
User
Defined
Function9
User
Defined
Function
Vararg
values()
variance()
with
Cached()
with
Spark()
with
Spark
Streaming()
scala-tuples-in-kotlin_2.
13
org.
jetbrains.
kotlinx.
spark.
api
to
Pair()
to
Triple()
to
Tuple()
org.
jetbrains.
kotlinx.
spark.
api.
tuples
_1
_10
_11
_12
_13
_14
_15
_16
_17
_18
_19
_2
_20
_21
_22
_3
_4
_5
_6
_7
_8
_9
appended
By()
as
Iterable()
cast()
component1()
component10()
component11()
component12()
component13()
component14()
component15()
component16()
component17()
component18()
component19()
component2()
component20()
component21()
component22()
component3()
component4()
component5()
component6()
component7()
component8()
component9()
concat()
contains()
copy()
drop0()
drop1()
drop10()
drop11()
drop12()
drop13()
drop14()
drop15()
drop16()
drop17()
drop18()
drop19()
drop2()
drop20()
drop21()
drop22()
drop3()
drop4()
drop5()
drop6()
drop7()
drop8()
drop9()
drop
First()
drop
Last()
drop
Last0()
drop
Last1()
drop
Last10()
drop
Last11()
drop
Last12()
drop
Last13()
drop
Last14()
drop
Last15()
drop
Last16()
drop
Last17()
drop
Last18()
drop
Last19()
drop
Last2()
drop
Last20()
drop
Last21()
drop
Last22()
drop
Last3()
drop
Last4()
drop
Last5()
drop
Last6()
drop
Last7()
drop
Last8()
drop
Last9()
Empty
Tuple
empty
Tuple()
first()
get()
get
As()
get
As
Or
Null()
get
Or
Null()
iterator()
last()
map()
plus()
prepended
By()
size
split
At0()
split
At1()
split
At10()
split
At11()
split
At12()
split
At13()
split
At14()
split
At15()
split
At16()
split
At17()
split
At18()
split
At19()
split
At2()
split
At20()
split
At21()
split
At22()
split
At3()
split
At4()
split
At5()
split
At6()
split
At7()
split
At8()
split
At9()
t()
take0()
take1()
take10()
take11()
take12()
take13()
take14()
take15()
take16()
take17()
take18()
take19()
take2()
take20()
take21()
take22()
take3()
take4()
take5()
take6()
take7()
take8()
take9()
take
Last0()
take
Last1()
take
Last10()
take
Last11()
take
Last12()
take
Last13()
take
Last14()
take
Last15()
take
Last16()
take
Last17()
take
Last18()
take
Last19()
take
Last2()
take
Last20()
take
Last21()
take
Last22()
take
Last3()
take
Last4()
take
Last5()
take
Last6()
take
Last7()
take
Last8()
take
Last9()
to
List()
tuple
Of()
X()
zip()
kotlin-spark-api_3.3.2_2.13
/
org.jetbrains.kotlinx.spark.api
/
KSparkSession
/
toRDD
to
RDD
fun
<
T
>
List
<
T
>
.
toRDD
(
numSlices
:
Int
=
sc.defaultParallelism()
)
:
JavaRDD
<
T
>
Utility method to create an RDD from a list. NOTE:
T
must be
Serializable
.