INNER CODE UNIT · Java
parseToObScanJobObject
PlaytikaOSS/testcontainers-spring-boot · embedded-aerospike/src/main/java/com/playtika/testcontainer/aerospike/AerospikeTestOperations.java:72
private ScanJob parseToObScanJobObject(String job) {
String[] pairs = job.split(":");
Map<String, String> pairsMap = Arrays.stream(pairs)
.map(pair -> {
String[] kv = pair.split("=");
return new AbstractMap.SimpleEntry<>(kv[0], kv[1]);
})
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
return ScanJob.builder()
.module(pairsMap.get("module"))
.set(pairsMap.get("set"))
.udfFunction(pairsMap.get("udf-function"))
.status(pairsMap.get("status"))
.trid(pairsMap.get("trid"))
.namespace(pairsMap.get("ns"))
.build();
}