1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.infra.executor.sql.process.yaml.swapper;
19
20 import org.apache.shardingsphere.infra.executor.sql.process.Process;
21 import org.apache.shardingsphere.infra.executor.sql.process.yaml.YamlProcessList;
22 import org.apache.shardingsphere.infra.util.yaml.swapper.YamlConfigurationSwapper;
23
24 import java.util.Collection;
25 import java.util.stream.Collectors;
26
27
28
29
30 public final class YamlProcessListSwapper implements YamlConfigurationSwapper<YamlProcessList, Collection<Process>> {
31
32 private final YamlProcessSwapper yamlProcessSwapper = new YamlProcessSwapper();
33
34 @Override
35 public YamlProcessList swapToYamlConfiguration(final Collection<Process> data) {
36 YamlProcessList result = new YamlProcessList();
37 result.setProcesses(data.stream().map(yamlProcessSwapper::swapToYamlConfiguration).collect(Collectors.toList()));
38 return result;
39 }
40
41 @Override
42 public Collection<Process> swapToObject(final YamlProcessList yamlConfig) {
43 return yamlConfig.getProcesses().stream().map(yamlProcessSwapper::swapToObject).collect(Collectors.toList());
44 }
45 }