public class IOTiming
extends java.lang.Object
RecordReader
, InputStreamInputSplit
(note that this uses input stream input split,
the record reader must support InputStreamInputSplit
for this to work)Modifier and Type | Class and Description |
---|---|
static interface |
IOTiming.INDArrayCreationFunction |
Constructor and Description |
---|
IOTiming() |
Modifier and Type | Method and Description |
---|---|
static TimingStatistics |
averageFileRead(long nTimes,
RecordReader recordReader,
java.io.File file,
IOTiming.INDArrayCreationFunction function)
Returns statistics for components of a datavec pipeline
averaged over the specified number of times
|
static TimingStatistics |
timeNDArrayCreation(RecordReader reader,
java.io.InputStream inputStream,
IOTiming.INDArrayCreationFunction function) |
public static TimingStatistics averageFileRead(long nTimes, RecordReader recordReader, java.io.File file, IOTiming.INDArrayCreationFunction function) throws java.lang.Exception
nTimes
- the number of times to run the pipeline for averagingrecordReader
- the record readerfile
- the file to readfunction
- the functionTimingStatistics
for input/output on a record
reader and ndarray creation (based on the given functionjava.lang.Exception
public static TimingStatistics timeNDArrayCreation(RecordReader reader, java.io.InputStream inputStream, IOTiming.INDArrayCreationFunction function) throws java.lang.Exception
reader
- inputStream
- function
- java.lang.Exception