pysparkling
latest
pysparkling
Reading and Writing
API
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
accumulator() (pysparkling.Context method)
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.Bz2 method)
(pysparkling.fileio.codec.Codec method)
(pysparkling.fileio.codec.Gz method)
(pysparkling.fileio.codec.Lzma method)
(pysparkling.fileio.codec.SevenZ method)
(pysparkling.fileio.codec.Tar method)
(pysparkling.fileio.codec.TarBz2 method)
(pysparkling.fileio.codec.TarGz method)
(pysparkling.fileio.codec.Zip 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)
countApproxDistinct() (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.Bz2 method)
(pysparkling.fileio.codec.Codec method)
(pysparkling.fileio.codec.Gz method)
(pysparkling.fileio.codec.Lzma method)
(pysparkling.fileio.codec.SevenZ method)
(pysparkling.fileio.codec.Tar method)
(pysparkling.fileio.codec.TarBz2 method)
(pysparkling.fileio.codec.TarGz method)
(pysparkling.fileio.codec.Zip method)
distinct() (pysparkling.RDD method)
DStream (class in pysparkling.streaming)
dump() (pysparkling.fileio.File method)
(pysparkling.fileio.TextFile method)
(pysparkling.fileio.fs.FileSystem method)
(pysparkling.fileio.fs.GS method)
(pysparkling.fileio.fs.Hdfs method)
(pysparkling.fileio.fs.Http method)
(pysparkling.fileio.fs.Local method)
(pysparkling.fileio.fs.S3 method)
E
exists() (pysparkling.fileio.File method)
(pysparkling.fileio.fs.FileSystem method)
(pysparkling.fileio.fs.GS method)
(pysparkling.fileio.fs.Hdfs method)
(pysparkling.fileio.fs.Http method)
(pysparkling.fileio.fs.Local method)
(pysparkling.fileio.fs.S3 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
get_content() (pysparkling.fileio.File class method)
getNumPartitions() (pysparkling.RDD method)
getPartitions() (pysparkling.RDD method)
glom() (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
id() (pysparkling.RDD method)
intersection() (pysparkling.RDD method)
isEmpty() (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)
(pysparkling.fileio.fs.GS method)
(pysparkling.fileio.fs.Hdfs method)
(pysparkling.fileio.fs.Http method)
(pysparkling.fileio.fs.Local method)
(pysparkling.fileio.fs.S3 method)
load_text() (pysparkling.fileio.fs.FileSystem method)
(pysparkling.fileio.fs.GS method)
(pysparkling.fileio.fs.Hdfs method)
(pysparkling.fileio.fs.Http method)
(pysparkling.fileio.fs.Local method)
(pysparkling.fileio.fs.S3 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)
(pysparkling.fileio.fs.GS method)
(pysparkling.fileio.fs.S3 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)
meanApprox() (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)
reduceByKeyLocally() (pysparkling.RDD method)
remember() (pysparkling.streaming.StreamingContext method)
repartition() (pysparkling.RDD method)
(pysparkling.streaming.DStream method)
repartitionAndSortWithinPartitions() (pysparkling.RDD method)
resolve_content() (pysparkling.fileio.fs.FileSystem static method)
(pysparkling.fileio.fs.GS static method)
(pysparkling.fileio.fs.Hdfs class method)
(pysparkling.fileio.fs.Local static method)
(pysparkling.fileio.fs.S3 class method)
resolve_filenames() (pysparkling.fileio.File static method)
(pysparkling.fileio.fs.FileSystem static method)
(pysparkling.fileio.fs.GS static method)
(pysparkling.fileio.fs.Hdfs static method)
(pysparkling.fileio.fs.Http static method)
(pysparkling.fileio.fs.Local static method)
(pysparkling.fileio.fs.S3 class 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)
setName() (pysparkling.RDD 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)
subtractByKey() (pysparkling.RDD method)
sum() (pysparkling.RDD method)
sumApprox() (pysparkling.RDD method)
T
take() (pysparkling.RDD method)
takeOrdered() (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)
toDF() (pysparkling.RDD method)
toLocalIterator() (pysparkling.RDD method)
top() (pysparkling.RDD method)
transform() (pysparkling.streaming.DStream method)
transformWith() (pysparkling.streaming.DStream method)
treeAggregate() (pysparkling.RDD method)
treeReduce() (pysparkling.RDD method)
U
union() (pysparkling.Context method)
(pysparkling.RDD method)
(pysparkling.streaming.DStream method)
unpersist() (pysparkling.RDD 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: latest
Versions
latest
stable
doc-updates
Downloads
html
On Read the Docs
Project Home
Builds
Free document hosting provided by
Read the Docs
.