| | |
| | | this.importStrategy = importStrategy; |
| | | } |
| | | |
| | | public void doImport(final Source source) throws Exception |
| | | private void doImport(final Source source) throws Exception |
| | | { |
| | | final long phaseOneStartTime = System.currentTimeMillis(); |
| | | final PhaseOneWriteableTransaction transaction = new PhaseOneWriteableTransaction(importStrategy); |
| | |
| | | private final long startOffset; |
| | | private long size; |
| | | private MappedByteBuffer mmapBuffer; |
| | | private OutputStream mmapBufferOS = new OutputStream() |
| | | private final OutputStream mmapBufferOS = new OutputStream() |
| | | { |
| | | @Override |
| | | public void write(int arg0) throws IOException |
| | |
| | | } |
| | | } |
| | | |
| | | static boolean supportOffHeap() |
| | | private static boolean supportOffHeap() |
| | | { |
| | | return unsafe != null; |
| | | } |
| | |
| | | return bufferSize; |
| | | } |
| | | |
| | | public Buffer get() |
| | | private Buffer get() |
| | | { |
| | | try |
| | | { |