test_class.file: flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/StreamFilterTest.java
test_class.identifier: StreamFilterTest
test_case.body: @Test
  	public void testOpenClose() throws Exception {
  		StreamFilter<String> operator = new StreamFilter<String>(new TestOpenCloseFilterFunction());
  
  		OneInputStreamOperatorTestHarness<String, String> testHarness = new OneInputStreamOperatorTestHarness<String, String>(operator);
  
  		long initialTime = 0L;
  
  		testHarness.open();
  
  		testHarness.processElement(new StreamRecord<String>("fooHello", initialTime));
  		testHarness.processElement(new StreamRecord<String>("bar", initialTime));
  
  		testHarness.close();
  
  		Assert.assertTrue("RichFunction methods where not called.", TestOpenCloseFilterFunction.closeCalled);
  		Assert.assertTrue("Output contains no elements.", testHarness.getOutput().size() > 0);
  	}
test_case.class_method_signature: StreamFilterTest.testOpenClose()
test_case.full_signature: @Test public void testOpenClose()
test_case.identifier: testOpenClose
test_case.invocations: open processElement processElement close assertTrue assertTrue size getOutput
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testOpenClose()
focal_class.declarator: serialVersionUID = 1L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = 1L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.file: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFilter.java
focal_class.identifier: StreamFilter
focal_class.interfaces: implements OneInputStreamOperator<IN, IN>
focal_class.class_method_signature: StreamFilter.StreamFilter(FilterFunction<IN> filterFunction)
focal_class.full_signature: public  StreamFilter(FilterFunction<IN> filterFunction)
focal_class.identifier: StreamFilter
focal_class.modifiers: public
focal_class.parameters: (FilterFunction<IN> filterFunction)
focal_class.signature:  StreamFilter(FilterFunction<IN> filterFunction)
focal_class.class_method_signature: StreamFilter.processElement(StreamRecord<IN> element)
focal_class.full_signature: @Override public void processElement(StreamRecord<IN> element)
focal_class.identifier: processElement
focal_class.modifiers: @Override public
focal_class.parameters: (StreamRecord<IN> element)
focal_class.return: void
focal_class.signature: void processElement(StreamRecord<IN> element)
focal_class.class_method_signature: StreamFilter.processWatermark(Watermark mark)
focal_class.full_signature: @Override public void processWatermark(Watermark mark)
focal_class.identifier: processWatermark
focal_class.modifiers: @Override public
focal_class.parameters: (Watermark mark)
focal_class.return: void
focal_class.signature: void processWatermark(Watermark mark)
focal_class.superclass: extends AbstractUdfStreamOperator<IN, FilterFunction<IN>>
focal_method.body: @Override
  	public void processElement(StreamRecord<IN> element) throws Exception {
  		if (userFunction.filter(element.getValue())) {
  			output.collect(element);
  		}
  	}
focal_method.class_method_signature: StreamFilter.processElement(StreamRecord<IN> element)
focal_method.full_signature: @Override public void processElement(StreamRecord<IN> element)
focal_method.identifier: processElement
focal_method.invocations: filter getValue collect
focal_method.modifiers: @Override public
focal_method.parameters: (StreamRecord<IN> element)
focal_method.return: void
focal_method.signature: void processElement(StreamRecord<IN> element)