pysparkling
doc-updates
pysparkling
Reading and Writing
API
Parallelization
Development
pysparkling
Docs
»
Index
Edit on GitHub
Index
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
Z
A
aggregate() (pysparkling.RDD method)
aggregateByKey() (pysparkling.RDD method)
awaitTermination() (pysparkling.streaming.StreamingContext method)
awaitTerminationOrTimeout() (pysparkling.streaming.StreamingContext method)
B
binaryFiles() (pysparkling.Context method)
binaryRecords() (pysparkling.Context method)
binaryRecordsStream() (pysparkling.streaming.StreamingContext method)
Bz2 (class in pysparkling.fileio.codec)
C
cache() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
cartesian() (pysparkling.RDD method)
coalesce() (pysparkling.RDD method)
Codec (class in pysparkling.fileio.codec)
cogroup() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
collect() (pysparkling.RDD method)
collectAsMap() (pysparkling.RDD method)
compress() (pysparkling.fileio.codec.Codec method)
compute() (pysparkling.RDD method)
connection_kwargs (pysparkling.fileio.fs.S3 attribute)
Context (class in pysparkling)
context() (pysparkling.streaming.DStream method)
count() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
countApprox() (pysparkling.RDD method)
countByKey() (pysparkling.RDD method)
countByValue() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
countByWindow() (pysparkling.streaming.DStream method)
D
decompress() (pysparkling.fileio.codec.Codec method)
distinct() (pysparkling.RDD method)
DStream (class in pysparkling.streaming)
dump() (pysparkling.fileio.File method)
(pysparkling.fileio.TextFile method)
(pysparkling.fileio.fs.FileSystem method)
E
exists() (pysparkling.fileio.File method)
(pysparkling.fileio.fs.FileSystem method)
F
File (class in pysparkling.fileio)
fileBinaryStream() (pysparkling.streaming.StreamingContext method)
FileSystem (class in pysparkling.fileio.fs)
fileTextStream() (pysparkling.streaming.StreamingContext method)
filter() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
first() (pysparkling.RDD method)
flatMap() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
flatMapValues() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
fold() (pysparkling.RDD method)
foldByKey() (pysparkling.RDD method)
foreach() (pysparkling.RDD method)
foreachPartition() (pysparkling.RDD method)
foreachRDD() (pysparkling.streaming.DStream method)
fullOuterJoin() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
G
getNumPartitions() (pysparkling.RDD method)
getPartitions() (pysparkling.RDD method)
groupBy() (pysparkling.RDD method)
groupByKey() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
GS (class in pysparkling.fileio.fs)
Gz (class in pysparkling.fileio.codec)
H
Hdfs (class in pysparkling.fileio.fs)
histogram() (pysparkling.RDD method)
Http (class in pysparkling.fileio.fs)
I
intersection() (pysparkling.RDD method)
J
join() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
K
keyBy() (pysparkling.RDD method)
keys() (pysparkling.RDD method)
L
leftOuterJoin() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
load() (pysparkling.fileio.File method)
(pysparkling.fileio.TextFile method)
(pysparkling.fileio.fs.FileSystem method)
load_text() (pysparkling.fileio.fs.FileSystem method)
Local (class in pysparkling.fileio.fs)
lookup() (pysparkling.RDD method)
Lzma (class in pysparkling.fileio.codec)
M
make_public() (pysparkling.fileio.File method)
(pysparkling.fileio.fs.FileSystem method)
map() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
mapPartitions() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
mapPartitionsWithIndex() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
mapValues() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
max() (pysparkling.RDD method)
mean() (pysparkling.RDD method)
mime_type (pysparkling.fileio.fs.GS attribute)
min() (pysparkling.RDD method)
N
name() (pysparkling.RDD method)
P
parallelize() (pysparkling.Context method)
partitionBy() (pysparkling.RDD method)
persist() (pysparkling.RDD method)
pickleFile() (pysparkling.Context method)
pipe() (pysparkling.RDD method)
pprint() (pysparkling.streaming.DStream method)
project_name (pysparkling.fileio.fs.GS attribute)
Q
queueStream() (pysparkling.streaming.StreamingContext method)
R
randomSplit() (pysparkling.RDD method)
RDD (class in pysparkling)
reduce() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
reduceByKey() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
remember() (pysparkling.streaming.StreamingContext method)
repartition() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
repartitionAndSortWithinPartitions() (pysparkling.RDD method)
resolve_filenames() (pysparkling.fileio.File static method)
(pysparkling.fileio.fs.FileSystem static method)
rightOuterJoin() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
runJob() (pysparkling.Context method)
S
S3 (class in pysparkling.fileio.fs)
sample() (pysparkling.RDD method)
sampleByKey() (pysparkling.RDD method)
sampleStdev() (pysparkling.RDD method)
sampleVariance() (pysparkling.RDD method)
saveAsPickleFile() (pysparkling.RDD method)
saveAsTextFile() (pysparkling.RDD method)
saveAsTextFiles() (pysparkling.streaming.DStream method)
SevenZ (class in pysparkling.fileio.codec)
slice() (pysparkling.streaming.DStream method)
socketBinaryStream() (pysparkling.streaming.StreamingContext method)
socketTextStream() (pysparkling.streaming.StreamingContext method)
sortBy() (pysparkling.RDD method)
sortByKey() (pysparkling.RDD method)
sparkContext (pysparkling.streaming.StreamingContext attribute)
start() (pysparkling.streaming.StreamingContext method)
StatCounter (class in pysparkling)
stats() (pysparkling.RDD method)
stdev() (pysparkling.RDD method)
stop() (pysparkling.streaming.StreamingContext method)
StreamingContext (class in pysparkling.streaming)
subtract() (pysparkling.RDD method)
sum() (pysparkling.RDD method)
T
take() (pysparkling.RDD method)
takeSample() (pysparkling.RDD method)
Tar (class in pysparkling.fileio.codec)
TarBz2 (class in pysparkling.fileio.codec)
TarGz (class in pysparkling.fileio.codec)
TextFile (class in pysparkling.fileio)
textFile() (pysparkling.Context method)
textFileStream() (pysparkling.streaming.StreamingContext method)
toLocalIterator() (pysparkling.RDD method)
top() (pysparkling.RDD method)
transform() (pysparkling.streaming.DStream method)
transformWith() (pysparkling.streaming.DStream method)
U
union() (pysparkling.Context method)
(pysparkling.RDD method)
(pysparkling.streaming.DStream method)
updateStateByKey() (pysparkling.streaming.DStream method)
V
values() (pysparkling.RDD method)
variance() (pysparkling.RDD method)
W
wholeTextFiles() (pysparkling.Context method)
window() (pysparkling.streaming.DStream method)
Z
Zip (class in pysparkling.fileio.codec)
zip() (pysparkling.RDD method)
zipWithIndex() (pysparkling.RDD method)
zipWithUniqueId() (pysparkling.RDD method)
Read the Docs
v: doc-updates
Versions
latest
stable
Downloads
htmlzip
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.