Mahmoud Ben Hassine fmbenhassine
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.easyrules.samples.bench; | |
| import org.easyrules.core.AnnotatedRulesEngine; | |
| import org.easyrules.core.DefaultRulesEngine; | |
| import java.util.Random; | |
| public class Benchmark { | |
| public static final int NB_ITERATION = 20000; //should be even |
fmbenhassine
/ DbParallelTest.java
Created
April 24, 2015 23:52
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.easybatch.jdbc; | |
| import org.easybatch.core.api.Record; | |
| import org.easybatch.core.api.RecordMapper; | |
| import org.easybatch.core.api.RecordProcessor; | |
| import org.easybatch.core.dispatcher.PoisonRecordBroadcaster; | |
| import org.easybatch.core.dispatcher.RoundRobinRecordDispatcher; | |
| import org.easybatch.core.filter.PoisonRecordFilter; | |
| import org.easybatch.core.impl.Engine; | |
| import org.easybatch.core.mapper.GenericRecordMapper; |
fmbenhassine
/ Tree.java
Last active
May 24, 2018 20:54
Use Easy Batch to do some data mining on paris trees data #EasyBatch
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.easybatch.flatfile; | |
| public class Tree { | |
| private String adresse; | |
| private float hauteur; | |
| public Tree() { | |
| } |
fmbenhassine
/ JobRule.java
Last active
May 24, 2018 20:55
Easy (Batch|Rules) inception #EasyBatch #EasyRules
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.easybatch.core.api.Engine; | |
| import org.easyrules.core.BasicRule; | |
| public class JobRule extends BasicRule { | |
| private ReportHolder reportHolder; | |
| private ReportPredicate reportPredicate; | |
| private Engine engine; |
fmbenhassine
/ JmxJob.java
Last active
May 24, 2018 21:00
Easy Batch Jmx push notification sample #EasyBatch
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.easybatch.core.job.Job; | |
| import org.easybatch.core.job.JobBuilder; | |
| import org.easybatch.core.job.JobExecutor; | |
| import org.easybatch.core.job.JobReport; | |
| import org.easybatch.core.processor.RecordProcessor; | |
| import org.easybatch.core.reader.IterableRecordReader; | |
| import org.easybatch.core.record.Record; | |
| import static java.util.Arrays.asList; |
fmbenhassine
/ DispatchAggregateSample.java
Last active
February 7, 2021 17:17
Easy Batch sample to dispatch/aggregate records using blocking queues #EasyBatch
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.easybatch.core.dispatcher.PoisonRecordBroadcaster; | |
| import org.easybatch.core.dispatcher.RoundRobinRecordDispatcher; | |
| import org.easybatch.core.filter.PoisonRecordFilter; | |
| import org.easybatch.core.job.Job; | |
| import org.easybatch.core.processor.RecordProcessingException; | |
| import org.easybatch.core.processor.RecordProcessor; | |
| import org.easybatch.core.reader.BlockingQueueRecordReader; | |
| import org.easybatch.core.reader.IterableRecordReader; | |
| import org.easybatch.core.record.Record; | |
| import org.easybatch.core.writer.BlockingQueueRecordWriter; |
fmbenhassine
/ post-install.sh
Last active
February 27, 2021 18:44
Cloud9 workspace post install script for Java development
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| sudo apt-get autoremove | |
| sudo apt-get update | |
| echo "Checking git version" | |
| git --version | |
| echo "Installing Jekyll" | |
| gem install jekyll | |
| cd ~/ && mkdir tools && cd tools |
fmbenhassine
/ Main.java
Last active
May 24, 2018 20:56
easy rules 1.3 with java 6 sample #EasyRules
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.easyrules.annotation.Action; | |
| import org.easyrules.annotation.Condition; | |
| import org.easyrules.annotation.Rule; | |
| import org.easyrules.api.RulesEngine; | |
| import org.easyrules.core.AnnotatedRulesEngine; | |
| public class Main { | |
| public static void main(String[] args) { | |
| RulesEngine rulesEngine = new AnnotatedRulesEngine(); | |
| rulesEngine.registerRule(new MyRule()); |
fmbenhassine
/ Main.java
Last active
May 24, 2018 20:58
Easy Batch implementation of http://aseigneurin.github.io/2015/01/23/spark-vs-command-line-tools.html #EasyBatch
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| public class Main { | |
| public static void main(String[] args) throws FileNotFoundException { | |
| Engine engine = new EngineBuilder() | |
| .reader(new FlatFileRecordReader(new File("/path/tp/ChessData-master/data.pgn"))) | |
| .filter(new GrepFilter("[Result")) | |
| .processor(new ComputationalRecordProcessor<StringRecord, StringRecord, Map<String, Integer>>() { | |
| Map<String, Integer> results = new HashMap<String, Integer>(); |
fmbenhassine
/ DatabaseUtil.java
Last active
May 24, 2018 20:58
Easy Batch implementation of https://spring.io/guides/gs/batch-processing/ #EasyBatch
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import java.sql.*; | |
| public class DatabaseUtil { | |
| private static final String DATABASE_URL = "jdbc:hsqldb:mem"; | |
| private static final String USER = "sa"; | |
| private static final String PASSWORD = "pwd"; | |
| public static Connection getConnection() throws SQLException { | |
| return DriverManager.getConnection(DATABASE_URL, USER, PASSWORD); |