@Test(expectedExceptions = RuntimeException.class) public void testWriteExisting() throws Exception { try (SingleFileIndexDirectory columnDirectory = new SingleFileIndexDirectory(TEMP_DIR, segmentMetadata, ReadMode.mmap)) { columnDirectory.newBuffer("column1", ColumnIndexType.DICTIONARY, 1024); } try (SingleFileIndexDirectory columnDirectory = new SingleFileIndexDirectory(TEMP_DIR, segmentMetadata, ReadMode.mmap)) { columnDirectory.newBuffer("column1", ColumnIndexType.DICTIONARY, 1024); } }
@Override public PinotDataBuffer newBuffer(String column, ColumnIndexType type, long sizeBytes) throws IOException { return allocNewBufferInternal(column, type, sizeBytes, type.name().toLowerCase() + ".create"); }
SingleFileIndexDirectory extends ColumnIndexDirectory { @Override public PinotDataBuffer newBuffer(String column, ColumnIndexType type, long sizeBytes) throws IOException { return allocNewBufferInternal(column, type, sizeBytes, type.name().toLowerCase() + ".create"); } }
SingleFileIndexDirectory extends ColumnIndexDirectory { @Override public PinotDataBuffer newBuffer(String column, ColumnIndexType type, long sizeBytes) throws IOException { return allocNewBufferInternal(column, type, sizeBytes, type.name().toLowerCase() + ".create"); } SingleFileIndexDirectory(File segmentDirectory, SegmentMetadataImpl metadata, ReadMode readMode); }
SingleFileIndexDirectory extends ColumnIndexDirectory { @Override public PinotDataBuffer newBuffer(String column, ColumnIndexType type, long sizeBytes) throws IOException { return allocNewBufferInternal(column, type, sizeBytes, type.name().toLowerCase() + ".create"); } SingleFileIndexDirectory(File segmentDirectory, SegmentMetadataImpl metadata, ReadMode readMode); @Override PinotDataBuffer getBuffer(String column, ColumnIndexType type); @Override PinotDataBuffer newBuffer(String column, ColumnIndexType type, long sizeBytes); @Override boolean hasIndexFor(String column, ColumnIndexType type); @Override void close(); @Override void removeIndex(String columnName, ColumnIndexType indexType); @Override boolean isIndexRemovalSupported(); @Override String toString(); }
SingleFileIndexDirectory extends ColumnIndexDirectory { @Override public PinotDataBuffer newBuffer(String column, ColumnIndexType type, long sizeBytes) throws IOException { return allocNewBufferInternal(column, type, sizeBytes, type.name().toLowerCase() + ".create"); } SingleFileIndexDirectory(File segmentDirectory, SegmentMetadataImpl metadata, ReadMode readMode); @Override PinotDataBuffer getBuffer(String column, ColumnIndexType type); @Override PinotDataBuffer newBuffer(String column, ColumnIndexType type, long sizeBytes); @Override boolean hasIndexFor(String column, ColumnIndexType type); @Override void close(); @Override void removeIndex(String columnName, ColumnIndexType indexType); @Override boolean isIndexRemovalSupported(); @Override String toString();  }