Class FixedInputData
- java.lang.Object
-
- org.pentaho.di.trans.step.BaseStepData
-
- org.pentaho.di.trans.steps.fixedinput.FixedInputData
-
- All Implemented Interfaces:
StepDataInterface
public class FixedInputData extends BaseStepData implements StepDataInterface
- Since:
- 24-jan-2005
- Author:
- Matt
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.pentaho.di.trans.step.BaseStepData
BaseStepData.StepExecutionStatus
-
-
Field Summary
Fields Modifier and Type Field Description ByteBuffer
bb
int
bufferSize
byte[]
byteBuffer
org.pentaho.di.core.row.RowMetaInterface
convertRowMeta
byte[]
delimiter
byte[]
enclosure
int
endBuffer
FileChannel
fc
String
filename
long
fileSize
FileInputStream
fis
int
lineWidth
org.pentaho.di.core.row.RowMetaInterface
outputRowMeta
int
preferredBufferSize
long
rowsToRead
int
startBuffer
int
stepNumber
boolean
stopReading
int
totalNumberOfSteps
-
Constructor Summary
Constructors Constructor Description FixedInputData()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
readBufferFromFile()
void
resizeByteBuffer()
-
Methods inherited from class org.pentaho.di.trans.step.BaseStepData
getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, isStopped, setStatus
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.pentaho.di.trans.step.StepDataInterface
getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, setStatus
-
-
-
-
Field Detail
-
fis
public FileInputStream fis
-
fc
public FileChannel fc
-
bb
public ByteBuffer bb
-
outputRowMeta
public org.pentaho.di.core.row.RowMetaInterface outputRowMeta
-
convertRowMeta
public org.pentaho.di.core.row.RowMetaInterface convertRowMeta
-
byteBuffer
public byte[] byteBuffer
-
startBuffer
public int startBuffer
-
endBuffer
public int endBuffer
-
bufferSize
public int bufferSize
-
delimiter
public byte[] delimiter
-
enclosure
public byte[] enclosure
-
preferredBufferSize
public int preferredBufferSize
-
filename
public String filename
-
lineWidth
public int lineWidth
-
stopReading
public boolean stopReading
-
stepNumber
public int stepNumber
-
totalNumberOfSteps
public int totalNumberOfSteps
-
fileSize
public long fileSize
-
rowsToRead
public long rowsToRead
-
-
Method Detail
-
resizeByteBuffer
public void resizeByteBuffer()
-
readBufferFromFile
public void readBufferFromFile() throws IOException
- Throws:
IOException
-
-