Package it.unimi.di.law.warc.processors

Class ParallelFilteredProcessorRunner

java.lang.Object

it.unimi.di.law.warc.processors.ParallelFilteredProcessorRunner

public class ParallelFilteredProcessorRunner
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ParallelFilteredProcessorRunner.Processor<T>
static interface	ParallelFilteredProcessorRunner.Writer<T>

Field Summary

Fields

Modifier and Type	Field	Description
protected java.io.IOException	flushingThreadException

Constructor Summary

Constructors

Constructor	Description
ParallelFilteredProcessorRunner(java.io.InputStream in)
ParallelFilteredProcessorRunner(java.io.InputStream in, Filter<WarcRecord> filter)

Method Summary

Modifier and Type	Method	Description
<T> ParallelFilteredProcessorRunner	add(ParallelFilteredProcessorRunner.Processor<T> p, ParallelFilteredProcessorRunner.Writer<? super T> s, java.io.PrintStream out)
static void	main(java.lang.String[] arg)
void	run()
void	run(int numberOfThreads)
void	runSequentially()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

flushingThreadException

protected volatile java.io.IOException flushingThreadException

Constructor Detail

ParallelFilteredProcessorRunner

public ParallelFilteredProcessorRunner(java.io.InputStream in,
                                       Filter<WarcRecord> filter)

ParallelFilteredProcessorRunner

public ParallelFilteredProcessorRunner(java.io.InputStream in)

Method Detail

add

public <T> ParallelFilteredProcessorRunner add(ParallelFilteredProcessorRunner.Processor<T> p,
                                               ParallelFilteredProcessorRunner.Writer<? super T> s,
                                               java.io.PrintStream out)

runSequentially

public void runSequentially()
                     throws WarcFormatException,
                            java.lang.Exception

Throws:

WarcFormatException

java.lang.Exception

run

public void run()
         throws WarcFormatException,
                java.io.IOException,
                java.lang.InterruptedException

Throws:

WarcFormatException

java.io.IOException

java.lang.InterruptedException

run

public void run(int numberOfThreads)
         throws WarcFormatException,
                java.io.IOException,
                java.lang.InterruptedException

Throws:

WarcFormatException

java.io.IOException

java.lang.InterruptedException

main

public static void main(java.lang.String[] arg)
                 throws java.lang.Exception

Throws:

java.lang.Exception