From 93dea402a5fad58a34e722bd0ec219680e242e60 Mon Sep 17 00:00:00 2001 From: Andreas Huber Date: Sat, 9 Feb 2019 15:25:39 +0100 Subject: [PATCH] remove obsolete class --- .../lucares/pdbui/CsvToEntryTransformer.java | 80 ------------------- 1 file changed, 80 deletions(-) delete mode 100644 pdb-ui/src/main/java/org/lucares/pdbui/CsvToEntryTransformer.java diff --git a/pdb-ui/src/main/java/org/lucares/pdbui/CsvToEntryTransformer.java b/pdb-ui/src/main/java/org/lucares/pdbui/CsvToEntryTransformer.java deleted file mode 100644 index b2fca9e..0000000 --- a/pdb-ui/src/main/java/org/lucares/pdbui/CsvToEntryTransformer.java +++ /dev/null @@ -1,80 +0,0 @@ -package org.lucares.pdbui; - -import java.io.IOException; -import java.util.Optional; -import java.util.regex.Pattern; - -import org.apache.commons.lang3.StringUtils; -import org.lucares.pdb.api.Entry; -import org.lucares.pdb.api.Tags; -import org.lucares.pdb.api.TagsBuilder; -import org.lucares.pdbui.date.FastISODateParser; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -// TODO remove? -public class CsvToEntryTransformer implements LineToEntryTransformer { - private static final Logger LOGGER = LoggerFactory.getLogger(CsvToEntryTransformer.class); - - private final String[] headers; - private final Pattern splitPattern = Pattern.compile(","); - private final FastISODateParser fastISODateParser = new FastISODateParser(); - - public CsvToEntryTransformer(final String[] headers) { - this.headers = headers; - } - - @Override - public Optional toEntry(final String line) throws IOException { - Optional result; - try { - // For future reference: - // Pattern.split is actually faster than StringUtils.splitPreserveAll when the - // test runs longer. - // It seems that the JIT is compiling StringUtils.splitPreserveAll earlier, but - // Pattern.split is ending up getting the faster code in the long run. - final String[] columns = splitPattern.split(line); - if (columns.length == headers.length && columns[0].length() > 0 && columns[0].charAt(0) != '@') { - - result = createEntry(columns); - - } else { - result = Optional.empty(); - } - } catch (final Exception e) { - LOGGER.error("Failed to create entry from line: {}", line, e); - result = Optional.empty(); - } - return result; - } - - private Optional createEntry(final String[] columns) { - - long epochMilli = 0; - long duration = Long.MIN_VALUE; - final TagsBuilder tagsBuilder = TagsBuilder.create(); - for (int i = 0; i < columns.length; i++) { - - switch (headers[i]) { - case "@timestamp": - epochMilli = fastISODateParser.parseAsEpochMilli(columns[i]); - break; - case "duration": - duration = Long.parseLong(columns[i]); - break; - default: - if (!StringUtils.isBlank(columns[i])) { - final int key = Tags.STRING_COMPRESSOR.put(headers[i]); - final int value = Tags.STRING_COMPRESSOR.put(columns[i]); - tagsBuilder.add(key, value); - } - break; - } - - } - final Tags tags = tagsBuilder.build(); - - final Entry entry = new Entry(epochMilli, duration, tags); - return Optional.of(entry); - } -}