Customer Portal

CloeverETL for Oracle Identity Analytics

Comments 1

  • Avatar
    avackova
    0
    Comment actions Permalink
    Hello,
    for joining data from one stream use Denoramlizer component with following code:
    //#TL
    // This transformation defines the way in which multiple input records
    // (with the same key) are denormalized into one output record.
    string data = '"';
    // This function is called for each input record from a group of records
    // with the same key.
    function append() {
    data = concat(data, $field2, ',');
    }

    // This function is called once after the append() function was called for all records
    // of a group of input records defined by the key.
    // It creates a single output record for the whole group.
    function transform() {
    $field1 := $field1;
    $field2 := concat(substring(data,0,length(data) - 1),'"');
    $field3 := $field3;
    $field4 := $field4;
    return OK
    }

    // Called after transform() to return the resources that have been used to their initial state
    // so that next group of records with different key may be parsed.
    function clean() {
    data = '"';
    }



    To partition output data to different files, set partitionKey attribute on DataWriter. You can specify the place of partition tag in file url, eg: ${DATAOUT_DIR}/file#.txt

Please sign in to leave a comment.