<dependencies> <dependency> <groupId>com.jmetrix</groupId> <artifactId>jmetrix-core</artifactId> <version>1.0.0</version> </dependency> </dependencies> JmetrixConfig.setDataSourceUrl("jdbc:mysql://localhost:3306/mydatabase"); JmetrixConfig.setDataSourceUsername("username"); JmetrixConfig.setDataSourcePassword("password"); Pipeline pipeline = new Pipeline() .extract(new DatabaseExtractor("SELECT * FROM mytable")) .clean(new DataCleaner()) .transform(new DataTransformer()) .load(new DataLoader()); AnalysisTask task = new AnalysisTask() .inputData("dataset.csv") .addColumn("age", DataType.INTEGER) .addColumn("income", DataType.DOUBLE) .perform(new AggregationAnalysis("income", Operation.SUM)) .perform(new MLModelTraining("income", "age"));