Skip to content

Commit d3c3bc5

Browse files
vjkoskelaorborde
andauthored
Update DimensionInjectingSink to use ThreadLocalBuilder for PeriodicData. (#176)
Co-authored-by: Mechanized Catastrophe <[email protected]>
1 parent e1d3a8b commit d3c3bc5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/main/java/com/arpnetworking/tsdcore/sinks/DimensionInjectingSink.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,7 @@
1515
*/
1616
package com.arpnetworking.tsdcore.sinks;
1717

18+
import com.arpnetworking.commons.builder.ThreadLocalBuilder;
1819
import com.arpnetworking.tsdcore.model.DefaultKey;
1920
import com.arpnetworking.tsdcore.model.PeriodicData;
2021
import com.google.common.collect.ImmutableMap;
@@ -38,7 +39,7 @@ public void recordAggregateData(final PeriodicData data) {
3839
final Map<String, String> mergedDimensions = Maps.newHashMap(_defaultDimensions);
3940
mergedDimensions.putAll(data.getDimensions().getParameters());
4041
mergedDimensions.putAll(_overrideDimensions);
41-
final PeriodicData.Builder dataBuilder = PeriodicData.Builder.clone(data);
42+
final PeriodicData.Builder dataBuilder = ThreadLocalBuilder.clone(data);
4243
dataBuilder.setDimensions(new DefaultKey(ImmutableMap.copyOf(mergedDimensions)));
4344
_sink.recordAggregateData(dataBuilder.build());
4445
}

0 commit comments

Comments
 (0)