| /dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/src/core/include/ |
| H A D | _ConcurrentMergeScheduler.h | 14 class LPPAPI MergeThread : public LuceneThread {
16 …MergeThread(const ConcurrentMergeSchedulerPtr& merger, const IndexWriterPtr& writer, const OneMerg…
17 virtual ~MergeThread();
19 LUCENE_CLASS(MergeThread);
|
| /dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/src/core/index/ |
| H A D | ConcurrentMergeScheduler.cpp | 174 MergeThreadPtr thread(newLucene<MergeThread>(shared_from_this(), writer, merge)); in getMergeThread()
233 MergeThread::MergeThread(const ConcurrentMergeSchedulerPtr& merger, const IndexWriterPtr& writer, c… in MergeThread() function in Lucene::MergeThread
239 MergeThread::~MergeThread() { in ~MergeThread()
242 void MergeThread::setRunningMerge(const OneMergePtr& merge) { in setRunningMerge()
248 OneMergePtr MergeThread::getRunningMerge() { in getRunningMerge()
254 void MergeThread::setThreadPriority(int32_t pri) { in setThreadPriority()
261 void MergeThread::run() { in run()
|
| /dports/lang/mono/mono-5.10.1.57/external/api-doc-tools/external/Lucene.Net.Light/src/core/Index/ |
| H A D | ConcurrentMergeScheduler.cs | 40 protected internal IList<MergeThread> mergeThreads = new List<MergeThread>();
104 MergeThread merge = mergeThreads[i]; in SetMergeThreadPriority()
248 MergeThread merger = GetMergeThread(writer, merge); in Merge()
274 …protected internal virtual MergeThread GetMergeThread(IndexWriter writer, MergePolicy.OneMerge mer… in GetMergeThread()
278 var thread = new MergeThread(this, writer, merge); in GetMergeThread()
286 public /*protected internal*/ class MergeThread:ThreadClass class in Lucene.Net.Index.ConcurrentMergeScheduler
306 …public MergeThread(ConcurrentMergeScheduler enclosingInstance, IndexWriter writer, MergePolicy.One… in MergeThread() method in Lucene.Net.Index.ConcurrentMergeScheduler.MergeThread
|
| /dports/biology/bbmap/bbmap/current/var2/ |
| H A D | MergeSamples.java | 186 ArrayList<MergeThread> alpt=spawnThreads(bswVcf); in mergeMT()
372 private ArrayList<MergeThread> spawnThreads(ByteStreamWriter bsw){ in spawnThreads()
377 ArrayList<MergeThread> alpt=new ArrayList<MergeThread>(threads); in spawnThreads()
379 alpt.add(new MergeThread(bsw)); in spawnThreads()
384 for(MergeThread pt : alpt){ in spawnThreads()
393 private void waitForFinish(ArrayList<MergeThread> alpt){ in waitForFinish()
396 for(MergeThread pt : alpt){ in waitForFinish()
409 private class MergeThread extends Thread { class in MergeSamples
411 MergeThread(ByteStreamWriter bsw_){ in MergeThread() method in MergeSamples.MergeThread
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/ |
| H A D | MergeThread.java | 31 abstract class MergeThread<T,K,V> extends Thread { class
33 private static final Log LOG = LogFactory.getLog(MergeThread.class);
42 public MergeThread(MergeManagerImpl<K,V> manager, int mergeFactor, in MergeThread() method in MergeThread
|
| H A D | MergeManagerImpl.java | 92 private final MergeThread<InMemoryMapOutput<K,V>, K,V> inMemoryMerger;
230 protected MergeThread<InMemoryMapOutput<K,V>, K,V> createInMemoryMerger() { in createInMemoryMerger()
234 protected MergeThread<CompressAwarePath,K,V> createOnDiskMerger() { in createOnDiskMerger()
375 extends MergeThread<InMemoryMapOutput<K, V>, K, V> {
426 private class InMemoryMerger extends MergeThread<InMemoryMapOutput<K,V>, K,V> {
510 private class OnDiskMerger extends MergeThread<CompressAwarePath,K,V> {
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/ |
| H A D | TestMergeManager.java | 144 protected MergeThread<InMemoryMapOutput<Text, Text>, Text, Text> createInMemoryMerger() { in createInMemoryMerger()
155 extends MergeThread<InMemoryMapOutput<Text,Text>, Text, Text> {
223 MergeThread<MapOutput<IntWritable, IntWritable>, IntWritable, IntWritable> in testOnDiskMerger()
224 onDiskMerger = (MergeThread<MapOutput<IntWritable, IntWritable>, in testOnDiskMerger()
|
| H A D | TestMerger.java | 129 MergeThread<InMemoryMapOutput<Text, Text>, Text, Text> inMemoryMerger = in testInMemoryAndOnDiskMerger()
164 MergeThread<InMemoryMapOutput<Text, Text>, Text, Text> inMemoryMerger2 = in testInMemoryAndOnDiskMerger()
192 MergeThread<CompressAwarePath,Text,Text> onDiskMerger = mergeManager.createOnDiskMerger(); in testInMemoryAndOnDiskMerger()
|
| /dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/include/lucene++/ |
| H A D | ConcurrentMergeScheduler.h | 95 friend class MergeThread; variable
|
| H A D | LuceneTypes.h | 177 DECLARE_SHARED_PTR(MergeThread)
|
| /dports/textproc/luceneplusplus/LucenePlusPlus-rel_3.0.8/src/test/index/ |
| H A D | ConcurrentMergeSchedulerTest.cpp | 287 class MyMergeThread : public MergeThread {
289 …merger, const IndexWriterPtr& writer, const OneMergePtr& startMerge) : MergeThread(merger, writer,… in MyMergeThread()
|
| /dports/lang/mono/mono-5.10.1.57/external/api-snapshot/profiles/net_4_x/ |
| H A D | monodoc.cs | 999 …stem.Collections.Generic.IList<Lucene.Net.Index.ConcurrentMergeScheduler.MergeThread> mergeThreads;
1008 …protected internal virtual Lucene.Net.Index.ConcurrentMergeScheduler.MergeThread GetMergeThread(Lu… in GetMergeThread()
1016 public partial class MergeThread : Lucene.Net.Support.ThreadClass class in Lucene.Net.Index.ConcurrentMergeScheduler
1018 …public MergeThread(Lucene.Net.Index.ConcurrentMergeScheduler enclosingInstance, Lucene.Net.Index.I… in MergeThread() method in Lucene.Net.Index.ConcurrentMergeScheduler.MergeThread
|