Skip to content

Commit

Permalink
Revert "Logging for testing" (#847)
Browse files Browse the repository at this point in the history
  • Loading branch information
burmanm committed Jul 14, 2017
1 parent c9a3567 commit c36ac76
Showing 1 changed file with 1 addition and 17 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2014-2017 Red Hat, Inc. and/or its affiliates
* Copyright 2014-2016 Red Hat, Inc. and/or its affiliates
* and other contributors as indicated by the @author tags.
*
* Licensed under the Apache License, Version 2.0 (the "License");
Expand All @@ -25,8 +25,6 @@

import org.hawkular.metrics.core.service.Order;
import org.hawkular.metrics.core.service.compress.TagsDeserializer;
import org.hawkular.metrics.core.service.log.CoreLogger;
import org.hawkular.metrics.core.service.log.CoreLogging;
import org.hawkular.metrics.model.AvailabilityType;
import org.hawkular.metrics.model.DataPoint;
import org.hawkular.metrics.model.MetricType;
Expand All @@ -46,8 +44,6 @@
*/
public class DataPointDecompressTransformer<T> implements Observable.Transformer<Row, DataPoint<T>> {

private static final CoreLogger log = CoreLogging.getCoreLogger(DataPointDecompressTransformer.class);

private Order order;
private int limit;
private long start;
Expand All @@ -73,18 +69,6 @@ public Observable<DataPoint<T>> call(Observable<Row> rows) {
ByteBuffer tagsBuffer = r.getBytes("tags");
ByteBuffer compressedValue = r.getBytes("c_value");

// Logging for soak-test
try {
byte[] array = compressedValue.array();
StringBuilder sb = new StringBuilder();
for(byte b : array) {
sb.append(String.format("%02x", b));
}
log.infof("ByteArrayContents: %s\n", sb.toString());
} catch(Exception e) {
// Ignore
}

if (compressedValue != null) {
// Read the HWKMETRICS internal header here, but don't process as of now
compressedValue.get();
Expand Down

0 comments on commit c36ac76

Please sign in to comment.