org.das2.stream.test
Class LocalFileStandardDataStreamSource

java.lang.Object
  extended by org.das2.stream.test.LocalFileStandardDataStreamSource
All Implemented Interfaces:
StandardDataStreamSource

public class LocalFileStandardDataStreamSource
extends java.lang.Object
implements StandardDataStreamSource


Constructor Summary
LocalFileStandardDataStreamSource(java.io.File file)
          Creates a new instance of LocalFileStandardDataStreamSource
 
Method Summary
 java.io.InputStream getInputStream(StreamDataSetDescriptor dsd, Datum start, Datum end)
           
 java.io.InputStream getReducedInputStream(StreamDataSetDescriptor dsd, Datum start, Datum end, Datum timeResolution)
           
static DataSetDescriptor newDataSetDescriptor(java.util.Map map)
           
 void reset()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

LocalFileStandardDataStreamSource

public LocalFileStandardDataStreamSource(java.io.File file)
Creates a new instance of LocalFileStandardDataStreamSource

Method Detail

getInputStream

public java.io.InputStream getInputStream(StreamDataSetDescriptor dsd,
                                          Datum start,
                                          Datum end)
                                   throws DasException
Specified by:
getInputStream in interface StandardDataStreamSource
Throws:
DasException

getReducedInputStream

public java.io.InputStream getReducedInputStream(StreamDataSetDescriptor dsd,
                                                 Datum start,
                                                 Datum end,
                                                 Datum timeResolution)
                                          throws DasException
Specified by:
getReducedInputStream in interface StandardDataStreamSource
Throws:
DasException

reset

public void reset()
Specified by:
reset in interface StandardDataStreamSource

newDataSetDescriptor

public static DataSetDescriptor newDataSetDescriptor(java.util.Map map)
                                              throws DataSetDescriptorNotAvailableException
Throws:
DataSetDescriptorNotAvailableException