Interface | Description |
---|---|
MemoryManager |
Implementations of this interface can be used to get updates about remaining heap memory.
|
MemoryManagerClient |
Client interface for
MemoryManager . |
NodeStateHolder | |
SortStrategy |
Class | Description |
---|---|
DefaultMemoryManager | |
FlatFileNodeStoreBuilder | |
FlatFileStore | |
MergeRunner |
Class responsible for -
Watching
MergeRunner.sortedFiles for new sorted files
Submitting those files in batch to an ExecutorService
Collecting the results (sorted files) created by those tasks
Merge the result with any left over files to create a single sorted file
Strategy -
Wait for n files
construct new list of files to be merged by checking if its already merged
and create intermediate merge file
(if final merge) merge all intermediate merge files and create sorted file
add all merged files to merged list
|
MultithreadedTraverseWithSortStrategy |
This class implements a sort strategy where node store is concurrently traversed for downloading node states by
multiple threads (number of threads is configurable via java system property
FlatFileNodeStoreBuilder.PROP_THREAD_POOL_SIZE
and sorted node states are written to files while concurrently being merged by multiple threads (number of threads is
configurable via java system property FlatFileNodeStoreBuilder.PROP_MERGE_THREAD_POOL_SIZE . |
NodeStateEntryReader | |
NodeStateEntrySorter | |
NodeStateEntryWriter | |
PathElementComparator |
Enum | Description |
---|---|
FlatFileNodeStoreBuilder.SortStrategyType | |
MemoryManager.Type |
Indicates type of memory management this instance does.
|
Copyright © 2012–2022 The Apache Software Foundation. All rights reserved.