public class RowDataInputMapper extends Object
Constructor and Description |
---|
RowDataInputMapper(MappingIODefinition inputDefinition,
RowProducer rowProducer) |
Modifier and Type | Method and Description |
---|---|
void |
finished() |
boolean |
putRow(RowMetaInterface rowMeta,
Object[] row)
Attempts to put the
row onto the underlying rowProducer during its timeout period. |
public RowDataInputMapper(MappingIODefinition inputDefinition, RowProducer rowProducer)
public boolean putRow(RowMetaInterface rowMeta, Object[] row)
row
onto the underlying rowProducer
during its timeout period.
Returns true
if the operation completed successfully and false
otherwise.rowMeta
- input row's meta datarow
- input rowtrue
if the row
was put successfullypublic void finished()
Copyright © 2018 Hitachi Vantara. All rights reserved.