Easy Batch是一個(gè)用于簡化在Java進(jìn)行批處理的框架。它提供了一些消除繁瑣的任務(wù)模板代碼，如讀取、篩選、解析和驗(yàn)證輸入數(shù)據(jù)，讓你專注于你的批量處理業(yè)務(wù)邏輯。

該框架背后的動(dòng)機(jī)是為了使您的開發(fā)生活更輕松。Easy Batch是一個(gè)輕量級的框架，你可以用流暢的Java API來進(jìn)行配置。可運(yùn)行在獨(dú)立模式或嵌入在應(yīng)用程序服務(wù)器中。

核心特性

輕量級框架

框架的核心沒有依賴關(guān)系,因此一個(gè)小內(nèi)存占用:80 ko jar文件的功能。

POJO-centric發(fā)展

簡單批處理發(fā)展POJO-centric。它允許您將數(shù)據(jù)映射到域?qū)ο笏阅闳匀豢梢允褂肑ava面向?qū)ο蠓矫妗?/p>

聲明數(shù)據(jù)驗(yàn)證

簡單批處理允許您聲明數(shù)據(jù)驗(yàn)證約束域?qū)ο蠛吞幚眚?yàn)證代碼。

并發(fā)執(zhí)行

簡單批處理允許你運(yùn)行多個(gè)并行加速引擎實(shí)例執(zhí)行,減少處理時(shí)間。

JMX監(jiān)控

與簡單的批處理,可以使用JMX監(jiān)控你的批處理執(zhí)行和進(jìn)展。

模塊化的體系結(jié)構(gòu)

簡單批處理體系結(jié)構(gòu)是通過一致的API模塊化和可擴(kuò)展的。您可以擴(kuò)展其組件和集成自己的解決方案。

代碼

public class Launcher {
    public static void main(String[] args) throws Exception {
        // Build a batch engine
        Engine engine = new EngineBuilder()
            .reader(new FlatFileRecordReader(new File("data.csv")))
            .filter(new HeaderRecordFilter())
            .mapper(new DelimitedRecordMapper(Data.class))
            .processor(new DataProcessor())
            .build();
        // Run the batch engine and get execution report
        Report report = engine.call();
    }
}