- 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
cosas -
utility.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