更新時(shí)間:2022-12-02 11:05:09 來源:動(dòng)力節(jié)點(diǎn) 瀏覽3543次
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)證代碼。
簡單批處理允許你運(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();
}
}

相關(guān)閱讀

初級 202925

初級 203221

初級 202629

初級 203743