TransformProcessSequenceRecordReader

java.lang.Object
- org.datavec.api.records.reader.impl.transform.TransformProcessSequenceRecordReader

All Implemented Interfaces:

java.io.Closeable, java.io.Serializable, java.lang.AutoCloseable, Configurable, RecordReader, SequenceRecordReader

Direct Known Subclasses:

LocalTransformProcessSequenceRecordReader
```
public class TransformProcessSequenceRecordReader
extends java.lang.Object
implements SequenceRecordReader
```
This wraps a SequenceRecordReader with a TransformProcess which will allow every Record returned from the SequenceRecordReader to be transformed before being returned.

See Also:

Serialized Form

Field Summary

Fields
Modifier and Type Field and Description

protected SequenceRecordReader sequenceRecordReader

protected TransformProcess transformProcess
- Fields inherited from interface org.datavec.api.records.reader.RecordReader
  APPEND_LABEL, LABELS, NAME_SPACE

Fields
Modifier and Type	Field and Description
`protected SequenceRecordReader`	`sequenceRecordReader`
`protected TransformProcess`	`transformProcess`

Constructor Summary

Constructors
Constructor and Description

TransformProcessSequenceRecordReader()

Constructors
Constructor and Description
`TransformProcessSequenceRecordReader()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`boolean`	`batchesSupported()` This method returns true, if next(int) signature is supported by this RecordReader implementation.
`void`	`close()` Closes this stream and releases any system resources associated with it.
`Configuration`	`getConf()` Return the configuration used by this object.
`java.util.List<java.lang.String>`	`getLabels()` List of label strings
`java.util.List<RecordListener>`	`getListeners()` Get the record listeners for this record reader.
`boolean`	`hasNext()` Whether there are anymore records
`void`	`initialize(Configuration conf, InputSplit split)` Called once at initialization.
`void`	`initialize(InputSplit split)` Called once at initialization.
`java.util.List<Record>`	`loadFromMetaData(java.util.List<RecordMetaData> recordMetaDatas)` Load multiple records from the given a list of `RecordMetaData` instances
`Record`	`loadFromMetaData(RecordMetaData recordMetaData)` Load a single record from the given `RecordMetaData` instance Note: that for data that isn't splittable (i.e., text data that needs to be scanned/split), it is more efficient to load multiple records at once using `loadFromMetaData(List)`
`java.util.List<SequenceRecord>`	`loadSequenceFromMetaData(java.util.List<RecordMetaData> recordMetaDatas)` Load multiple sequence records from the given a list of `RecordMetaData` instances
`SequenceRecord`	`loadSequenceFromMetaData(RecordMetaData recordMetaData)` Load a single sequence record from the given `RecordMetaData` instance Note: that for data that isn't splittable (i.e., text data that needs to be scanned/split), it is more efficient to load multiple records at once using `loadSequenceFromMetaData(List)`
`java.util.List<Writable>`	`next()` Get the next record
`java.util.List<java.util.List<Writable>>`	`next(int num)` This method will be used, if batchesSupported() returns true.
`Record`	`nextRecord()` Similar to `next()`, but returns a `Record` object, that may include metadata such as the source of the data
`SequenceRecord`	`nextSequence()` Similar to `sequenceRecord()`, but returns a `Record` object, that may include metadata such as the source of the data
`java.util.List<Writable>`	`record(java.net.URI uri, java.io.DataInputStream dataInputStream)` Load the record from the given DataInputStream Unlike `next()` the internal state of the RecordReader is not modified Implementations of this method should not close the DataInputStream
`void`	`reset()` Reset record reader iterator
`boolean`	`resetSupported()`
`java.util.List<java.util.List<Writable>>`	`sequenceRecord()` Returns a sequence record.
`java.util.List<java.util.List<Writable>>`	`sequenceRecord(java.net.URI uri, java.io.DataInputStream dataInputStream)` Load a sequence record from the given DataInputStream Unlike `next()` the internal state of the RecordReader is not modified Implementations of this method should not close the DataInputStream
`void`	`setConf(Configuration conf)` Set the configuration to be used by this object.
`void`	`setListeners(java.util.Collection<RecordListener> listeners)` Set the record listeners for this record reader.
`void`	`setListeners(RecordListener... listeners)` Set the record listeners for this record reader.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - sequenceRecordReader
```
protected SequenceRecordReader sequenceRecordReader
```
  - transformProcess
```
protected TransformProcess transformProcess
```
- Constructor Detail
  - TransformProcessSequenceRecordReader
```
public TransformProcessSequenceRecordReader()
```
- Method Detail
  - setConf
```
public void setConf(Configuration conf)
```
    Set the configuration to be used by this object.
    
    Specified by:
    
    setConf in interface Configurable
    
    Parameters:
    
    conf -
  - getConf
```
public Configuration getConf()
```
    Return the configuration used by this object.
    
    Specified by:
    
    getConf in interface Configurable
  - sequenceRecord
```
public java.util.List<java.util.List<Writable>> sequenceRecord()
```
    Returns a sequence record.
    
    Specified by:
    
    sequenceRecord in interface SequenceRecordReader
    
    Returns:
    
    a sequence of records
  - batchesSupported
```
public boolean batchesSupported()
```
    Description copied from interface: RecordReader
    
    This method returns true, if next(int) signature is supported by this RecordReader implementation.
    
    Specified by:
    
    batchesSupported in interface RecordReader
    
    Returns:
  - next
```
public java.util.List<java.util.List<Writable>> next(int num)
```
    Description copied from interface: RecordReader
    
    This method will be used, if batchesSupported() returns true.
    
    Specified by:
    
    next in interface RecordReader
    
    Returns:
  - sequenceRecord
```
public java.util.List<java.util.List<Writable>> sequenceRecord(java.net.URI uri,
                                                               java.io.DataInputStream dataInputStream)
                                                        throws java.io.IOException
```
    Load a sequence record from the given DataInputStream Unlike next() the internal state of the RecordReader is not modified Implementations of this method should not close the DataInputStream
    
    Specified by:
    
    sequenceRecord in interface SequenceRecordReader
    
    Parameters:
    
    uri -
    
    dataInputStream -
    
    Throws:
    
    java.io.IOException - if error occurs during reading from the input stream
  - nextSequence
```
public SequenceRecord nextSequence()
```
    Similar to sequenceRecord(), but returns a Record object, that may include metadata such as the source of the data
    
    Specified by:
    
    nextSequence in interface SequenceRecordReader
    
    Returns:
    
    next sequence record
  - loadSequenceFromMetaData
```
public SequenceRecord loadSequenceFromMetaData(RecordMetaData recordMetaData)
                                        throws java.io.IOException
```
    Load a single sequence record from the given RecordMetaData instance
    Note: that for data that isn't splittable (i.e., text data that needs to be scanned/split), it is more efficient to load multiple records at once using loadSequenceFromMetaData(List)
    
    Specified by:
    
    loadSequenceFromMetaData in interface SequenceRecordReader
    
    Parameters:
    
    recordMetaData - Metadata for the sequence record that we want to load from
    
    Returns:
    
    Single sequence record for the given RecordMetaData instance
    
    Throws:
    
    java.io.IOException - If I/O error occurs during loading
  - loadSequenceFromMetaData
```
public java.util.List<SequenceRecord> loadSequenceFromMetaData(java.util.List<RecordMetaData> recordMetaDatas)
                                                        throws java.io.IOException
```
    Load multiple sequence records from the given a list of RecordMetaData instances
    
    Specified by:
    
    loadSequenceFromMetaData in interface SequenceRecordReader
    
    Parameters:
    
    recordMetaDatas - Metadata for the records that we want to load from
    
    Returns:
    
    Multiple sequence record for the given RecordMetaData instances
    
    Throws:
    
    java.io.IOException - If I/O error occurs during loading
  - initialize
```
public void initialize(InputSplit split)
                throws java.io.IOException,
                       java.lang.InterruptedException
```
    Called once at initialization.
    
    Specified by:
    
    initialize in interface RecordReader
    
    Parameters:
    
    split - the split that defines the range of records to read
    
    Throws:
    
    java.io.IOException
    
    java.lang.InterruptedException
  - initialize
```
public void initialize(Configuration conf,
                       InputSplit split)
                throws java.io.IOException,
                       java.lang.InterruptedException
```
    Called once at initialization.
    
    Specified by:
    
    initialize in interface RecordReader
    
    Parameters:
    
    conf - a configuration for initialization
    
    split - the split that defines the range of records to read
    
    Throws:
    
    java.io.IOException
    
    java.lang.InterruptedException
  - next
```
public java.util.List<Writable> next()
```
    Get the next record
    
    Specified by:
    
    next in interface RecordReader
    
    Returns:
  - hasNext
```
public boolean hasNext()
```
    Whether there are anymore records
    
    Specified by:
    
    hasNext in interface RecordReader
    
    Returns:
  - getLabels
```
public java.util.List<java.lang.String> getLabels()
```
    List of label strings
    
    Specified by:
    
    getLabels in interface RecordReader
    
    Returns:
  - reset
```
public void reset()
```
    Reset record reader iterator
    
    Specified by:
    
    reset in interface RecordReader
  - resetSupported
```
public boolean resetSupported()
```
    Specified by:
    
    resetSupported in interface RecordReader
    
    Returns:
    
    True if the record reader can be reset, false otherwise. Note that some record readers cannot be reset - for example, if they are backed by a non-resettable input split (such as certain types of streams)
  - record
```
public java.util.List<Writable> record(java.net.URI uri,
                                       java.io.DataInputStream dataInputStream)
                                throws java.io.IOException
```
    Load the record from the given DataInputStream Unlike next() the internal state of the RecordReader is not modified Implementations of this method should not close the DataInputStream
    
    Specified by:
    
    record in interface RecordReader
    
    Parameters:
    
    uri -
    
    dataInputStream -
    
    Throws:
    
    java.io.IOException - if error occurs during reading from the input stream
  - nextRecord
```
public Record nextRecord()
```
    Similar to next(), but returns a Record object, that may include metadata such as the source of the data
    
    Specified by:
    
    nextRecord in interface RecordReader
    
    Returns:
    
    next record
  - loadFromMetaData
```
public Record loadFromMetaData(RecordMetaData recordMetaData)
                        throws java.io.IOException
```
    Load a single record from the given RecordMetaData instance
    Note: that for data that isn't splittable (i.e., text data that needs to be scanned/split), it is more efficient to load multiple records at once using loadFromMetaData(List)
    
    Specified by:
    
    loadFromMetaData in interface RecordReader
    
    Parameters:
    
    recordMetaData - Metadata for the record that we want to load from
    
    Returns:
    
    Single record for the given RecordMetaData instance
    
    Throws:
    
    java.io.IOException - If I/O error occurs during loading
  - loadFromMetaData
```
public java.util.List<Record> loadFromMetaData(java.util.List<RecordMetaData> recordMetaDatas)
                                        throws java.io.IOException
```
    Load multiple records from the given a list of RecordMetaData instances
    
    Specified by:
    
    loadFromMetaData in interface RecordReader
    
    Parameters:
    
    recordMetaDatas - Metadata for the records that we want to load from
    
    Returns:
    
    Multiple records for the given RecordMetaData instances
    
    Throws:
    
    java.io.IOException - If I/O error occurs during loading
  - getListeners
```
public java.util.List<RecordListener> getListeners()
```
    Get the record listeners for this record reader.
    
    Specified by:
    
    getListeners in interface RecordReader
  - setListeners
```
public void setListeners(RecordListener... listeners)
```
    Set the record listeners for this record reader.
    
    Specified by:
    
    setListeners in interface RecordReader
    
    Parameters:
    
    listeners -
  - setListeners
```
public void setListeners(java.util.Collection<RecordListener> listeners)
```
    Set the record listeners for this record reader.
    
    Specified by:
    
    setListeners in interface RecordReader
    
    Parameters:
    
    listeners -
  - close
```
public void close()
           throws java.io.IOException
```
    Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.
    
    As noted in AutoCloseable.close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.
    
    Specified by:
    
    close in interface java.io.Closeable
    
    Specified by:
    
    close in interface java.lang.AutoCloseable
    
    Throws:
    
    java.io.IOException - if an I/O error occurs

Class TransformProcessSequenceRecordReader

Field Summary

Fields inherited from interface org.datavec.api.records.reader.RecordReader

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

sequenceRecordReader

transformProcess

Constructor Detail

TransformProcessSequenceRecordReader

Method Detail

setConf

getConf

sequenceRecord

batchesSupported

next

sequenceRecord

nextSequence

loadSequenceFromMetaData

loadSequenceFromMetaData

initialize

initialize

next

hasNext

getLabels

reset

resetSupported

record

nextRecord

loadFromMetaData

loadFromMetaData

getListeners

setListeners

setListeners

close