Skip to content
This repository was archived by the owner on Dec 23, 2023. It is now read-only.

Commit ff43823

Browse files
authored
Rename StatsRecord to MeasureMap (#757)
1 parent ce6d16a commit ff43823

File tree

13 files changed

+108
-106
lines changed

13 files changed

+108
-106
lines changed

api/src/main/java/io/opencensus/stats/StatsRecord.java renamed to api/src/main/java/io/opencensus/stats/MeasureMap.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323

2424
/** A map from {@link Measure}s to measured values to be recorded at the same time. */
2525
@NotThreadSafe
26-
public abstract class StatsRecord {
26+
public abstract class MeasureMap {
2727

2828
/**
2929
* Associates the {@link MeasureDouble} with the given value. Subsequent updates to the same
@@ -33,7 +33,7 @@ public abstract class StatsRecord {
3333
* @param value the value to be associated with {@code measure}
3434
* @return this
3535
*/
36-
public abstract StatsRecord put(MeasureDouble measure, double value);
36+
public abstract MeasureMap put(MeasureDouble measure, double value);
3737

3838
/**
3939
* Associates the {@link MeasureLong} with the given value. Subsequent updates to the same {@link
@@ -43,19 +43,19 @@ public abstract class StatsRecord {
4343
* @param value the value to be associated with {@code measure}
4444
* @return this
4545
*/
46-
public abstract StatsRecord put(MeasureLong measure, long value);
46+
public abstract MeasureMap put(MeasureLong measure, long value);
4747

4848
/**
4949
* Records all of the measures at the same time, with the current {@link TagContext}.
5050
*
51-
* <p>This method records all of the stats in the {@code StatsRecord} every time it is called.
51+
* <p>This method records all of the stats in the {@code MeasureMap} every time it is called.
5252
*/
5353
public abstract void record();
5454

5555
/**
5656
* Records all of the measures at the same time, with an explicit {@link TagContext}.
5757
*
58-
* <p>This method records all of the stats in the {@code StatsRecord} every time it is called.
58+
* <p>This method records all of the stats in the {@code MeasureMap} every time it is called.
5959
*
6060
* @param tags the tags associated with the measurements.
6161
*/

api/src/main/java/io/opencensus/stats/NoopStats.java

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -61,12 +61,12 @@ static StatsRecorder getNoopStatsRecorder() {
6161
}
6262

6363
/**
64-
* Returns a {@code StatsRecord} that ignores all calls to {@link StatsRecord#put}.
64+
* Returns a {@code MeasureMap} that ignores all calls to {@link MeasureMap#put}.
6565
*
66-
* @return a {@code StatsRecord} that ignores all calls to {@code StatsRecord#put}.
66+
* @return a {@code MeasureMap} that ignores all calls to {@code MeasureMap#put}.
6767
*/
68-
static StatsRecord getNoopStatsRecord() {
69-
return NoopStatsRecord.INSTANCE;
68+
static MeasureMap getNoopMeasureMap() {
69+
return NoopMeasureMap.INSTANCE;
7070
}
7171

7272
/**
@@ -110,22 +110,22 @@ private static final class NoopStatsRecorder extends StatsRecorder {
110110
static final StatsRecorder INSTANCE = new NoopStatsRecorder();
111111

112112
@Override
113-
public StatsRecord newRecord() {
114-
return getNoopStatsRecord();
113+
public MeasureMap newMeasureMap() {
114+
return getNoopMeasureMap();
115115
}
116116
}
117117

118118
@Immutable
119-
private static final class NoopStatsRecord extends StatsRecord {
120-
static final StatsRecord INSTANCE = new NoopStatsRecord();
119+
private static final class NoopMeasureMap extends MeasureMap {
120+
static final MeasureMap INSTANCE = new NoopMeasureMap();
121121

122122
@Override
123-
public StatsRecord put(MeasureDouble measure, double value) {
123+
public MeasureMap put(MeasureDouble measure, double value) {
124124
return this;
125125
}
126126

127127
@Override
128-
public StatsRecord put(MeasureLong measure, long value) {
128+
public MeasureMap put(MeasureLong measure, long value) {
129129
return this;
130130
}
131131

api/src/main/java/io/opencensus/stats/StatsRecorder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,5 +25,5 @@ public abstract class StatsRecorder {
2525
*
2626
* @return an object for recording multiple measurements.
2727
*/
28-
public abstract StatsRecord newRecord();
28+
public abstract MeasureMap newMeasureMap();
2929
}

api/src/test/java/io/opencensus/stats/NoopStatsTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -85,7 +85,7 @@ public void noopStatsComponent_SetState_DisallowsNull() {
8585
@Test
8686
public void noopStatsRecorder_Record() {
8787
NoopStats.getNoopStatsRecorder()
88-
.newRecord()
88+
.newMeasureMap()
8989
.put(MEASURE, 5)
9090
.record(tagContext);
9191
}
@@ -94,13 +94,13 @@ public void noopStatsRecorder_Record() {
9494
// exception.
9595
@Test
9696
public void noopStatsRecorder_RecordWithCurrentContext() {
97-
NoopStats.getNoopStatsRecorder().newRecord().put(MEASURE, 6).record();
97+
NoopStats.getNoopStatsRecorder().newMeasureMap().put(MEASURE, 6).record();
9898
}
9999

100100
@Test
101101
public void noopStatsRecorder_Record_DisallowNullTagContext() {
102-
StatsRecord record = NoopStats.getNoopStatsRecorder().newRecord();
102+
MeasureMap measureMap = NoopStats.getNoopStatsRecorder().newMeasureMap();
103103
thrown.expect(NullPointerException.class);
104-
record.record(null);
104+
measureMap.record(null);
105105
}
106106
}

core_impl/src/main/java/io/opencensus/implcore/stats/StatsRecordImpl.java renamed to core_impl/src/main/java/io/opencensus/implcore/stats/MeasureMapImpl.java

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -18,31 +18,31 @@
1818

1919
import io.opencensus.stats.Measure.MeasureDouble;
2020
import io.opencensus.stats.Measure.MeasureLong;
21-
import io.opencensus.stats.StatsRecord;
21+
import io.opencensus.stats.MeasureMap;
2222
import io.opencensus.tags.TagContext;
2323
import io.opencensus.tags.unsafe.ContextUtils;
2424

25-
/** Implementation of {@link StatsRecord}. */
26-
final class StatsRecordImpl extends StatsRecord {
25+
/** Implementation of {@link MeasureMap}. */
26+
final class MeasureMapImpl extends MeasureMap {
2727
private final StatsManager statsManager;
28-
private final MeasureMap.Builder builder = MeasureMap.builder();
28+
private final MeasureMapInternal.Builder builder = MeasureMapInternal.builder();
2929

30-
static StatsRecordImpl create(StatsManager statsManager) {
31-
return new StatsRecordImpl(statsManager);
30+
static MeasureMapImpl create(StatsManager statsManager) {
31+
return new MeasureMapImpl(statsManager);
3232
}
3333

34-
private StatsRecordImpl(StatsManager statsManager) {
34+
private MeasureMapImpl(StatsManager statsManager) {
3535
this.statsManager = statsManager;
3636
}
3737

3838
@Override
39-
public StatsRecordImpl put(MeasureDouble measure, double value) {
39+
public MeasureMapImpl put(MeasureDouble measure, double value) {
4040
builder.put(measure, value);
4141
return this;
4242
}
4343

4444
@Override
45-
public StatsRecordImpl put(MeasureLong measure, long value) {
45+
public MeasureMapImpl put(MeasureLong measure, long value) {
4646
builder.put(measure, value);
4747
return this;
4848
}

core_impl/src/main/java/io/opencensus/implcore/stats/MeasureMap.java renamed to core_impl/src/main/java/io/opencensus/implcore/stats/MeasureMapInternal.java

Lines changed: 13 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -24,34 +24,35 @@
2424
import java.util.Iterator;
2525
import java.util.NoSuchElementException;
2626

27+
// TODO(songya): consider combining MeasureMapImpl and this class.
2728
/**
2829
* A map from {@link Measure}'s to measured values.
2930
*/
30-
final class MeasureMap {
31+
final class MeasureMapInternal {
3132

3233
/**
33-
* Returns a {@link Builder} for the {@link MeasureMap} class.
34+
* Returns a {@link Builder} for the {@link MeasureMapInternal} class.
3435
*/
3536
static Builder builder() {
3637
return new Builder();
3738
}
3839

3940
/**
40-
* Returns an {@link Iterator} over the measure/value mappings in this {@link MeasureMap}.
41+
* Returns an {@link Iterator} over the measure/value mappings in this {@link MeasureMapInternal}.
4142
* The {@code Iterator} does not support {@link Iterator#remove()}.
4243
*/
4344
Iterator<Measurement> iterator() {
44-
return new MeasureMapIterator();
45+
return new MeasureMapInternalIterator();
4546
}
4647

4748
private final ArrayList<Measurement> measurements;
4849

49-
private MeasureMap(ArrayList<Measurement> measurements) {
50+
private MeasureMapInternal(ArrayList<Measurement> measurements) {
5051
this.measurements = measurements;
5152
}
5253

5354
/**
54-
* Builder for the {@link MeasureMap} class.
55+
* Builder for the {@link MeasureMapInternal} class.
5556
*/
5657
static class Builder {
5758
/**
@@ -81,12 +82,12 @@ Builder put(MeasureLong measure, long value) {
8182
}
8283

8384
/**
84-
* Constructs a {@link MeasureMap} from the current measurements.
85+
* Constructs a {@link MeasureMapInternal} from the current measurements.
8586
*/
86-
MeasureMap build() {
87+
MeasureMapInternal build() {
8788
// Note: this makes adding measurements quadratic but is fastest for the sizes of
88-
// MeasureMaps that we should see. We may want to go to a strategy of sort/eliminate
89-
// for larger MeasureMaps.
89+
// MeasureMapInternals that we should see. We may want to go to a strategy of sort/eliminate
90+
// for larger MeasureMapInternals.
9091
for (int i = measurements.size() - 1; i >= 0; i--) {
9192
for (int j = i - 1; j >= 0; j--) {
9293
if (measurements.get(i).getMeasure() == measurements.get(j).getMeasure()) {
@@ -95,7 +96,7 @@ MeasureMap build() {
9596
}
9697
}
9798
}
98-
return new MeasureMap(measurements);
99+
return new MeasureMapInternal(measurements);
99100
}
100101

101102
private final ArrayList<Measurement> measurements = new ArrayList<Measurement>();
@@ -105,7 +106,7 @@ private Builder() {
105106
}
106107

107108
// Provides an unmodifiable Iterator over this instance's measurements.
108-
private final class MeasureMapIterator implements Iterator<Measurement> {
109+
private final class MeasureMapInternalIterator implements Iterator<Measurement> {
109110
@Override
110111
public boolean hasNext() {
111112
return position < length;

core_impl/src/main/java/io/opencensus/implcore/stats/MeasureToViewMap.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ synchronized void registerView(View view, Clock clock) {
108108
}
109109

110110
// Records stats with a set of tags.
111-
synchronized void record(TagContext tags, MeasureMap stats, Timestamp timestamp) {
111+
synchronized void record(TagContext tags, MeasureMapInternal stats, Timestamp timestamp) {
112112
Iterator<Measurement> iterator = stats.iterator();
113113
while (iterator.hasNext()) {
114114
Measurement measurement = iterator.next();

core_impl/src/main/java/io/opencensus/implcore/stats/StatsManager.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -49,17 +49,17 @@ ViewData getView(View.Name viewName) {
4949
return measureToViewMap.getView(viewName, clock);
5050
}
5151

52-
void record(TagContext tags, MeasureMap measurementValues) {
52+
void record(TagContext tags, MeasureMapInternal measurementValues) {
5353
queue.enqueue(new StatsEvent(this, tags, measurementValues));
5454
}
5555

5656
// An EventQueue entry that records the stats from one call to StatsManager.record(...).
5757
private static final class StatsEvent implements EventQueue.Entry {
5858
private final TagContext tags;
59-
private final MeasureMap stats;
59+
private final MeasureMapInternal stats;
6060
private final StatsManager statsManager;
6161

62-
StatsEvent(StatsManager statsManager, TagContext tags, MeasureMap stats) {
62+
StatsEvent(StatsManager statsManager, TagContext tags, MeasureMapInternal stats) {
6363
this.statsManager = statsManager;
6464
this.tags = tags;
6565
this.stats = stats;

core_impl/src/main/java/io/opencensus/implcore/stats/StatsRecorderImpl.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ public final class StatsRecorderImpl extends StatsRecorder {
3030
}
3131

3232
@Override
33-
public StatsRecordImpl newRecord() {
34-
return StatsRecordImpl.create(statsManager);
33+
public MeasureMapImpl newMeasureMap() {
34+
return MeasureMapImpl.create(statsManager);
3535
}
3636
}

core_impl/src/test/java/io/opencensus/implcore/stats/MeasureMapTest.java renamed to core_impl/src/test/java/io/opencensus/implcore/stats/MeasureMapInternalTest.java

Lines changed: 20 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -30,28 +30,29 @@
3030
import org.junit.runner.RunWith;
3131
import org.junit.runners.JUnit4;
3232

33-
/** Tests for {@link MeasureMap}. */
33+
/** Tests for {@link MeasureMapInternal}. */
3434
@RunWith(JUnit4.class)
35-
public class MeasureMapTest {
35+
public class MeasureMapInternalTest {
3636

3737
@Test
3838
public void testPutDouble() {
39-
MeasureMap metrics = MeasureMap.builder().put(M1, 44.4).build();
39+
MeasureMapInternal metrics = MeasureMapInternal.builder().put(M1, 44.4).build();
4040
assertContains(metrics, MeasurementDouble.create(M1, 44.4));
4141
}
4242

4343
@Test
4444
public void testPutLong() {
45-
MeasureMap metrics = MeasureMap.builder().put(M3, 9999L).put(M4, 8888L).build();
45+
MeasureMapInternal metrics = MeasureMapInternal.builder().put(M3, 9999L).put(M4, 8888L).build();
4646
assertContains(metrics,
4747
MeasurementLong.create(M3, 9999L),
4848
MeasurementLong.create(M4, 8888L));
4949
}
5050

5151
@Test
5252
public void testCombination() {
53-
MeasureMap metrics =
54-
MeasureMap.builder().put(M1, 44.4).put(M2, 66.6).put(M3, 9999L).put(M4, 8888L).build();
53+
MeasureMapInternal metrics =
54+
MeasureMapInternal.builder().put(M1, 44.4).put(M2, 66.6).put(M3, 9999L).put(M4, 8888L)
55+
.build();
5556
assertContains(metrics,
5657
MeasurementDouble.create(M1, 44.4),
5758
MeasurementDouble.create(M2, 66.6),
@@ -61,14 +62,14 @@ public void testCombination() {
6162

6263
@Test
6364
public void testBuilderEmpty() {
64-
MeasureMap metrics = MeasureMap.builder().build();
65+
MeasureMapInternal metrics = MeasureMapInternal.builder().build();
6566
assertContains(metrics);
6667
}
6768

6869
@Test
6970
public void testBuilder() {
7071
ArrayList<Measurement> expected = new ArrayList<Measurement>(10);
71-
MeasureMap.Builder builder = MeasureMap.builder();
72+
MeasureMapInternal.Builder builder = MeasureMapInternal.builder();
7273
for (int i = 1; i <= 10; i++) {
7374
expected
7475
.add(MeasurementDouble.create(makeSimpleMeasureDouble("m" + i), i * 11.1));
@@ -79,38 +80,38 @@ public void testBuilder() {
7980

8081
@Test
8182
public void testDuplicateMeasureDoubles() {
82-
assertContains(MeasureMap.builder().put(M1, 1.0).put(M1, 2.0).build(),
83+
assertContains(MeasureMapInternal.builder().put(M1, 1.0).put(M1, 2.0).build(),
8384
MeasurementDouble.create(M1, 2.0));
84-
assertContains(MeasureMap.builder().put(M1, 1.0).put(M1, 2.0).put(M1, 3.0).build(),
85+
assertContains(MeasureMapInternal.builder().put(M1, 1.0).put(M1, 2.0).put(M1, 3.0).build(),
8586
MeasurementDouble.create(M1, 3.0));
86-
assertContains(MeasureMap.builder().put(M1, 1.0).put(M2, 2.0).put(M1, 3.0).build(),
87+
assertContains(MeasureMapInternal.builder().put(M1, 1.0).put(M2, 2.0).put(M1, 3.0).build(),
8788
MeasurementDouble.create(M1, 3.0),
8889
MeasurementDouble.create(M2, 2.0));
89-
assertContains(MeasureMap.builder().put(M1, 1.0).put(M1, 2.0).put(M2, 2.0).build(),
90+
assertContains(MeasureMapInternal.builder().put(M1, 1.0).put(M1, 2.0).put(M2, 2.0).build(),
9091
MeasurementDouble.create(M1, 2.0),
9192
MeasurementDouble.create(M2, 2.0));
9293
}
9394

9495
@Test
9596
public void testDuplicateMeasureLongs() {
96-
assertContains(MeasureMap.builder().put(M3, 100L).put(M3, 100L).build(),
97+
assertContains(MeasureMapInternal.builder().put(M3, 100L).put(M3, 100L).build(),
9798
MeasurementLong.create(M3, 100L));
98-
assertContains(MeasureMap.builder().put(M3, 100L).put(M3, 200L).put(M3, 300L).build(),
99+
assertContains(MeasureMapInternal.builder().put(M3, 100L).put(M3, 200L).put(M3, 300L).build(),
99100
MeasurementLong.create(M3, 300L));
100-
assertContains(MeasureMap.builder().put(M3, 100L).put(M4, 200L).put(M3, 300L).build(),
101+
assertContains(MeasureMapInternal.builder().put(M3, 100L).put(M4, 200L).put(M3, 300L).build(),
101102
MeasurementLong.create(M3, 300L),
102103
MeasurementLong.create(M4, 200L));
103-
assertContains(MeasureMap.builder().put(M3, 100L).put(M3, 200L).put(M4, 200L).build(),
104+
assertContains(MeasureMapInternal.builder().put(M3, 100L).put(M3, 200L).put(M4, 200L).build(),
104105
MeasurementLong.create(M3, 200L),
105106
MeasurementLong.create(M4, 200L));
106107
}
107108

108109
@Test
109110
public void testDuplicateMeasures() {
110-
assertContains(MeasureMap.builder().put(M3, 100L).put(M1, 1.0).put(M3, 300L).build(),
111+
assertContains(MeasureMapInternal.builder().put(M3, 100L).put(M1, 1.0).put(M3, 300L).build(),
111112
MeasurementLong.create(M3, 300L),
112113
MeasurementDouble.create(M1, 1.0));
113-
assertContains(MeasureMap.builder().put(M2, 2.0).put(M3, 100L).put(M2, 3.0).build(),
114+
assertContains(MeasureMapInternal.builder().put(M2, 2.0).put(M3, 100L).put(M2, 3.0).build(),
114115
MeasurementDouble.create(M2, 3.0),
115116
MeasurementLong.create(M3, 100L));
116117
}
@@ -128,7 +129,7 @@ private static MeasureLong makeSimpleMeasureLong(String measure) {
128129
return Measure.MeasureLong.create(measure, measure + " description", "1");
129130
}
130131

131-
private static void assertContains(MeasureMap metrics, Measurement... measurements) {
132+
private static void assertContains(MeasureMapInternal metrics, Measurement... measurements) {
132133
assertThat(Lists.newArrayList(metrics.iterator())).containsExactly((Object[]) measurements);
133134
}
134135
}

0 commit comments

Comments
 (0)