- Transportador
Cambie la función de Ejecutar () de acuerdo con lo siguiente:
Total ByteBuffer
la documentación se puede encontrar en ByteBuffer
Documentación para personalización Transporter
Los módulos se pueden encontrar en algunos Cree un módulo de transportista personalizado.
- Formateador
Amplíe su clase de formato personalizado
com.sybase.esp.adapter.framework.module.StreamingFormatter
Realice las siguientes funciones:
El es
init()
función.Prepare su módulo de formato para la conversión entre formatos de datos; por ejemplo, recuperar propiedades del archivo de configuración del adaptador y realizar las tareas iniciales necesarias.
El es
start()
función.Realice las tareas necesarias al iniciar el adaptador.
El es
execute()
función.A continuación, se muestra un ejemplo de la función de ejecución () para formatear que convierte datos consecutivos en basados en flujo:
public void execute() throws Exception { OutputStream output = utility.getOutputStream(); while(!utility.isStopRequested()) { AdapterRow row = utility.getRow(); if(row != null) { AepRecord record = (AepRecord)row.getData(0); String str = record.getValues().toString() + "n"; output.write(str.getBytes()); } } }Para el formato que cambia de datos basados en flujo a datos basados en capas, use:
utility.getInputStream()
para obtener elInputStream
utility.createRow()
crearAdapterRow
cosasutility.sendRow()
para enviar las capas al siguiente módulo especificado en el archivo de configuración del adaptador
El es
stop()
funciónRealice las tareas necesarias cuando el adaptador esté apagado.
El es
destroy()
función.Realice acciones de limpieza para su formateador.
La documentación para los módulos personalizados de Formatter se puede encontrar en la sección Cree un módulo de formato personalizado.
Ver el $STREAMING_HOME/adapters/framework/examples/src
directorio tu código fuente para módulos de muestra