skip
-
Sequence 필터링 OperatorSpring Reactive Web Application/Project Reactor 2023. 8. 4. 05:00
filter filter() Operator는 Upstream에서 emit된 데이터 중 조건에 일치하는 데이터만 Downstream으로 emit 합니다. 즉, 파라미터로 입력받은 Predicate의 리턴 값이 true인 데이터만 Downstream으로 emit 합니다. import lombok.extern.slf4j.Slf4j; import reactor.core.publisher.Flux; /** * filter 예제 */ @Slf4j public class Example14_15 { public static void main(String[] args) { Flux .range(1, 20) .filter(num -> num % 2 != 0) .subscribe(data -> log.info("# onN..
-
필터링 연산자BackEnd/RxJava 2023. 7. 6. 07:00
filter 전달 받은 데이터가 조건에 맞는지 확인한 후 결과가 true인 데이터만 통지합니다. 파라미터로 받는 Predicate 함수형 인터페이스에서 조건을 확인합니다. 연산자 함수는 메서드 체인으로 여러 개를 사용할 수 있습니다. package com.itvillage.chapter05.chapter0502; import com.itvillage.common.CarMaker; import com.itvillage.common.SampleData; import io.reactivex.Observable; public class ObservableFilterExample02 { public static void main(String[] args) { Observable.fromIterable(Sample..
-
25. SkipBackEnd/Spring Batch 2022. 1. 6. 21:48
Skip은 데이터를 처리하는 동안 설정된 Exception이 발생했을 경우, 해당 데이터 처리를 건너뛰는 기능입니다. ItemReader: 예외가 발생하면 해당 아이템만 스킵하고 계속 진행 ItemProcessor, ItemWriter: 예외가 발생하면 Chunk의 처음으로 돌아가서 스킵된 아이템을 제외한 나머지 아이템들을 가지고 처리 Skip 기능은 내부적으로 SkipPolicy를 통해서 구현되어 있으며, Skip 가능 여부 판단 기준은 아래와 같습니다. 1. 스킵 대상에 포함된 예외인지 여부 (skippableException) 2. 스킵 카운터를 초과 했는지 여부 (skipCount > skipLimit, skipCount는 ItemReader, ItemProcessor, ItemWriter 합) ..
-
24. FaultTolerantBackEnd/Spring Batch 2022. 1. 4. 22:50
Spring Batch는 Job 실행 중에 오류가 발생할 경우 장애를 처리하기 위한 기능을 제공하며 이를 통해 복원력을 향상시킬 수 있습니다. 오류가 발생해도 Step이 즉시 종료되지 않고 Retry 혹은 Skip 기능을 활성화 함으로써 내결함성 서비스가 가능하도록 합니다. FaultTolerant 구조는 청크 기반의 프로세스 기반 위에 Skip과 Retry 기능이 추가되어 재정의 되어 있습니다. Skip: ItemReader / ItemProcessor / ItemWriter에 적용할 수 있습니다. Retry: ItemProcessor / ItemWriter에 적용할 수 있습니다. API package io.springbatch.springbatchlecture; import lombok.Require..