iSharkFly-Docs/java-tutorials
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Refactor Ignite samples (#4010)

Browse Source 
* asd

* Update IgniteStream.java

* Update IgniteStream.java

* Update IgniteStream.java
This commit is contained in:
Grzegorz Piwowarek 2018-04-29 17:24:13 +02:00 committed by GitHub
parent 443a691752
commit 40d6af7fab
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
libraries-data/src/main/java/com/baeldung/ignite/stream/IgniteStream.java
View File

@ -14,6 +14,8 @@ import java.nio.file.Paths;
public class IgniteStream { public class IgniteStream {
private static final Gson GSON = new Gson();
public static void main(String[] args) throws Exception { public static void main(String[] args) throws Exception {
Ignition.setClientMode(true); Ignition.setClientMode(true);
@ -29,16 +31,16 @@ public class IgniteStream {
employee.setEmployed(true); employee.setEmployed(true);
e.setValue(employee); e.setValue(employee);
return null; return employee;
})); }));
Path path = Paths.get(IgniteStream.class.getResource("employees.txt").toURI()); Path path = Paths.get(IgniteStream.class.getResource("employees.txt").toURI());
Files.lines(path) Files.lines(path)
.forEach(line -> { .forEach(line -> {
Employee employee = new Gson().fromJson(line, Employee.class); Employee employee = GSON.fromJson(line, Employee.class);
streamer.addData(employee.getId(), employee); streamer.addData(employee.getId(), employee);
}); });
} }
} }