cleanup

data-store/src/main/java/org/lucares/pdb/datastore/lang/QueryLanguage.java

@@ -70,16 +70,6 @@ public class QueryLanguage {
 
 				stack.push(new Terminal(ctx.getText(), line, startIndex, stopIndex));
 			}
-// TODO remove
-//			@Override
-//			public void exitPropertyExpression(final PropertyExpressionContext ctx) {
-//				// System.out.println("property expression");
-//
-//				final Expression value = stack.pop();
-//				final Terminal property = (Terminal) stack.pop();
-//
-//				stack.push(new Property(property.getValue(), (Terminal) value));
-//			}
 
 			@Override
 			public void exitNotExpression(final NotExpressionContext ctx) {

pdb-plotting/src/main/java/org/lucares/recommind/logs/ScatterPlot.java

@@ -99,7 +99,7 @@ public class ScatterPlot {
 						dataSeries.add(dataSerie);
 					}
 				} catch (final Exception e) {
-					throw new IllegalStateException(e); // TODO handle
+					throw new IllegalStateException(e);
 				}
 			});
 			METRICS_LOGGER.debug("csv generation took: " + (System.nanoTime() - start) / 1_000_000.0 + "ms");

performanceDb/src/main/java/org/lucares/performance/db/FileCorruptException.java

@@ -1,10 +0,0 @@
-package org.lucares.performance.db;
-
-public class FileCorruptException extends RuntimeException {
-
-	private static final long serialVersionUID = -4194021585305770924L;
-
-	public FileCorruptException(final String message) {
-		super(message);
-	}
-}

performanceDb/src/main/java/org/lucares/performance/db/PdbWriter.java

@@ -2,7 +2,6 @@ package org.lucares.performance.db;
 
 import java.io.Flushable;
 import java.io.IOException;
-import java.time.OffsetDateTime;
 import java.util.Optional;
 
 import org.lucares.pdb.api.Entry;
@@ -36,10 +35,6 @@ class PdbWriter implements AutoCloseable, Flushable {
 		return pdbFile;
 	}
 
-	public OffsetDateTime getDateOffset() {
-		return DateUtils.epochMilliInUTC(lastEpochMilli);
-	}
-
 	public long getDateOffsetAsEpochMilli() {
 		return lastEpochMilli;
 	}

performanceDb/src/main/java/org/lucares/performance/db/PerformanceDb.java

@@ -9,7 +9,6 @@ import java.util.Iterator;
 import java.util.List;
 import java.util.Optional;
 import java.util.SortedSet;
-import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 import java.util.stream.Stream;
@@ -48,11 +47,6 @@ public class PerformanceDb implements AutoCloseable {
 		put(entries.iterator());
 	}
 
-	public void put(final BlockingQueue<Entry> entries, final Entry poisonObject) throws WriteException {
-		final BlockingQueueIterator<Entry> iterator = new BlockingQueueIterator<>(entries, poisonObject);
-		put(iterator);
-	}
-
 	public void put(final Iterator<Entry> entries) throws WriteException {
 
 		final BlockingIteratorIterator<Entry> iterator = new BlockingIteratorIterator<>(entries);