SpringCloud/spring-cloud-dataflow-samples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Change group and package

Browse Source
This commit is contained in:
David Turanski
2018-10-30 10:08:44 -04:00
parent bdc9d1848d
commit 8d9fbb0c6e
12 changed files with 208 additions and 82 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
batch/file-ingest/pom.xml
View File

@@ -2,7 +2,7 @@
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.springframework</groupId>
<groupId>io.spring.cloud.ingest</groupId>
<artifactId>ingest</artifactId>
<version>1.0.0</version>
<parent>
@@ -14,7 +14,6 @@
<java.version>1.8</java.version>
<maven.compiler.plugin.version>3.7.0</maven.compiler.plugin.version>
<spring.cloud.task.version>1.2.2.RELEASE</spring.cloud.task.version>
<spring.batch.starter.version>2.0.0.M7</spring.batch.starter.version>
<checkstyle.config.location>checkstyle.xml</checkstyle.config.location>
<checkstyle.plugin.version>2.17</checkstyle.plugin.version>
</properties>

34
batch/file-ingest/src/main/java/io/spring/cloud/ingest/Application.java Normal file
View File

@@ -0,0 +1,34 @@
/*
* Copyright 2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.spring.cloud.ingest;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.task.configuration.EnableTask;
/**
* Main entry point for the ingest sample application.
*
* @author Chris Schaefer
*/
@EnableTask
@SpringBootApplication
public class Application {
public static void main(String[] args) throws Exception {
SpringApplication.run(Application.class, args);
}
}

25
batch/file-ingest/src/main/java/org/springframework/ingest/config/BatchConfiguration.java → batch/file-ingest/src/main/java/io/spring/cloud/ingest/config/BatchConfiguration.java
View File

@@ -1,5 +1,24 @@
package org.springframework.ingest.config;
/*
* Copyright 2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.spring.cloud.ingest.config;
import io.spring.cloud.ingest.domain.Person;
import io.spring.cloud.ingest.mapper.fieldset.PersonFieldSetMapper;
import io.spring.cloud.ingest.processor.PersonItemProcessor;
import javax.sql.DataSource;
import org.springframework.batch.core.Job;
@@ -21,10 +40,6 @@ import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.ResourceLoader;
import org.springframework.ingest.domain.Person;
import org.springframework.ingest.mapper.fieldset.PersonFieldSetMapper;
import org.springframework.ingest.processor.PersonItemProcessor;
/**
* Class used to configure the batch job related beans.
*

45
batch/file-ingest/src/main/java/io/spring/cloud/ingest/domain/Person.java Normal file
View File

@@ -0,0 +1,45 @@
/*
* Copyright 2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.spring.cloud.ingest.domain;
/**
* Domain object representing data about a Person.
*
* @author Chris Schaefer
*/
public class Person {
private final String firstName;
private final String lastName;
public Person(final String firstName, final String lastName) {
this.firstName = firstName;
this.lastName = lastName;
}
public String getFirstName() {
return firstName;
}
public String getLastName() {
return lastName;
}
@Override
public String toString() {
return "First name: " + firstName + " , last name: " + lastName;
}
}

37
batch/file-ingest/src/main/java/io/spring/cloud/ingest/mapper/fieldset/PersonFieldSetMapper.java Normal file
View File

@@ -0,0 +1,37 @@
/*
* Copyright 2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.spring.cloud.ingest.mapper.fieldset;
import io.spring.cloud.ingest.domain.Person;
import org.springframework.batch.item.file.mapping.FieldSetMapper;
import org.springframework.batch.item.file.transform.FieldSet;
/**
* Maps the provided FieldSet into a Person object.
*
* @author Chris Schaefer
*/
public class PersonFieldSetMapper implements FieldSetMapper<Person> {
@Override
public Person mapFieldSet(FieldSet fieldSet) {
String firstName = fieldSet.readString(0);
String lastName = fieldSet.readString(1);
return new Person(firstName, lastName);
}
}

20
batch/file-ingest/src/main/java/org/springframework/ingest/processor/PersonItemProcessor.java → batch/file-ingest/src/main/java/io/spring/cloud/ingest/processor/PersonItemProcessor.java
View File

@@ -1,10 +1,26 @@
package org.springframework.ingest.processor;
/*
* Copyright 2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.spring.cloud.ingest.processor;
import io.spring.cloud.ingest.domain.Person;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.batch.item.ItemProcessor;
import org.springframework.ingest.domain.Person;
/**
* Processes the providing record, transforming the data into

18
batch/file-ingest/src/main/java/org/springframework/ingest/Application.java
View File

@@ -1,18 +0,0 @@
package org.springframework.ingest;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.task.configuration.EnableTask;
/**
* Main entry point for the ingest sample application.
*
* @author Chris Schaefer
*/
@EnableTask
@SpringBootApplication
public class Application {
public static void main(String[] args) throws Exception {
SpringApplication.run(Application.class, args);
}
}

29
batch/file-ingest/src/main/java/org/springframework/ingest/domain/Person.java
View File

@@ -1,29 +0,0 @@
package org.springframework.ingest.domain;
/**
* Domain object representing data about a Person.
*
* @author Chris Schaefer
*/
public class Person {
private final String firstName;
private final String lastName;
public Person(final String firstName, final String lastName) {
this.firstName = firstName;
this.lastName = lastName;
}
public String getFirstName() {
return firstName;
}
public String getLastName() {
return lastName;
}
@Override
public String toString() {
return "First name: " + firstName + " , last name: " + lastName;
}
}

21
batch/file-ingest/src/main/java/org/springframework/ingest/mapper/fieldset/PersonFieldSetMapper.java
View File

@@ -1,21 +0,0 @@
package org.springframework.ingest.mapper.fieldset;
import org.springframework.batch.item.file.mapping.FieldSetMapper;
import org.springframework.batch.item.file.transform.FieldSet;
import org.springframework.ingest.domain.Person;
/**
* Maps the provided FieldSet into a Person object.
*
* @author Chris Schaefer
*/
public class PersonFieldSetMapper implements FieldSetMapper<Person> {
@Override
public Person mapFieldSet(FieldSet fieldSet) {
String firstName = fieldSet.readString(0);
String lastName = fieldSet.readString(1);
return new Person(firstName, lastName);
}
}

18
batch/file-ingest/src/test/java/org/springframework/ingest/config/BatchConfigurationTests.java → batch/file-ingest/src/test/java/io/spring/cloud/ingest/config/BatchConfigurationTests.java
View File

@@ -1,4 +1,20 @@
package org.springframework.ingest.config;
/*
* Copyright 2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.spring.cloud.ingest.config;
import org.junit.After;
import org.junit.Before;

20
batch/file-ingest/src/test/java/org/springframework/ingest/mapper/fieldset/PersonFieldSetMapperTests.java → batch/file-ingest/src/test/java/io/spring/cloud/ingest/mapper/fieldset/PersonFieldSetMapperTests.java
View File

@@ -1,4 +1,20 @@
package org.springframework.ingest.mapper.fieldset;
/*
* Copyright 2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.spring.cloud.ingest.mapper.fieldset;
import org.junit.Test;
@@ -6,7 +22,7 @@ import org.springframework.batch.item.file.mapping.FieldSetMapper;
import org.springframework.batch.item.file.transform.DefaultFieldSet;
import org.springframework.batch.item.file.transform.FieldSet;
import org.springframework.ingest.domain.Person;
import io.spring.cloud.ingest.domain.Person;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertEquals;

20
batch/file-ingest/src/test/java/org/springframework/ingest/processor/PersonItemProcessorTests.java → batch/file-ingest/src/test/java/io/spring/cloud/ingest/processor/PersonItemProcessorTests.java
View File

@@ -1,9 +1,25 @@
package org.springframework.ingest.processor;
/*
* Copyright 2018 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package io.spring.cloud.ingest.processor;
import io.spring.cloud.ingest.domain.Person;
import org.junit.Test;
import org.springframework.batch.item.ItemProcessor;
import org.springframework.ingest.domain.Person;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertEquals;