class_docstr: Test case of valid data collection interface 
docstr: target: test filter() API for pipeline
  method: Get the input data, apply it to a function, check the function
          with filter_columns,then output.
  expected: output successfully
docstr_tok: ["target",":","test","filter","(",")","API","for","pipeline","method",":","Get","the","input","data",",","apply","it","to","a","function",",","check","the","function","with","filter_columns",",","then","output",".","expected",":","output","successfully"]
code: def test_data_collection_filter(self):
      """
      target: test filter() API for pipeline
      method: Get the input data, apply it to a function, check the function
              with filter_columns,then output.
      expected: output successfully
      """
      p = (
          towhee.pipe.input("a")
          .filter("a", "a", "a", lambda x: x > 10)
          .output("a")
      )
      assert p(1).get() is None
      assert p(11).get() == [11]
  
      # The order of filter() and map() can't be reversed here!
      q = (
          towhee.pipe.input("a")
          .filter("a", "a", "a", lambda x: x > 10)
          .map("a", "b", lambda x: x + 1)
          .output("b")
      )
      assert q(5).get() is None
      assert q(20).get() == [21]
      return True
  
imports: import sys
  import towhee
  import time
  import threading
  import numpy
  import random
  import operator
  from common import common_func
  from towhee import pipe, ops
label_desc: Use image node_id 5 for calling the TestDataCollectionAPIsValid obj's underlying member method code with example usage: obj.test_data_collection_filter() and returns: True