Package com.yammer.metrics.core

Examples of com.yammer.metrics.core.TimerContext.stop()

123
124
125
126
127
128
129
130
131
132
133
            // convert max key found back to an integer, and increment it
            startOffset = String.format(format, (1 + lastMaxKey));

            session.operations.getAndIncrement();
            session.keys.getAndAdd(lastQueryResultSize);
            context.stop();
        }
    }

    /**
     * Get maximum key from CqlRow list
View Full Code Here
89
90
91
92
93
94
95
96
97
98
99
                                        ByteBufferUtil.string(start),
                                        (exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
                }

                session.operations.getAndIncrement();
                context.stop();
            }

            session.keys.getAndAdd(slices.size());
        }
        else
View Full Code Here
136
137
138
139
140
141
142
143
144
                                    (exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
            }

            session.operations.getAndIncrement();
            session.keys.getAndAdd(slices.size());
            context.stop();
        }
    }
}
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
                                cqlQuery));
        }

        session.operations.getAndIncrement();
        session.keys.getAndIncrement();
        context.stop();
    }

    protected boolean validateThriftResult(CqlResult result)
    {
        return result.rows.get(0).columns.size() != 0;
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
                                cqlQuery));
        }

        session.operations.getAndIncrement();
        session.keys.getAndIncrement();
        context.stop();
    }

    protected boolean validateThriftResult(CqlResult result)
    {
        return true;
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
                                (exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
        }

        session.operations.getAndIncrement();
        session.keys.getAndIncrement();
        context.stop();
    }

    protected boolean validateThriftResult(CqlResult result)
    {
        return result.rows.get(0).columns.size() != 0;
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
                                    (exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
            }

            session.operations.getAndIncrement();
            session.keys.getAndIncrement();
            context.stop();
        }
    }

    private void runCounterGetter(SlicePredicate predicate, Cassandra.Client client) throws IOException
    {
View Full Code Here
145
146
147
148
149
150
151
152
                                (exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
        }

        session.operations.getAndIncrement();
        session.keys.getAndIncrement();
        context.stop();
    }
}
View Full Code Here
86
87
88
89
90
91
92
93
94
95
96
                                        (exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
                }

                session.operations.getAndIncrement();
                session.keys.getAndAdd(keys.size());
                context.stop();

                offset += session.getKeysPerCall();
            }
        }
        else
View Full Code Here
130
131
132
133
134
135
136
137
138
139
140
                                    (exceptionMessage == null) ? "" : "(" + exceptionMessage + ")"));
            }

            session.operations.getAndIncrement();
            session.keys.getAndAdd(keys.size());
            context.stop();

            offset += session.getKeysPerCall();
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.