使用eclipse开发Morphline的Java代码段

小程序：扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序

背景：morphline是一个轻量级的etl工具。除了提供标准化的方法之外，还可以定制化的开发java片段。定制化的java片段会在加载时被作为一个独立的类编译，对源数据作处理。

morphline关于java片段的例子，在配置文件上编写java代码太难了，尤其是在中文输入法下，可能逗号或者引号打错了也浑然不知。

java {

  imports : "import java.util.*;"

  code: """

    // Update some custom metrics - see http://metrics.codahale.com/getting-started/

    context.getMetricRegistry().counter("myMetrics.myCounter").inc(1);

    context.getMetricRegistry().meter("myMetrics.myMeter").mark(1);

    context.getMetricRegistry().histogram("myMetrics.myHistogram").update(100);

    com.codahale.metrics.Timer.Context timerContext = context.getMetricRegistry().timer("myMetrics.myTimer").time();

    // manipulate the contents of a record field

    List tags = record.get("tags");

    if (!tags.contains("hello")) {

      return false;

    }

    tags.add("world");

    logger.debug("tags: {} for record: {}", tags, record); // log to SLF4J

    timerContext.stop(); // measure how much time the code block took

    return child.process(record); // pass record to next command in chain

        """

}

在eclipse下开发代码也比较简单。定义一个如下的类，在test()方法里面开发代码段，需要import的包就在上面定义，这样就可以利用eclipse的编译功能来纠错了。然后把import段拷贝到morphline的import字段，把test()里面的内容拷贝到code：”””//[code] ”””里面。

package test;

import java.util.Collections;

import java.util.Iterator;

import org.kitesdk.morphline.api.Command;

import org.kitesdk.morphline.api.Record;

import org.kitesdk.morphline.base.Fields;

import com.fasterxml.jackson.databind.JsonNode;

public class TestMain

{

    Record record;

    Command child;

    public boolean test()

    {

        JsonNode rootNode = (JsonNode) record.getFirstValue(Fields.ATTACHMENT_BODY);

        JsonNode jsonNode = rootNode.get("tags");

        if (jsonNode.isArray())

        {

            Iterator<JsonNode> tags = jsonNode.elements();

            while (tags.hasNext())

            {

                JsonNode next = tags.next();

                String name = next.get("name").asText();

                JsonNode values = next.get("value");

                for (JsonNode value : values)

                {

                    record.put("custom_tag", name + "=" + value.asText());

                }

            }

        }

        return child.process(record);

    }

}