net.eduvax.util

Class SortedStreamMerger

java.lang.Object

net.eduvax.util.SortedStreamMerger

All Implemented Interfaces:

java.lang.Runnable

public class SortedStreamMerger
extends java.lang.Object
implements java.lang.Runnable

Fusion de streams ordonnés tout en préservant l'ordre dans le résultat.

Peut être utilisé pour l'étape finale de fusion d'un tri externe (cf littérature à propos des "external sort algorithms")

Attention, ceci ne fonctionne évidemment que si les entrées à fusionner sont déjà triées selon le même critère de tri que celui qui sera appliqué pendant la fusion.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	SortedStreamMerger.DefaultLineBufferComparator Comparateur de ligne par defaut.

Field Summary

Fields

Modifier and Type	Field and Description
private ErrorHandler	_errHandler
private java.util.Vector<LineReaderBuffer>	_inputs Chemins fichiers d'entrée.
private java.io.PrintStream	_output Chemin fichier de sortie.

Constructor Summary

Constructors

Constructor and Description
SortedStreamMerger() Créer nouveau fusionneur

Method Summary

Methods

Modifier and Type	Method and Description
void	addFile(java.lang.String path) Ajouter un fichier d'entrée à fusionner.
void	addStream(java.io.InputStream str) Ajouter un stream d'entrée à fusionner
void	run() Mise en oeuvre Runnable.
void	setOutputPath(java.lang.String path) Définir le fichier de sortie.
void	setOutputStream(java.io.OutputStream s) Définir le flux de sortie.

Methods inherited from class java.lang.Object

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

Field Detail

_errHandler

private ErrorHandler _errHandler

_output

private java.io.PrintStream _output

Chemin fichier de sortie.

_inputs

private java.util.Vector<LineReaderBuffer> _inputs

Chemins fichiers d'entrée.

Constructor Detail

SortedStreamMerger

public SortedStreamMerger()

Créer nouveau fusionneur

Method Detail

addStream

public void addStream(java.io.InputStream str)

Ajouter un stream d'entrée à fusionner

Parameters:

str - Stream à ajouter

addFile

public void addFile(java.lang.String path)

Ajouter un fichier d'entrée à fusionner.

Parameters:

path - Chemin du fichier à ajouter.

setOutputStream

public void setOutputStream(java.io.OutputStream s)

Définir le flux de sortie.

Parameters:

s - flux destination de la fusion.

setOutputPath

public void setOutputPath(java.lang.String path)

Définir le fichier de sortie.

Parameters:

path - Chemin du fichier cible.

run

public void run()

Mise en oeuvre Runnable.

Specified by:

run in interface java.lang.Runnable