diff options
author | Henning Baldersheim <balder@verizonmedia.com> | 2020-03-08 16:51:08 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@verizonmedia.com> | 2020-03-08 16:51:08 +0000 |
commit | 5337561c2c1ebdaca4c0f84aeee6519f82117138 (patch) | |
tree | 8e4b8279c913886dca7612ebc624dcaf05e55d2a /vespaclient-java | |
parent | 014f5b6f712b004fc1c3956db100ad9f6cbf01fc (diff) |
Since resolving instances are error phrone we need to do it once.
Diffstat (limited to 'vespaclient-java')
-rw-r--r-- | vespaclient-java/src/main/java/com/yahoo/vespasummarybenchmark/VespaSummaryBenchmark.java | 26 |
1 files changed, 21 insertions, 5 deletions
diff --git a/vespaclient-java/src/main/java/com/yahoo/vespasummarybenchmark/VespaSummaryBenchmark.java b/vespaclient-java/src/main/java/com/yahoo/vespasummarybenchmark/VespaSummaryBenchmark.java index 16f8198a8ac..c47ffb241d2 100644 --- a/vespaclient-java/src/main/java/com/yahoo/vespasummarybenchmark/VespaSummaryBenchmark.java +++ b/vespaclient-java/src/main/java/com/yahoo/vespasummarybenchmark/VespaSummaryBenchmark.java @@ -5,13 +5,29 @@ import com.yahoo.compress.CompressionType; import com.yahoo.document.GlobalId; import com.yahoo.document.idstring.IdString; import com.yahoo.document.serialization.DeserializationException; -import com.yahoo.jrt.*; +import com.yahoo.jrt.DataValue; +import com.yahoo.jrt.Int32Value; +import com.yahoo.jrt.Int8Value; +import com.yahoo.jrt.Request; +import com.yahoo.jrt.RequestWaiter; +import com.yahoo.jrt.Spec; +import com.yahoo.jrt.Supervisor; +import com.yahoo.jrt.Target; +import com.yahoo.jrt.Transport; +import com.yahoo.jrt.Values; import com.yahoo.log.LogSetup; -import com.yahoo.slime.*; +import com.yahoo.slime.BinaryFormat; +import com.yahoo.slime.Cursor; +import com.yahoo.slime.JsonFormat; +import com.yahoo.slime.Slime; import net.jpountz.lz4.LZ4Factory; import net.jpountz.lz4.LZ4FastDecompressor; -import java.io.*; +import java.io.BufferedReader; +import java.io.DataInputStream; +import java.io.FileInputStream; +import java.io.IOException; +import java.io.InputStreamReader; import java.util.ArrayList; import java.util.List; @@ -26,6 +42,7 @@ import java.util.List; public class VespaSummaryBenchmark { private final Supervisor supervisor = new Supervisor(new Transport()); + private static final LZ4Factory lz4Factory = LZ4Factory.fastestInstance(); private VespaSummaryBenchmark() { } @@ -82,8 +99,7 @@ public class VespaSummaryBenchmark { int uncompressedSize = ret.get(1).asInt32(); byte [] blob = ret.get(2).asData(); if (type == CompressionType.LZ4) { - LZ4Factory factory = LZ4Factory.fastestInstance(); - LZ4FastDecompressor decompressor = factory.fastDecompressor(); + LZ4FastDecompressor decompressor = lz4Factory.fastDecompressor(); byte [] uncompressed = new byte [uncompressedSize]; int compressedLength = decompressor.decompress(blob, 0, uncompressed, 0, uncompressedSize); if (compressedLength != blob.length) { |