test_class.declarator: NUM_ITERATIONS = 100000
test_class.modifier: private static final
test_class.original_string: private static final int NUM_ITERATIONS = 100000;
test_class.type: int
test_class.var_name: NUM_ITERATIONS
test_class.file: ml/streaminer/src/test/java/org/streaminer/stream/frequency/topk/TestConcurrentStreamSummary.java
test_class.identifier: TestConcurrentStreamSummary
test_case.body: @Test
      public void testStreamSummary() {
          ConcurrentStreamSummary<String> vs = new ConcurrentStreamSummary<String>(3);
          String[] stream = {"X", "X", "Y", "Z", "A", "B", "C", "X", "X", "A", "A", "A"};
          for (String i : stream)
          {
                  vs.add(i);
                  /*
          for(String s : vs.poll(3))
          System.out.print(s+" ");
                   */
                  System.out.println(vs);
          }
      }
test_case.class_method_signature: TestConcurrentStreamSummary.testStreamSummary()
test_case.full_signature: @Test public void testStreamSummary()
test_case.identifier: testStreamSummary
test_case.invocations: add println
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testStreamSummary()
focal_class.declarator: capacity
focal_class.modifier: private final
focal_class.original_string: private final int capacity;
focal_class.type: int
focal_class.var_name: capacity
focal_class.declarator: itemMap
focal_class.modifier: private final
focal_class.original_string: private final ConcurrentHashMap<T, ScoredItem> itemMap;
focal_class.type: ConcurrentHashMap<T, ScoredItem>
focal_class.var_name: itemMap
focal_class.declarator: minVal
focal_class.modifier: private final
focal_class.original_string: private final AtomicReference<ScoredItem> minVal;
focal_class.type: AtomicReference<ScoredItem>
focal_class.var_name: minVal
focal_class.declarator: size
focal_class.modifier: private final
focal_class.original_string: private final AtomicLong size;
focal_class.type: AtomicLong
focal_class.var_name: size
focal_class.declarator: reachCapacity
focal_class.modifier: private final
focal_class.original_string: private final AtomicBoolean reachCapacity;
focal_class.type: AtomicBoolean
focal_class.var_name: reachCapacity
focal_class.file: ml/streaminer/src/main/java/org/streaminer/stream/frequency/topk/ConcurrentStreamSummary.java
focal_class.identifier: ConcurrentStreamSummary
focal_class.interfaces: implements ITopK<T>
focal_class.class_method_signature: ConcurrentStreamSummary.ConcurrentStreamSummary(final int capacity)
focal_class.full_signature: public  ConcurrentStreamSummary(final int capacity)
focal_class.identifier: ConcurrentStreamSummary
focal_class.modifiers: public
focal_class.parameters: (final int capacity)
focal_class.signature:  ConcurrentStreamSummary(final int capacity)
focal_class.class_method_signature: ConcurrentStreamSummary.add(final T element)
focal_class.full_signature: @Override public boolean add(final T element)
focal_class.identifier: add
focal_class.modifiers: @Override public
focal_class.parameters: (final T element)
focal_class.return: boolean
focal_class.signature: boolean add(final T element)
focal_class.class_method_signature: ConcurrentStreamSummary.add(final T element, final long incrementCount)
focal_class.full_signature: @Override public boolean add(final T element, final long incrementCount)
focal_class.identifier: add
focal_class.modifiers: @Override public
focal_class.parameters: (final T element, final long incrementCount)
focal_class.return: boolean
focal_class.signature: boolean add(final T element, final long incrementCount)
focal_class.class_method_signature: ConcurrentStreamSummary.getMinValue()
focal_class.full_signature: private ScoredItem getMinValue()
focal_class.identifier: getMinValue
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: ScoredItem
focal_class.signature: ScoredItem getMinValue()
focal_class.class_method_signature: ConcurrentStreamSummary.toString()
focal_class.full_signature: @Override public String toString()
focal_class.identifier: toString
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_class.class_method_signature: ConcurrentStreamSummary.peek(final int k)
focal_class.full_signature: @Override public List<CountEntry<T>> peek(final int k)
focal_class.identifier: peek
focal_class.modifiers: @Override public
focal_class.parameters: (final int k)
focal_class.return: List<CountEntry<T>>
focal_class.signature: List<CountEntry<T>> peek(final int k)
focal_class.class_method_signature: ConcurrentStreamSummary.size()
focal_class.full_signature: public long size()
focal_class.identifier: size
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: long
focal_class.signature: long size()
focal_class.class_method_signature: ConcurrentStreamSummary.peekWithScores(final int k)
focal_class.full_signature: public List<ScoredItem<T>> peekWithScores(final int k)
focal_class.identifier: peekWithScores
focal_class.modifiers: public
focal_class.parameters: (final int k)
focal_class.return: List<ScoredItem<T>>
focal_class.signature: List<ScoredItem<T>> peekWithScores(final int k)
focal_method.body: @Override
      public boolean add(final T element) {
          return add(element, 1);
      }
focal_method.class_method_signature: ConcurrentStreamSummary.add(final T element)
focal_method.full_signature: @Override public boolean add(final T element)
focal_method.identifier: add
focal_method.invocations: add
focal_method.modifiers: @Override public
focal_method.parameters: (final T element)
focal_method.return: boolean
focal_method.signature: boolean add(final T element)