Examples of AggregationKey

mondrian.rolap.agg.AggregationKey
rian-release/3.2/src/main/mondrian/rolap/agg/AggregationKey.java#2 $
net.java.btrace.ext.aggregations.AggregationKey

Examples of mondrian.rolap.agg.AggregationKey

            if (cacheAggregations && !RolapStar.disableCaching) {
                synchronized (sharedAggregations) {
                    for (Map.Entry<AggregationKey, Aggregation> e
                        : sharedAggregations.entrySet())
                    {
                        AggregationKey aggregationKey = e.getKey();


                        Aggregation aggregation = e.getValue();
                        if (changeListener.isAggregationChanged(aggregation)) {
                            // Create new thread local aggregation
                            // This thread will renew aggregations

View Full Code Here

Examples of mondrian.rolap.agg.AggregationKey

                // to global cache, because it was in use
                Iterator<Map.Entry<AggregationKey, Aggregation>>
                    it = pendingAggregations.entrySet().iterator();
                while (it.hasNext()) {
                    Map.Entry<AggregationKey, Aggregation> e = it.next();
                    AggregationKey aggregationKey = e.getKey();
                    Aggregation aggregation = e.getValue();
                    // In case this aggregation is not requested by anyone
                    // this aggregation may be pushed into global cache
                    // otherwise put it in pending cache, that will be pushed
                    // when another query finishes
                    if (!isAggregationRequested(aggregationKey)) {
                        pushAggregateModification(
                            aggregationKey, aggregation, sharedAggregations);
                        it.remove();
                    }
                }
                // Push thread local modifications
                it = localAggregations.get().entrySet().iterator();
                while (it.hasNext()) {
                    Map.Entry<AggregationKey, Aggregation> e = it.next();
                    AggregationKey aggregationKey = e.getKey();
                    Aggregation aggregation = e.getValue();
                    // In case this aggregation is not requested by anyone
                    // this aggregation may be pushed into global cache
                    // otherwise put it in pending cache, that will be pushed
                    // when another query finishes

View Full Code Here

Examples of mondrian.rolap.agg.AggregationKey

                Iterator<Map.Entry<AggregationKey, Aggregation>>
                        it = destAggregations.entrySet().iterator();
                while (it.hasNext()) {
                    Map.Entry<AggregationKey, Aggregation> e =
                        it.next();
                    AggregationKey aggregationKey = e.getKey();
                    Aggregation aggregation = e.getValue();


                    if (localAggregationKey.equals(aggregationKey)) {
                        if (localAggregation.getCreationTimestamp().after(
                            aggregation.getCreationTimestamp()))

View Full Code Here

Examples of mondrian.rolap.agg.AggregationKey

            // quadratic algorithm if it is large.
            Set<AggregationKey> localAggregationRequestSet =
                new HashSet<AggregationKey>(localAggregationRequests.get());
            Iterator<AggregationKey> iter = aggregationRequests.iterator();
            while (iter.hasNext()) {
                AggregationKey aggregationKey = iter.next();
                if (localAggregationRequestSet.contains(aggregationKey)) {
                    iter.remove();
                    // Make sure that bitKey is not removed more than once:
                    // other occurrences might exist for other threads.
                    localAggregationRequestSet.remove(aggregationKey);

View Full Code Here

Examples of net.java.btrace.ext.aggregations.AggregationKey

        clazz="+java.lang.Thread",
        method="run",
    location=@Location(value=Kind.ENTRY, clazz="/.*/", method="/.*/")
    )
    public static void threadEntry(@ProbeMethodName String probeMethod, @ProbeClassName String probeClass) { // all calls to the info methods with signature "(String)"
    AggregationKey key = Aggregations.newAggregationKey(probeClass);
    currThread = currentThread();
    
    Aggregations.addToAggregation(threadsLiveCount, key, 1);
    }

View Full Code Here

Examples of net.java.btrace.ext.aggregations.AggregationKey

        clazz="+java.lang.Thread",
        method="run",
    location=@Location(value=Kind.RETURN, clazz="/.*/", method="/.*/")
    )
    public static void threadReturn(@ProbeMethodName String probeMethod, @ProbeClassName String probeClass) { // all calls to the info methods with signature "(String)"
    AggregationKey key = Aggregations.newAggregationKey(probeClass);
    
    Aggregations.addToAggregation(threadsLiveCount, key, -1);
    }

View Full Code Here

TOP

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.