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.Exceptionpublic static TimingStatistics timeNDArrayCreation(RecordReader reader, java.io.InputStream inputStream, IOTiming.INDArrayCreationFunction function) throws java.lang.Exception
reader - inputStream - function - java.lang.Exception