@Test public void createOutput() throws Exception { Directory buffered = createDir(builder, true); byte[] data = writeFile(buffered, "file"); Directory base = createDir(builder, false); assertFalse(base.fileExists("file")); base.close(); buffered.close(); base = createDir(builder, false); assertFile(base, "file", data); base.close(); }
@Override public IndexOutput createOutput(String name, IOContext context) throws IOException { LOG.debug("[{}]createOutput({})", definition.getIndexPath(), name); bufferedForDelete.remove(name); return buffered.createOutput(name, context); }
BufferedOakDirectory extends Directory { @Override public IndexOutput createOutput(String name, IOContext context) throws IOException { LOG.debug("[{}]createOutput({})", definition.getIndexPath(), name); bufferedForDelete.remove(name); return buffered.createOutput(name, context); } }
BufferedOakDirectory extends Directory { @Override public IndexOutput createOutput(String name, IOContext context) throws IOException { LOG.debug("[{}]createOutput({})", definition.getIndexPath(), name); bufferedForDelete.remove(name); return buffered.createOutput(name, context); } BufferedOakDirectory(@NotNull NodeBuilder builder,
                                @NotNull String dataNodeName,
                                @NotNull LuceneIndexDefinition definition,
                                @Nullable BlobStore blobStore);  BufferedOakDirectory(@NotNull NodeBuilder builder,
                                @NotNull String dataNodeName,
                                @NotNull LuceneIndexDefinition definition,
                                @Nullable BlobStore blobStore,
                                @NotNull ActiveDeletedBlobCollectorFactory.BlobDeletionCallback blobDeletionCallback); }
BufferedOakDirectory extends Directory { @Override public IndexOutput createOutput(String name, IOContext context) throws IOException { LOG.debug("[{}]createOutput({})", definition.getIndexPath(), name); bufferedForDelete.remove(name); return buffered.createOutput(name, context); } BufferedOakDirectory(@NotNull NodeBuilder builder,
                                @NotNull String dataNodeName,
                                @NotNull LuceneIndexDefinition definition,
                                @Nullable BlobStore blobStore);  BufferedOakDirectory(@NotNull NodeBuilder builder,
                                @NotNull String dataNodeName,
                                @NotNull LuceneIndexDefinition definition,
                                @Nullable BlobStore blobStore,
                                @NotNull ActiveDeletedBlobCollectorFactory.BlobDeletionCallback blobDeletionCallback); static void setEnableWritingSingleBlobIndexFile(boolean val); static boolean isEnableWritingSingleBlobIndexFile(); @Override String[] listAll(); @Override boolean fileExists(String name); @Override void deleteFile(String name); @Override long fileLength(String name); @Override IndexOutput createOutput(String name, IOContext context); @Override void sync(Collection<String> names); @Override IndexInput openInput(String name, IOContext context); @Override Lock makeLock(String name); @Override void clearLock(String name); @Override void close(); @Override void setLockFactory(LockFactory lockFactory); @Override LockFactory getLockFactory(); }
BufferedOakDirectory extends Directory { @Override public IndexOutput createOutput(String name, IOContext context) throws IOException { LOG.debug("[{}]createOutput({})", definition.getIndexPath(), name); bufferedForDelete.remove(name); return buffered.createOutput(name, context); } BufferedOakDirectory(@NotNull NodeBuilder builder,
                                @NotNull String dataNodeName,
                                @NotNull LuceneIndexDefinition definition,
                                @Nullable BlobStore blobStore);  BufferedOakDirectory(@NotNull NodeBuilder builder,
                                @NotNull String dataNodeName,
                                @NotNull LuceneIndexDefinition definition,
                                @Nullable BlobStore blobStore,
                                @NotNull ActiveDeletedBlobCollectorFactory.BlobDeletionCallback blobDeletionCallback); static void setEnableWritingSingleBlobIndexFile(boolean val); static boolean isEnableWritingSingleBlobIndexFile(); @Override String[] listAll(); @Override boolean fileExists(String name); @Override void deleteFile(String name); @Override long fileLength(String name); @Override IndexOutput createOutput(String name, IOContext context); @Override void sync(Collection<String> names); @Override IndexInput openInput(String name, IOContext context); @Override Lock makeLock(String name); @Override void clearLock(String name); @Override void close(); @Override void setLockFactory(LockFactory lockFactory); @Override LockFactory getLockFactory(); static final String ENABLE_WRITING_SINGLE_BLOB_INDEX_FILE_PARAM; }