Hello! I am a beam user.
I want to ask you two questions.
First.
I use beam of my project and my data is jsonobject.I find in my flow,the
data will be Serializable and deSerializable many times,but i am not know where
use Serializable and deSerializable,because this question give me many time
exhaustion??so could you please tell me whether i can close it,only
Serializable on read and write.
Second.
I use beam and run on spark,but i find a problem,some keys have many value,and
create data Slant,so i want to know whether have some methods to solve it.I try
use Reshuffle.of(),does't have action.
Thanks for your answer!