Sign in
apache
/
incubator-retired-amaterasu
/
c664db1b725e43fb2fbe03dc5fc83cd7b3a6bc21
/
.
/
executor
/
src
/
test
/
resources
/
pyspark-with-amacontext.py
blob: bd780a9c5a4dfeb1f46399a6dcf170bbf5fdbc5c [
file
] [
log
] [
blame
]
data
=
[
1
,
2
,
3
,
4
,
5
,
6
,
7
,
8
,
9
,
10
]
rdd
=
ama_context
.
sc
.
parallelize
(
data
)
odd
=
rdd
.
filter
(
lambda
num
:
num
%
2
!=
0
)