-
Notifications
You must be signed in to change notification settings - Fork 911
Open
Description
@jadianes
hello I'm Hiroyuki.
nice Tutorial, Thank you!
In[7]
tcp_interactions_out = tcp_interactions.map(lambda p: "Duration: {}, Dest. bytes: {}".format(p.duration, p.dst_bytes))
for ti_out in tcp_interactions_out.collect():
print ti_out
but map can use only for RDD.
so we need to change tcp_interactions(DataFrame) to RDD , I think.
here is the sample
tcp_interactions_out = tcp_interactions.rdd.map(lambda p: "Duration: {}, Dest. bytes: {}".format(p.duration, p.dst_bytes))
for ti_out in tcp_interactions_out.collect():
print ti_out
how do you think about it?
If there is my mistake in my code or in my sentence , sorry. (couse Im not good at writting English)
please forgive me if I make you feel bad.
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels