Package org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined
package org.apache.jackrabbit.oak.index.indexer.document.flatfile.pipelined
-
ClassDescriptionA histogram that keeps a maximum number of buckets (entries).Aggregates statistics when downloading from Mongo with two threadsImplements a filter to decide if a given Mongo document should be processed or ignored based on its path.Custom codec to create NodeDocument from a stream of BSON data received from MongoDB.Accumulates the intermediate sorted files and, when all files are generated, merges them into a single sorted file, the flat file storeSelects a Mongo server that is available for a new connection.Downloads the contents of the MongoDB repository dividing the tasks in a pipeline with the following stages: Download - Downloads from Mongo all the documents in the node store.Downloads the contents of the MongoDB repository dividing the tasks in a pipeline with the following stages: Download - Downloads from Mongo all the documents in the node store.Receives batches of node state entries, sorts then in memory, and finally writes them to a tree store.Keeps track of a list of threads and prints statistics of CPU usage of the threads.Thread factory that registers all new threads with a given thread monitor.