@Test public void close() throws Exception { ByteBuffer buf = BufferUtils.getIncreasingByteBuffer(TEST_BLOCK_SIZE); Assert.assertEquals(TEST_BLOCK_SIZE, mWriter.append(buf)); mWriter.close(); mThrown.expect(IOException.class); mWriter.append(buf); }
@Override public void close() throws IOException { if (mClosed) { return; } mClosed = true; super.close(); mCloser.close(); mPosition = -1; }
LocalFileBlockWriter extends BlockWriter { @Override public void close() throws IOException { if (mClosed) { return; } mClosed = true; super.close(); mCloser.close(); mPosition = -1; } }
LocalFileBlockWriter extends BlockWriter { @Override public void close() throws IOException { if (mClosed) { return; } mClosed = true; super.close(); mCloser.close(); mPosition = -1; } LocalFileBlockWriter(String path); }
LocalFileBlockWriter extends BlockWriter { @Override public void close() throws IOException { if (mClosed) { return; } mClosed = true; super.close(); mCloser.close(); mPosition = -1; } LocalFileBlockWriter(String path); @Override long append(ByteBuffer inputBuf); @Override long append(ByteBuf buf); @Override long append(DataBuffer buffer); @Override long getPosition(); @Override WritableByteChannel getChannel(); @Override void close(); }
LocalFileBlockWriter extends BlockWriter { @Override public void close() throws IOException { if (mClosed) { return; } mClosed = true; super.close(); mCloser.close(); mPosition = -1; } LocalFileBlockWriter(String path); @Override long append(ByteBuffer inputBuf); @Override long append(ByteBuf buf); @Override long append(DataBuffer buffer); @Override long getPosition(); @Override WritableByteChannel getChannel(); @Override void close();  }