remove debug output
This commit is contained in:
@@ -72,11 +72,11 @@ public class TcpIngestor implements AutoCloseable {
|
||||
System.out.println("reading from stream");
|
||||
while (iterator.hasNext()) {
|
||||
|
||||
final long start = System.nanoTime();
|
||||
// System.out.println("read: " + line);
|
||||
@SuppressWarnings("unchecked")
|
||||
final Map<String, Object> object = (Map<String, Object>) iterator.next();
|
||||
|
||||
final long start = System.nanoTime();
|
||||
final Optional<Entry> entry = createEntry(object);
|
||||
final long end = System.nanoTime();
|
||||
duration += (end - start) / 1_000_000.0;
|
||||
|
||||
Reference in New Issue
Block a user