public class FixedInputData extends BaseStepData implements StepDataInterface
BaseStepData.StepExecutionStatus
Modifier and Type | Field and 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 and Description |
---|
FixedInputData() |
Modifier and Type | Method and Description |
---|---|
void |
readBufferFromFile() |
void |
resizeByteBuffer() |
getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, isStopped, setStatus
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getStatus, isDisposed, isEmpty, isFinished, isIdle, isInitialising, isRunning, setStatus
public FileInputStream fis
public FileChannel fc
public ByteBuffer bb
public org.pentaho.di.core.row.RowMetaInterface outputRowMeta
public org.pentaho.di.core.row.RowMetaInterface convertRowMeta
public byte[] byteBuffer
public int startBuffer
public int endBuffer
public int bufferSize
public byte[] delimiter
public byte[] enclosure
public int preferredBufferSize
public String filename
public int lineWidth
public boolean stopReading
public int stepNumber
public int totalNumberOfSteps
public long fileSize
public long rowsToRead
public void resizeByteBuffer()
public void readBufferFromFile() throws IOException
IOException