스타일 적용
This commit is contained in:
@@ -20,14 +20,14 @@ public class CsvFileProcessor implements ZipEntryProcessor {
|
||||
public void process(String fileName, InputStream is) throws IOException {
|
||||
try (BufferedReader br = new BufferedReader(new InputStreamReader(is))) {
|
||||
br.lines()
|
||||
.forEach(
|
||||
line -> {
|
||||
String[] cols = line.split(",");
|
||||
// CSV 처리
|
||||
for (String col : cols) {
|
||||
log.info(col); //TODO : 추후에 csv 파일 읽어서 작업 필요할 때 정의하기
|
||||
}
|
||||
});
|
||||
.forEach(
|
||||
line -> {
|
||||
String[] cols = line.split(",");
|
||||
// CSV 처리
|
||||
for (String col : cols) {
|
||||
log.info(col); // TODO : 추후에 csv 파일 읽어서 작업 필요할 때 정의하기
|
||||
}
|
||||
});
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -46,7 +46,7 @@ public class JsonStreamingFileProcessor implements ZipEntryProcessor {
|
||||
|
||||
if (token == JsonToken.FIELD_NAME) {
|
||||
String fieldName = parser.getCurrentName();
|
||||
//TODO: json 파일 읽어야 할 내용 정의되면 항목 확정하기
|
||||
// TODO: json 파일 읽어야 할 내용 정의되면 항목 확정하기
|
||||
switch (fieldName) {
|
||||
case "type" -> {
|
||||
parser.nextToken();
|
||||
|
||||
@@ -21,7 +21,7 @@ public class TextFileProcessor implements ZipEntryProcessor {
|
||||
BufferedReader br = new BufferedReader(new InputStreamReader(is));
|
||||
String line;
|
||||
while ((line = br.readLine()) != null) {
|
||||
log.info(line); //TODO : 추후 txt 파일 읽어서 작업할 때 정의하기
|
||||
log.info(line); // TODO : 추후 txt 파일 읽어서 작업할 때 정의하기
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -31,16 +31,16 @@ public class ZipUtils {
|
||||
|
||||
String fileName = entry.getName();
|
||||
processors.stream()
|
||||
.filter(p -> p.supports(fileName))
|
||||
.findFirst()
|
||||
.ifPresent(
|
||||
processor -> {
|
||||
try {
|
||||
processor.process(fileName, zis);
|
||||
} catch (IOException ioe) {
|
||||
throw new UncheckedIOException(ioe);
|
||||
}
|
||||
});
|
||||
.filter(p -> p.supports(fileName))
|
||||
.findFirst()
|
||||
.ifPresent(
|
||||
processor -> {
|
||||
try {
|
||||
processor.process(fileName, zis);
|
||||
} catch (IOException ioe) {
|
||||
throw new UncheckedIOException(ioe);
|
||||
}
|
||||
});
|
||||
|
||||
zis.closeEntry();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user