Lectura de registros desde enlace de entrada (etapa de integración de Java en DataStage)

La interfaz de InputLink es una extensión de la interfaz de Link. Define los métodos que se utilizan para interactuar con el enlace de entrada de etapa correspondiente. Las instancias de un InputLink están disponibles en el objeto Configuration que se proporciona como argumento del método validateConfiguration() .

Métodos proporcionados por la interfaz de Link
  • getColumn()
  • getColumnCount()
  • getColumnMetadata()
  • getLinkIndex()
  • getUserProperties()
  • subtractColumnList()
Métodos proporcionados por la interfaz de InputLink
  • GetAssociatedRejectLink()
  • readRecord()
Al llamar al método readRecord() de una interfaz InputLink , el código Java™ puede consumir una fila del enlace de entrada. Devuelve un objeto que implementa la interfaz de InputRecord.
InputRecord inputRecord = m_inputLink.readRecord();

La interfaz de InputRecord es una extensión de la interfaz de Record. Define los métodos que se utilizan para obtener datos de columna de un registro de fila consumido.

Métodos proporcionados por la interfaz InputRecord
  • getObject()
  • getValue(String columnName)
  • getValue(int columnIndex)
En el ejemplo siguiente, se muestra cómo recuperar el valor correspondiente a un índice de columna determinado "i" en este registro.
Object value = inputRecord.getValue(i);
También puede recuperar el valor especificando el nombre de columna como se muestra a continuación.
Object value = inputRecord.getValue(“name”);