Package org.apache.commons.lang.mutable

Examples of org.apache.commons.lang.mutable.MutableLong

204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
    Map<Integer,FrequentPatternMaxHeap> patterns = Maps.newHashMap();
    for (int attribute : tree.attrIterableRev()) {
      if (requiredFeatures.contains(attribute)) {
        log.info("Mining FTree Tree for all patterns with {}", attribute);
        MutableLong minSupport = new MutableLong(minSupportValue);
        FrequentPatternMaxHeap frequentPatterns = growth(tree, minSupport, k,
                                                         attribute, updater);
        patterns.put(attribute, frequentPatterns);
        outputCollector.collect(attribute, frequentPatterns);

        minSupportValue = Math.max(minSupportValue, minSupport.longValue() / 2);
        log.info("Found {} Patterns with Least Support {}", patterns.get(
            attribute).count(), patterns.get(attribute).leastSupport());
      }
    }
    return patterns;
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
      Pair<List<A>,Long> transaction = transactions.next();
      for (A attribute : transaction.getFirst()) {
        if (attributeSupport.containsKey(attribute)) {
          attributeSupport.get(attribute).add(transaction.getSecond().longValue());
        } else {
          attributeSupport.put(attribute, new MutableLong(transaction.getSecond()));
        }
      }
    }
    List<Pair<A,Long>> fList = Lists.newArrayList();
    for (Entry<A,MutableLong> e : attributeSupport.entrySet()) {
View Full Code Here
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
    FPTreeDepthCache treeCache = new FPTreeDepthCache();
    for (int i = tree.getHeaderTableCount() - 1; i >= 0; i--) {
      int attribute = tree.getAttributeAtIndex(i);
      if (requiredFeatures.contains(attribute)) {
        log.info("Mining FTree Tree for all patterns with {}", attribute);
        MutableLong minSupport = new MutableLong(minSupportValue);
        FrequentPatternMaxHeap frequentPatterns = growth(tree, minSupport, k,
                                                         treeCache, 0, attribute, updater);
        patterns.put(attribute, frequentPatterns);
        outputCollector.collect(attribute, frequentPatterns);

        minSupportValue = Math.max(minSupportValue, minSupport.longValue() / 2);
        log.info("Found {} Patterns with Least Support {}", patterns.get(
            attribute).count(), patterns.get(attribute).leastSupport());
      }
    }
    log.info("Tree Cache: First Level: Cache hits={} Cache Misses={}",
View Full Code Here
178
179
180
181
182
183
184
185
186
187
188
    while (it.hasNext()) {
      Pair<IntArrayList,Long> p = it.next();
      IntArrayList items = p.getFirst();
      for (int idx = 0; idx < items.size(); idx++) {
        if (!frequencyList.containsKey(items.get(idx))) {
          frequencyList.put(items.get(idx), new MutableLong(0));
        }
        frequencyList.get(items.get(idx)).add(p.getSecond());
      }
    }
    return frequencyList;
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
103
104
105
  public void updateCounter(String groupName, String counterName, long newCounts)
  {
    Counter counter = this.getCounterByName (groupName, counterName);
    synchronized(this.counts)
    {
      MutableLong count;
      if( (count=this.counts.get (counter))==null )
      {
        count = new MutableLong(0L);
        this.counts.put (counter, count);
      }
      count.setValue (newCounts);
    }
  }
View Full Code Here
TOP

Related Classes of org.apache.commons.lang.mutable.MutableLong

  • com.ebay.erl.mobius.core.mapred.CounterUpdateThread
  • org.apache.accumulo.core.client.impl.ConditionalWriterImpl
  • org.apache.accumulo.core.file.rfile.RFile$LocalityGroupMetadata
  • org.apache.accumulo.core.util.PartitionerTest
  • org.apache.accumulo.tserver.InMemoryMap$LocalityGroupMap
  • org.apache.jorphan.math.StatCalculator
  • org.apache.mahout.common.cache.LFUCache
  • org.apache.mahout.common.DummyReporter
  • org.apache.mahout.fpm.pfpgrowth.fpgrowth.FPGrowth
  • org.apache.mahout.fpm.pfpgrowth.fpgrowth2.FPGrowthIds
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.