test_class.declarator: window
test_class.modifier: private
test_class.original_string: private OverlappingBloomFilterBasedWindow window;
test_class.type: OverlappingBloomFilterBasedWindow
test_class.var_name: window
test_class.declarator: count
test_class.modifier: private
test_class.original_string: private int count;
test_class.type: int
test_class.var_name: count
test_class.declarator: windowSize
test_class.original_string: int windowSize;
test_class.type: int
test_class.var_name: windowSize
test_class.file: bigdata-intro/cep-intro/siddhi3-quick-start/src/main/java/org/wso2/siddhi/bloomfilter/OverlappingBloomFilterBasedWindowTest.java
test_class.identifier: OverlappingBloomFilterBasedWindowTest
test_case.body: @Test
      public void testWithStateEvent() {
  
          StreamEvent[] streamEvents1 =
                  { createStreamEvent("Hp", 210.45, 23),
                          createStreamEvent("Apple", 3500.50, 10),
                          createStreamEvent("Dell", 245.95, 78) };
  
          //addStateEvent(new StateEvent(streamEvents1), 3);
  
          Assert.assertTrue(window.find("price", 1000.55).isEmpty());
          Assert.assertFalse(window.find("price", 3500.50).isEmpty());
  
          StreamEvent[] streamEvents2 =
                  { createStreamEvent("Toshiba", 234.45, 24),
                          createStreamEvent("Dell", 456.45, 80),
                          createStreamEvent("Hp", 875.98, 70),
                          createStreamEvent("Hp", 223.87, 190),
                          createStreamEvent("Apple", 356.97, 76) };
  
          //addStateEvent(new StateEvent(streamEvents2), 5);
          Assert.assertFalse(window.find("price", 3500.50).isEmpty());
  
          StreamEvent[] streamEvents3 =
                  { createStreamEvent("Hp", 678.87, 65),
                          createStreamEvent("Toshiba", 235.95, 19),
                          createStreamEvent("Dell", 879.25, 57),
                          createStreamEvent("Hp", 345.45, 19),
                          createStreamEvent("Hp", 879.76, 86),
                          createStreamEvent("Apple", 719.82, 29),
                          createStreamEvent("Hp", 985.30, 112) };
  
          //addStateEvent(new StateEvent(streamEvents3), 7);
  
          Assert.assertTrue(window.find("price", 3500.50).isEmpty());
  
      }
test_case.class_method_signature: OverlappingBloomFilterBasedWindowTest.testWithStateEvent()
test_case.full_signature: @Test public void testWithStateEvent()
test_case.identifier: testWithStateEvent
test_case.invocations: createStreamEvent createStreamEvent createStreamEvent assertTrue isEmpty find assertFalse isEmpty find createStreamEvent createStreamEvent createStreamEvent createStreamEvent createStreamEvent assertFalse isEmpty find createStreamEvent createStreamEvent createStreamEvent createStreamEvent createStreamEvent createStreamEvent createStreamEvent assertTrue isEmpty find
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testWithStateEvent()
focal_class.declarator: expectedNoOfEventsPerWindow
focal_class.modifier: private
focal_class.original_string: private int expectedNoOfEventsPerWindow;
focal_class.type: int
focal_class.var_name: expectedNoOfEventsPerWindow
focal_class.declarator: joinAttributeId
focal_class.modifier: private
focal_class.original_string: private int[] joinAttributeId;
focal_class.type: int[]
focal_class.var_name: joinAttributeId
focal_class.declarator: overLapPrecentage
focal_class.modifier: private
focal_class.original_string: private int overLapPrecentage;
focal_class.type: int
focal_class.var_name: overLapPrecentage
focal_class.declarator: filterList
focal_class.modifier: private
focal_class.original_string: private ArrayList<BloomFilter> filterList;
focal_class.type: ArrayList<BloomFilter>
focal_class.var_name: filterList
focal_class.declarator: noOfEventList
focal_class.modifier: private
focal_class.original_string: private ArrayList<Integer> noOfEventList;
focal_class.type: ArrayList<Integer>
focal_class.var_name: noOfEventList
focal_class.declarator: eventQueue
focal_class.modifier: private
focal_class.original_string: private BlockingQueue<StreamEvent> eventQueue;
focal_class.type: BlockingQueue<StreamEvent>
focal_class.var_name: eventQueue
focal_class.declarator: bloomFilterSize
focal_class.modifier: private
focal_class.original_string: private int bloomFilterSize;
focal_class.type: int
focal_class.var_name: bloomFilterSize
focal_class.declarator: nonOverLapEvents
focal_class.modifier: private
focal_class.original_string: private int nonOverLapEvents;
focal_class.type: int
focal_class.var_name: nonOverLapEvents
focal_class.declarator: noOfHash
focal_class.modifier: private
focal_class.original_string: private int noOfHash;
focal_class.type: int
focal_class.var_name: noOfHash
focal_class.declarator: oldestAddingFilter
focal_class.modifier: private
focal_class.original_string: private int oldestAddingFilter;
focal_class.type: int
focal_class.var_name: oldestAddingFilter
focal_class.declarator: newestAddingFilter
focal_class.modifier: private
focal_class.original_string: private int newestAddingFilter;
focal_class.type: int
focal_class.var_name: newestAddingFilter
focal_class.declarator: removeEventCount
focal_class.modifier: private
focal_class.original_string: private int removeEventCount;
focal_class.type: int
focal_class.var_name: removeEventCount
focal_class.file: bigdata-intro/cep-intro/siddhi3-quick-start/src/main/java/org/wso2/siddhi/bloomfilter/OverlappingBloomFilterBasedWindow.java
focal_class.identifier: OverlappingBloomFilterBasedWindow
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.init(Expression[] expressions)
focal_class.full_signature: public void init(Expression[] expressions)
focal_class.identifier: init
focal_class.modifiers: public
focal_class.parameters: (Expression[] expressions)
focal_class.return: void
focal_class.signature: void init(Expression[] expressions)
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.add(ComplexEvent event)
focal_class.full_signature: public void add(ComplexEvent event)
focal_class.identifier: add
focal_class.modifiers: public
focal_class.parameters: (ComplexEvent event)
focal_class.return: void
focal_class.signature: void add(ComplexEvent event)
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.getLast(Boolean remove)
focal_class.full_signature: public ComplexEvent getLast(Boolean remove)
focal_class.identifier: getLast
focal_class.modifiers: public
focal_class.parameters: (Boolean remove)
focal_class.return: ComplexEvent
focal_class.signature: ComplexEvent getLast(Boolean remove)
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.find(String attributeName, Object value)
focal_class.full_signature: public List<ComplexEvent> find(String attributeName, Object value)
focal_class.identifier: find
focal_class.modifiers: public
focal_class.parameters: (String attributeName, Object value)
focal_class.return: List<ComplexEvent>
focal_class.signature: List<ComplexEvent> find(String attributeName, Object value)
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.remove(ComplexEvent event)
focal_class.full_signature: public void remove(ComplexEvent event)
focal_class.identifier: remove
focal_class.modifiers: public
focal_class.parameters: (ComplexEvent event)
focal_class.return: void
focal_class.signature: void remove(ComplexEvent event)
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.currentState()
focal_class.full_signature: public Object[] currentState()
focal_class.identifier: currentState
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Object[]
focal_class.signature: Object[] currentState()
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.restoreState(Object[] objects)
focal_class.full_signature: public void restoreState(Object[] objects)
focal_class.identifier: restoreState
focal_class.modifiers: public
focal_class.parameters: (Object[] objects)
focal_class.return: void
focal_class.signature: void restoreState(Object[] objects)
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.size()
focal_class.full_signature: public int size()
focal_class.identifier: size
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int size()
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.destroy()
focal_class.full_signature: public void destroy()
focal_class.identifier: destroy
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void destroy()
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.addStreamEvent(StreamEvent streamEvent)
focal_class.full_signature: private void addStreamEvent(StreamEvent streamEvent)
focal_class.identifier: addStreamEvent
focal_class.modifiers: private
focal_class.parameters: (StreamEvent streamEvent)
focal_class.return: void
focal_class.signature: void addStreamEvent(StreamEvent streamEvent)
focal_class.class_method_signature: OverlappingBloomFilterBasedWindow.removLastEventFromFilters()
focal_class.full_signature: private void removLastEventFromFilters()
focal_class.identifier: removLastEventFromFilters
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void removLastEventFromFilters()
focal_method.body: public List<ComplexEvent> find(String attributeName, Object value) {
  
          Key key = new Key(value.toString().getBytes());
          List<ComplexEvent> foundEventList = new ArrayList<ComplexEvent>();
  
          boolean isInFilters = false;
  
          for (int i = 0; i <= oldestAddingFilter; i++) {
              if (filterList.get(i).membershipTest(key)) {
                  isInFilters = true;
                  break;
              }
          }
  
          if (isInFilters) {
              Iterator<StreamEvent> iterator = eventQueue.iterator();
              while (iterator.hasNext()) {
                  StreamEvent streamEvent = iterator.next();
                  if (streamEvent.getAttribute(joinAttributeId).equals(value)) {
                      foundEventList.add(streamEvent);
                  }
              }
          }
  
          return foundEventList;
  
      }
focal_method.class_method_signature: OverlappingBloomFilterBasedWindow.find(String attributeName, Object value)
focal_method.full_signature: public List<ComplexEvent> find(String attributeName, Object value)
focal_method.identifier: find
focal_method.invocations: getBytes toString membershipTest get iterator hasNext next equals getAttribute add
focal_method.modifiers: public
focal_method.parameters: (String attributeName, Object value)
focal_method.return: List<ComplexEvent>
focal_method.signature: List<ComplexEvent> find(String attributeName, Object value)