Hello, I want to create a component that use a java method returning a byte array. I want that component have a out row connection, to be able to branch other component, eg : tLogRow. If someone have an idea the way to convert that byte array for talend row connection please share Thanks
I guess this appends between the _begin.javajet & the _main.javajet. Ten, for each byte I get from the database, I have to extract all field. Then I have to transform it to String, and parse the string to get the correct output type. A split on the String can give me all the columns, and then I can get the node.outgoing format and try to format it. This represents some work, Acutally this is to create 2 components alias tPostgresqlBulkSTDIN & tPostgresqlBulkSTDOUT that could replace tPostgresqlOutput & tPostgresqlInput. I need to create/extract those bytes array to transform them on the fly as flow.
Done : Ive created the tPostgresqlBulkInput. This one works for now 2.5 times faster than tPostgresqlInput. It captures/parses the STDOUT, from posgresql COPY function and transforms it as a classical row. (only for integer/date/string field for now) Next step will be tPostgresqlBulkOutput, taking a row connection as input : - Bulk Insert - Bulk Update - Bulk Insert or update - Bulk Delete - Bulk Select with Join (github/parisni)