org.expasy.mzjava.hadoop.io

Class HadoopSpectraReader<A extends PeakAnnotation,S extends Spectrum<A>>

java.lang.Object

org.expasy.mzjava.hadoop.io.HadoopSpectraReader<A,S>

All Implemented Interfaces:

IterativeReader<S>

public class HadoopSpectraReader<A extends PeakAnnotation,S extends Spectrum<A>>
extends Object
implements IterativeReader<S>

Version:

1.0

Author:

Oliver Horlacher

Field Summary

Fields inherited from interface org.expasy.mzjava.core.io.IterativeReader

EMPTY_READER

Constructor Summary

Constructors

Constructor and Description
HadoopSpectraReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path, AbstractPeakListValue<S> value)
HadoopSpectraReader(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path, SpectrumKey key, AbstractPeakListValue<S> value)
HadoopSpectraReader(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, AbstractPeakListValue<S> value)
HadoopSpectraReader(String path, String name, AbstractPeakListValue<S> value)
HadoopSpectraReader(String path, String name, SpectrumKey key, AbstractPeakListValue<S> value)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the reader and releases any system resources associated with it.
static org.apache.hadoop.fs.LocalFileSystem	getLocal(org.apache.hadoop.conf.Configuration conf)
boolean	hasNext() Returns true if the reader has more elements.
static HadoopSpectraReader<PeakAnnotation,MsnSpectrum>	msnReader(File file)
S	next() Returns the next element in the reader.

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopSpectraReader

public HadoopSpectraReader(org.apache.hadoop.conf.Configuration conf,
                   org.apache.hadoop.fs.Path path,
                   AbstractPeakListValue<S> value)
                    throws IOException

Throws:

IOException

HadoopSpectraReader

public HadoopSpectraReader(String path,
                   String name,
                   AbstractPeakListValue<S> value)
                    throws IOException

Throws:

IOException

HadoopSpectraReader

public HadoopSpectraReader(String path,
                   String name,
                   SpectrumKey key,
                   AbstractPeakListValue<S> value)
                    throws IOException

Throws:

IOException

HadoopSpectraReader

public HadoopSpectraReader(org.apache.hadoop.fs.FileSystem fs,
                   org.apache.hadoop.fs.Path path,
                   AbstractPeakListValue<S> value)
                    throws IOException

Throws:

IOException

HadoopSpectraReader

public HadoopSpectraReader(org.apache.hadoop.conf.Configuration conf,
                   org.apache.hadoop.fs.Path path,
                   SpectrumKey key,
                   AbstractPeakListValue<S> value)
                    throws IOException

Throws:

IOException

Method Detail

getLocal

public static org.apache.hadoop.fs.LocalFileSystem getLocal(org.apache.hadoop.conf.Configuration conf)
                                                     throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: IterativeReader

Closes the reader and releases any system resources associated with it. Once the reader has been closed, further hasNext() or next() invocations will throw an IOException. Closing a previously closed reader has no effect.

Specified by:

close in interface IterativeReader<S extends Spectrum<A>>

Throws:

IOException - If an I/O error occurs

hasNext

public boolean hasNext()

Description copied from interface: IterativeReader

Returns true if the reader has more elements. (In other words, returns true if IterativeReader.next() would return an element rather than throwing an exception.)

Specified by:

hasNext in interface IterativeReader<S extends Spectrum<A>>

Returns:

true if the reader has more elements

next

public S next()
                           throws IOException

Description copied from interface: IterativeReader

Returns the next element in the reader.

Specified by:

next in interface IterativeReader<S extends Spectrum<A>>

Returns:

the next element in the iteration

Throws:

IOException - if there is an io exception

msnReader

public static HadoopSpectraReader<PeakAnnotation,MsnSpectrum> msnReader(File file)
                                                                 throws IOException

Throws:

IOException