arnaudroger

import org.simpleflatmapper.csv.CsvMapper;
import org.simpleflatmapper.csv.CsvMapperFactory;
import org.simpleflatmapper.csv.CsvParser;
import org.simpleflatmapper.lightningcsv.CsvReader;

import java.io.IOException;

public class SampleReadingOneLine {

    private static final CsvMapper<MyObject> mapper =

arnaudroger

  0x00007fe6ecc85730: mov    (%r10),%r11d       ;*invokestatic access$100 {reexecute=0 rethrow=0 return_oop=0}
                                                ; - com.rapid7.odin.netty.NettyMessageConsumer$ScheduleProcess::run@4 (line 236)
                                                ; - com.rapid7.odin.netty.util.WriteTaskScheduler$WriteTask::run@11 (line 102)
                                                ; - io.netty.util.concurrent.AbstractEventExecutor::safeExecute@1 (line 163)
                                                ; - io.netty.util.concurrent.SingleThreadEventExecutor::runAllTasks@31 (line 404)

  0x00007fe6ecc85733: test   %r11d,%r11d
  0x00007fe6ecc85736: je     0x00007fe6ecc85730

arnaudroger

# {method} {0x00000001282303f8} 'poll' '()Ljava/lang/Object;' in 'org/jctools/queues/BaseMpscLinkedArrayQueue'
#           [sp+0x70]  (sp of caller)
[Entry Point]
0x00000001186d03e0: mov 0x8(%rsi),%r10d
0x00000001186d03e4: movabs $0x800000000,%r12
0x00000001186d03ee: add %r12,%r10
0x00000001186d03f1: xor %r12,%r12
0x00000001186d03f4: cmp %r10,%rax
0x00000001186d03f7: jne 0x0000000110c24c80  ;   {runtime_call ic_miss_stub}
0x00000001186d03fd: data16 xchg %ax,%ax

arnaudroger

# {method} {0x00000001206a6320} 'poll' '()Ljava/lang/Object;' in 'org/jctools/queues/BaseMpscLinkedArrayQueue'
#           [sp+0x30]  (sp of caller)
[Entry Point]
0x0000000108427ee0: mov 0x8(%rsi),%r10d
0x0000000108427ee4: shl $0x3,%r10
0x0000000108427ee8: cmp %r10,%rax
0x0000000108427eeb: jne 0x00000001082e6ba0  ;   {runtime_call}
0x0000000108427ef1: data16 xchg %ax,%ax
0x0000000108427ef4: nopl 0x0(%rax,%rax,1)
0x0000000108427efc: data16 data16 xchg %ax,%ax

arnaudroger

import org.jctools.queues.MpscUnboundedArrayQueue;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.LockSupport;

public class Main {

    public static final long HEALTH_INT = TimeUnit.SECONDS.toNanos(1);

arnaudroger

import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.core.JsonGenerator;
import org.simpleflatmapper.csv.CsvParser;
import org.simpleflatmapper.csv.CsvReader;
import org.simpleflatmapper.csv.parser.CellConsumer;
import org.simpleflatmapper.util.ErrorHelper;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;

arnaudroger

import com.fasterxml.jackson.core.JsonFactory;
import com.fasterxml.jackson.core.JsonGenerator;
import org.simpleflatmapper.csv.CsvParser;
import org.simpleflatmapper.csv.CsvReader;

import java.io.IOException;
import java.util.Iterator;

// uses http://simpleflatmapper.org/0101-getting-started-csv.html for csv parser
// and jackson-core for JsonGenerator