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!
  • [no subject] ?9?0?9?0
    • Re: Eugene Kirpichov

Reply via email to