StreamTaskState function ( long arg0 , long arg1 ) { return testHarness . snapshot ( arg0 , arg1 ) ; }
takes a snapshot of the current state of the operator . this can be used to test fault-tolerance . concode_field_sep boolean isOpen concode_elem_sep TestTimeServiceProvider timeServiceProvider concode_elem_sep ConcurrentLinkedQueue<Object> expectedOutputs concode_elem_sep long serialVersionUID concode_elem_sep OneInputStreamOperatorTestHarness<IN,IN> testHarness concode_field_sep int compare concode_elem_sep void processWatermark concode_elem_sep void restore concode_elem_sep void openOperator concode_elem_sep void apply concode_elem_sep void addExpectedWatermark concode_elem_sep void addExpectedElement concode_elem_sep void close concode_elem_sep void processElement concode_elem_sep void setProcessingTime concode_elem_sep void compareActualToExpectedOutput concode_elem_sep ConcurrentLinkedQueue<Object> getOutput