Hi Lifecycle:
1) DoFn created over new DoFn 2) serialization 3) transfer to workers 4) deserialization 5) @Setup (preparing for work) for every part of data 6) @StartBundle (before every bundle) 7) @ProcessElement 8) @FinishBundle 9) @Teardown (shutdown function) You can't pass argument in setup() because this function called on remote machine after deserialization. Thanks, Alexey Diomin 2017-01-11 16:20 GMT+04:00 陈竞 <[email protected]>: > i want to get some configuration in my own DoFn.setup(), but i see that > setup() has no argument, i cant get anything. while in hadoop's api Mapper > has function setup(Context c). >
