void function ( ) { operator . open ( ) ; }
calls org.apache.flink.streaming.api.operators.streamoperator #open . concode_field_sep ConcurrentLinkedQueue<Object> outputList concode_elem_sep ExecutionConfig executionConfig concode_elem_sep TypeSerializer<OUT> outputSerializer concode_elem_sep Object checkpointLock concode_elem_sep TwoInputStreamOperator<IN1,IN2,OUT> operator concode_field_sep void processElement1 concode_elem_sep void emitWatermark concode_elem_sep void processElement2 concode_elem_sep void processWatermark1 concode_elem_sep void close concode_elem_sep void close concode_elem_sep void processWatermark2 concode_elem_sep void collect concode_elem_sep ConcurrentLinkedQueue<Object> getOutput