Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
DefaultBlockMaster.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<Journal.JournalEntry> |
InodeTreeBufferedIterator.create(InodeStore inodeStore,
InodeDirectory rootInode)
Creates buffered iterator with closeable interface.
|
CloseableIterator<Journal.JournalEntry> |
InodeDirectoryIdGenerator.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
InodeTreePersistentState.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
MountTable.State.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
JournaledGroup.getJournalEntryIterator() |
default CloseableIterator<Journal.JournalEntry> |
DelegatingJournaled.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
SingleEntryJournaled.getJournalEntryIterator() |
default CloseableIterator<Journal.JournalEntry> |
NoopJournaled.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
JournalEntryIterable.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
PathProperties.State.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
DefaultMetaMaster.getJournalEntryIterator() |
CloseableIterator<Journal.JournalEntry> |
DefaultMetaMaster.State.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Long> |
DelegatingReadOnlyInodeStore.getChildIds(InodeDirectoryView inode,
ReadOption option) |
default CloseableIterator<Long> |
ReadOnlyInodeStore.getChildIds(InodeDirectoryView inode,
ReadOption option)
Returns an iterable for the ids of the children of the given directory.
|
default CloseableIterator<Long> |
ReadOnlyInodeStore.getChildIds(Long inodeId) |
CloseableIterator<Long> |
DelegatingReadOnlyInodeStore.getChildIds(Long inodeId,
ReadOption option) |
CloseableIterator<Long> |
ReadOnlyInodeStore.getChildIds(Long inodeId,
ReadOption option)
Returns an iterable for the ids of the children of the given directory.
|
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildren(InodeDirectoryView inode) |
CloseableIterator<? extends Inode> |
DelegatingReadOnlyInodeStore.getChildren(InodeDirectoryView inode,
ReadOption option) |
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildren(InodeDirectoryView inode,
ReadOption option) |
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildren(Long inodeId) |
CloseableIterator<? extends Inode> |
DelegatingReadOnlyInodeStore.getChildren(Long inodeId,
ReadOption option) |
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildren(Long inodeId,
ReadOption option)
Returns an iterator over the children of the specified inode.
|
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildrenFrom(long parentId,
String fromName)
Returns a closeable stream of the inodes sorted by filename of the children of the given
directory that come after and including fromName.
|
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildrenPrefix(long parentId,
String prefix)
Returns a closeable stream of the inodes sorted by filename of the children of the given
directory that come after and including fromName.
|
default CloseableIterator<? extends Inode> |
ReadOnlyInodeStore.getChildrenPrefixFrom(long parentId,
String prefix,
String fromName)
Returns a closeable stream of the inodes sorted by filename of the children of the given
directory that come after and including fromName, and matching the prefix.
|
CloseableIterator<BlockMetaStore.Block> |
BlockMetaStore.getCloseableIterator()
Gets a
CloseableIterator over the blocks. |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Long> |
CachingInodeStore.getChildIds(Long inodeId,
ReadOption option) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Long> |
HeapInodeStore.getChildIds(Long inodeId,
ReadOption option) |
CloseableIterator<? extends Inode> |
HeapInodeStore.getChildren(Long inodeId,
ReadOption option) |
CloseableIterator<BlockMetaStore.Block> |
HeapBlockMetaStore.getCloseableIterator() |
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
RocksUtils.createCloseableIterator(org.rocksdb.RocksIterator rocksIterator,
RocksUtils.RocksIteratorParser<T> parser,
java.util.function.Supplier<Void> abortCheck,
RocksSharedLockHandle rocksDbSharedLock)
Used to wrap an
CloseableIterator over RocksIterator . |
CloseableIterator<Long> |
RocksInodeStore.getChildIds(Long inodeId,
ReadOption option) |
CloseableIterator<InodeView> |
RocksInodeStore.getCloseableIterator()
Acquires an iterator to iterate all Inodes in RocksDB.
|
CloseableIterator<BlockMetaStore.Block> |
RocksBlockMetaStore.getCloseableIterator() |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
JournaledJobMetaStore.getJournalEntryIterator() |
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
CloseableIterator.concat(CloseableIterator<T> a,
CloseableIterator<T> b)
Combines two iterators into a single iterator.
|
static <T> CloseableIterator<T> |
CloseableIterator.concat(List<CloseableIterator<T>> iterators)
Concatenates iterators.
|
static <T> CloseableIterator<T> |
CloseableIterator.create(Iterator<? extends T> iterator,
java.util.function.Consumer<Void> closeAction)
Wrap around an iterator with a resource to close.
|
static <T> CloseableIterator<T> |
CloseableIterator.noopCloseable(Iterator<? extends T> iterator)
Wraps around an iterator with no resource to close.
|
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
CloseableIterator.concat(CloseableIterator<T> a,
CloseableIterator<T> b)
Combines two iterators into a single iterator.
|
static <T> CloseableIterator<T> |
CloseableIterator.concat(CloseableIterator<T> a,
CloseableIterator<T> b)
Combines two iterators into a single iterator.
|
static int |
CloseableIterator.size(CloseableIterator<?> iter)
Consumes the iterator, closes it, and returns its size.
|
Modifier and Type | Method and Description |
---|---|
static <T> CloseableIterator<T> |
CloseableIterator.concat(List<CloseableIterator<T>> iterators)
Concatenates iterators.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<Journal.JournalEntry> |
MasterUfsManager.getJournalEntryIterator() |
Copyright © 2023. All Rights Reserved.