본문 바로가기

빅데이터 품질의 추가 위험

보고서는 10시부터 10시 10분까지의 거래를 150이라고 알렸다. 잠시 뒤에는 170이 되었고, 다른 팀은 270이라고 계산했다. 어느 값이 맞는지는 큰 서버를 썼는지보다 무엇을 한 번 세었고, 언제 발생한 자료를 언제까지 받았는지에 달려 있다.

1. 오전 매출이 나중에 바뀌면 모두 오류일까

보고서는 10시부터 10시 10분까지의 거래를 150이라고 알렸다. 잠시 뒤에는 170이 되었고, 다른 팀은 270이라고 계산했다. 어느 값이 맞는지는 큰 서버를 썼는지보다 무엇을 한 번 세었고, 언제 발생한 자료를 언제까지 받았는지에 달려 있다.

이 절에서는 가상 거래 스트림 BD-E1을 따라가며 수집 지연·재전송·원천 단절·구조 변화가 품질 판단을 어떻게 바꾸는지 살핀다. 모든 식별자·수치·시간은 자체 예제이며 실제 매출 자료나 Beam·Flink 실행 결과가 아니다. 기본 품질 원리를 새 이름으로 반복하지 않고, 결과의 잠정성·포함 범위·정정 경로를 추가한다.

앞 절에서 가져올 판단

품질 검사에서 남겨 둘 미확인. 품질차원·규칙·측정·개선체계에서는 용도와 규칙을 정한 뒤 통과·위반·미확인을 나누어 측정하고 개선 후 재측정했다. 많은 자료에서도 미확인을 조용히 분모에서 빼면 품질이 좋아진 것처럼 보일 수 있었다.

앞 절에서 가져올 판단

계보에서 이어받을 판본·시점. 메타데이터·표준·마스터·계보에서는 원천 식별자·기준 판본·유효시점과 변환 경로를 함께 기록했다. 여기서는 그 연결을 이용하여 늦은 기록과 재처리가 어느 결과를 바꾸는지 찾는다.

정확한 정의와 이 절의 경계

빅데이터 품질 통제는 대량·다양·고속 자료의 수집·변환·분석 과정에서 중복·지연·누락·의미 변화의 영향을 관찰하고, 목적별 사용 조건과 정정 책임을 유지하는 활동이다.

기본 품질차원과 관리체계는 품질차원·규칙·측정·개선체계의 정의를 재사용한다. 이 절은 분산·연속 수집에서 추가되는 관찰·확정·정정의 경계를 담당하며 데이터레이크 구현·학습기법·법적 보존기간을 새로 정의하지 않는다.

더 많은 자료보다 더 어려운 확인

같은 양식의 확정된 파일 하나와 여러 기기에서 계속 도착하는 기록은 확인할 질문이 다르다. 후자는 아직 오지 않은 기록과 영원히 빠진 기록을 당장 구별하기 어렵고, 원천별 시계·단위·판본도 다를 수 있다.

NIST의 정의 설명은 자료 규모·다양성·속도 등의 특성과 확장 가능한 처리 구조를 연결한다. [BD-S1] 그렇다고 건수가 어떤 숫자를 넘으면 모든 자료를 ‘빅데이터’로 인증한다는 뜻은 아니다. 이 절은 용어의 크기 경쟁보다 그 특성 때문에 기존 품질 확인의 경계가 어떻게 달라지는지 다룬다.

한 결과에 이르는 관찰 지점을 만든다

원천 범위와 받은 기록의 상태를 따로 관찰한다

상자 안의 대상과 화살표의 조건을 함께 읽으세요. 좁은 화면에서는 같은 관계를 세로로 재배치한 도식을 보여 줍니다.

원천 범위와 받은 기록의 상태를 따로 관찰한다상단은 수집과 수용 판단, 하단은 집계·분석·업무 사용이다. 각 노드에 해당 관찰값을 붙인다. 수신 후 상태가 대사돼도 원천 자료가 모두 수신되었는지는 별도로 확인한다. 점선은 계보·영향을 확인하여 정정·재처리·같은 기준 재측정으로 돌아가는 경로이며 실제 설치·운영 증거가 아니다.source → receivereceive → schemaschema → eventevent → aggregateaggregate → modelmodel → useuse → aggregate: 정정·재측정정정·재측정원천 A·B: 가동·전송 범위 미수신 상태원천 A·B가동·전송 범위미수신 상태수집 기록: 도착 시각·수신 수수집 기록도착 시각·수신 수판본·형식 확인: 단위·거부·격리 사유판본·형식 확인단위·거부·격리 사유사건 식별·중복 통제: 사건 시각·지연 키·내용·재전송사건 식별·중복 통제사건 시각·지연키·내용·재전송시간 구간 집계: 잠정·정정 판본시간 구간 집계잠정·정정 판본분석 입력·모델: 재현 가능한 입력 집합분석 입력·모델재현 가능한 입력 집합실제 업무 사용: 허용 범위·제한·통지실제 업무 사용허용 범위·제한·통지
원천 범위와 받은 기록의 상태를 따로 관찰한다상단은 수집과 수용 판단, 하단은 집계·분석·업무 사용이다. 각 노드에 해당 관찰값을 붙인다. 수신 후 상태가 대사돼도 원천 자료가 모두 수신되었는지는 별도로 확인한다. 점선은 계보·영향을 확인하여 정정·재처리·같은 기준 재측정으로 돌아가는 경로이며 실제 설치·운영 증거가 아니다.source → receivereceive → schemaschema → eventevent → aggregateaggregate → modelmodel → useuse → aggregate: 정정·재측정정정·재측정원천 A·B: 가동·전송 범위 미수신 상태원천 A·B가동·전송 범위미수신 상태수집 기록: 도착 시각·수신 수수집 기록도착 시각·수신 수판본·형식 확인: 단위·거부·격리 사유판본·형식확인단위·거부·격리사유사건 식별·중복 통제: 사건 시각·지연 키·내용·재전송사건 식별·중복 통제사건 시각·지연키·내용·재전송시간 구간 집계: 잠정·정정 판본시간 구간 집계잠정·정정 판본분석 입력·모델: 재현 가능한 입력 집합분석입력·모델재현 가능한 입력집합실제 업무 사용: 허용 범위·제한·통지실제 업무 사용허용범위·제한·통지

상단은 수집과 수용 판단, 하단은 집계·분석·업무 사용이다. 각 노드에 해당 관찰값을 붙인다. 수신 후 상태가 대사돼도 원천 자료가 모두 수신되었는지는 별도로 확인한다. 점선은 계보·영향을 확인하여 정정·재처리·같은 기준 재측정으로 돌아가는 경로이며 실제 설치·운영 증거가 아니다.

원천 가동·범위, 도착 시각, 거부·격리 건수, 사건 시각·지연을 함께 관찰한다. 계보에서 영향받는 결과를 찾고 재처리·재측정하며 미수신과 수신 후 거부를 합치지 않는다.

처리한 행 수만 감시하면 첫 단계에서 아예 오지 않은 원천을 놓친다. 단계별 수량과 사유를 연결하여 수집 전 누락과 수집 후 거부를 구별한다. 이 그림은 관찰 설계이지 실제 시스템에서 이 계측을 설치했다는 증거가 아니다.

규모·다양성·속도에 따라 실패가 증폭되는 위치

특성추가 위험의 예필요한 질문
대량특정 작은 집단의 오류가 전체 평균에 묻힘중요 원천·기간별 분모와 오류는 어떤가
다양같은 amount가 원·천 원, 현재값·거래 당시 값으로 섞임의미·단위·판본의 대응이 검증되었나
고속·연속지연·재전송·수정 기록이 확정 이후 도착사건 식별·시간 경계·정정 정책은 무엇인가
분산정상 무거래와 원천 단절이 모두 0건으로 보임원천 상태·전송 범위·미수신을 관찰하는가

차원을 늘어놓는 대신 용도에 맞는 규칙을 단계에 붙인다. 누락된 원천을 ‘0건 정상’으로 처리하면 모든 수신 행이 형식 검사를 통과해도 전체 보고서는 완전하지 않다. 점검 종류가 많다는 사실과 실제 중요한 실패를 발견했다는 사실은 다르다.

2. 발생한 시각과 처리한 시각을 분리한다

이벤트 시간(event time)은 자료가 나타내는 사건이 원천에서 발생한 시각이다. 처리 시간(processing time)은 특정 처리 단계가 그 자료를 다루는 시각이다. 분산 수집에서는 두 순서가 일치하지 않을 수 있다. [BD-S2]

예컨대 10시 7분 거래가 연결 장애로 10시 12분에 도착했다면 10시대 거래라는 업무 의미는 도착 순서로 바뀌지 않는다. 반대로 원천 시계가 잘못되어 있다면 이벤트 시간 필드가 있다는 것만으로 실제 발생시각을 믿을 수는 없다. 시각의 출처·시간대·오차와 정정 방법도 계약의 일부로 남긴다.

구간의 끝과 늦은 자료의 뜻

윈도(window)는 연속 자료를 집계하기 위해 정한 시간 등의 기준으로 나눈 범위다. 워터마크(watermark)는 이벤트 시간의 처리 진행을 나타내며 더 오래된 자료의 도착 가능성을 다루기 위해 사용하는 경계 정보다. 그 보장의 강도는 원천과 생성 규약에 따라 다르며 항상 참인 완전성 인증은 아니다. [BD-S2]

이 절의 거래 구간 W1은 같은 업무 시간대의 [10:00, 10:10)이다. 10시는 포함하고 10시 10분은 다음 구간으로 보낸다. 도착이 늦다는 말에는 사건시각·관찰한 워터마크·구간·허용 정책이 필요하다. 벽시계가 10시 10분을 넘었다는 사실과 이벤트 시간 집계의 마감 조건을 혼동하지 않는다.

BD-E1: 같은 거래가 두 번 전송된다

수집 순서와 무관하게 (원천, 사건 ID)를 동일 사건의 키로 쓴다고 가정한다. 같은 키의 재전송은 내용까지 같을 때만 중복으로 인정하며, 금액이 다르면 수정 규약 없이는 충돌로 격리한다.

수신 순서원천:사건 ID이벤트 시간수신·처리 시각금액
1A:e110:0110:02100
2A:e210:0510:0650
3A:e110:0110:08100
4A:e310:0710:1220

표에는 수신 기록 4개와 서로 다른 사건 3개가 있다. 3번은 e1 재전송이고 e3는 새로운 사건이다. 이것은 확인된 예제 규약이며 모든 원천이 신뢰할 만한 사건 ID를 준다는 보장은 아니다. 원천이 바뀌면 키의 범위·재사용·충돌부터 검토한다.

150, 170, 270이 생기는 이유를 따라간다

세 번째 수신까지 반영한 집합은 {A:e1, A:e2}다. 중복을 한 번만 세면 잠정 합계는 100+50=150이다. 네 번째 수신까지 같은 구간에 반영하면 {A:e1,A:e2,A:e3}이므로 정정 합계는 170이다.

중복 확인 없이 네 행을 모두 더하면 100+50+100+20=270이다. 150과 170의 차이 20은 늦은 신규 사건이고, 170과 270의 차이 100은 중복 효과다. 두 차이를 ‘지연 때문에 숫자가 달라짐’ 하나로 묶으면 통제할 원인이 사라진다.

150을 보여 줄 때 결과 판본·포함 집합·관찰 시점과 잠정 표시를 남긴다. 뒤의 170은 이전 값을 몰래 덮는 수치가 아니라 무엇이 추가되어 바뀌었는지 설명할 수 있는 정정 결과다.

수용·격리·정정의 정책을 먼저 정한다

BD-E1의 설명용 정책은 첫 결과 후 10시 15분까지 받은 적합 기록을 정정판에 반영하는 것이다. 이것은 업무가 허용한 수신시각 기준의 예제 마감이며 Beam의 특정 API 설정과 동일하다고 주장하지 않는다. 실제 시스템에서는 이벤트 시간 진행·트리거·허용 지연·상태 보관이 어떻게 맞물리는지 해당 판본으로 확인한다. [BD-S2]

마감 뒤 온 자료를 조용히 버리지 않고 늦은 자료 장부에 기록하여 다음 정산·재처리 경로로 넘긴다. 실시간 알림은 잠정 결과를 허용하고 결산은 원천 대조를 요구할 수 있다. 어떤 경로든 늦은 자료 수·금액·영향받은 결과와 처리 책임을 남겨야 한다.

이미 외부로 전달한 잠정 결과가 있으면 정정 수신자가 어떤 판본을 사용했는지도 확인한다. 단순한 파일 덮어쓰기로 후속 의사결정의 영향까지 사라지지는 않는다.

독립 변형 — 두 시간 조건을 따로 적용한다. 앞 네 수신에 더해, 서로 다른 신규 사건 e4는 이벤트 시간 10:10·수신시각 10:14·금액 30이고 e5는 이벤트 시간 10:09·수신시각 10:16·금액 40이라고 하자. 두 사건의 원천·형식·금액은 모두 확인되어 있다. e4와 e5를 각각 어느 구간·처리 경로로 보낼지 정하고, 위 마감 정책에 따른 W1의 정정 합계를 먼저 계산한다.

이벤트 구간과 수신 마감을 각각 적용한 결과 보기

해설: e4는 마감 전에 받았어도 W1의 끝 10:10을 포함하지 않으므로 다음 구간의 사건이다. e5는 W1 사건이지만 마감 뒤에 받았으므로 늦은 자료 장부와 후속 정산·재처리로 넘긴다. 이 정책의 현재 W1 정정판은 170이며, 나중에 e5를 반영하도록 승인된 별도 판본은 170+40=210이 된다. 수신이 빠르다는 이유로 e4의 30을 W1에 더했다면 시작 포함·끝 제외의 구간 경계를, e5를 기록 없이 버렸다면 이 블록의 마감 후 처리 경로를 다시 확인한다. e4가 속한 다음 구간의 마감·확정 조건은 별도로 정해야 한다.

중복 제거의 보관기간도 보장 범위다

e1을 기억하는 상태를 지운 뒤 같은 e1이 다시 오면, 같은 키를 쓴다는 문장만으로 중복 효과를 막지 못한다. 원천의 재전송 가능 기간, 처리 상태의 보관, 출력 저장의 중복 통제를 함께 확인해야 한다.

BD-E1에서 e1 금액이 100에서 120으로 바뀐 기록은 단순 재전송으로 삭제하지 않는다. 수정 번호·우선순위·취소와 재발행의 의미가 정해지지 않았다면 충돌을 보류한다. ‘마지막 수신값이 최신’이라는 임의 규칙은 실제 사건의 순서를 바꿀 수 있다.

여기서 검사하는 것은 가상 집합과 판정이다. 실제 처리기의 정확히 한 번 보장이나 외부 저장소와의 원자성을 검증한 결과로 확대하지 않는다.

BD-W1: 느린 원천을 평균으로 숨기지 않는다

두 병렬 입력의 현재 워터마크를 A=12:10, B=12:04라고 가정하자. 두 입력을 함께 고려하는 진행 경계는 이 예에서 min(12:10,12:04)=12:04다. 평균 12시 7분으로 정하면 아직 그 지점까지 진행하지 않은 B를 앞서간 것으로 취급한다. Flink 문서도 여러 병렬 입력 중 느린 진행과 유휴 입력의 문제를 설명한다. [BD-S3]

B를 유휴 입력으로 제외하면 나머지 진행은 빨라질 수 있지만 B의 모든 사건이 존재하지 않는다는 증거가 생기는 것은 아니다. BD-W1 보고서에는 A 포함, B 유휴 처리, B의 자료 완전성 미확인을 따로 적는다.

B가 다시 돌아올 때 오래된 사건의 처리·정정 경로가 있어야 한다. 특정 입력을 제외하는 실행 설정과 전체 원천의 품질 승인은 서로 다른 판단이다.

빠른 결과와 완결된 결과를 같은 약속으로 팔지 않는다

사용 목적허용할 수 있는 결과의 예추가 확인
상황 알림잠정 집계·지연 표시늦은 변화의 통지와 중복 알림 통제
정산 대조원천 범위와 정정이 대조된 판본미수신 원천·차액·미해결 충돌
모델 입력특정 판본에서 재현 가능한 특징 집합당시 이용 가능성과 지연된 정답

늦은 자료를 오래 기다리면 결과의 시의성이 낮아지고 상태·운영 부담이 커질 수 있다. 짧게 기다리면 정정이 더 필요하다. 어느 쪽이든 미확인을 감추어 ‘완전한 최신값’이라고 표시하지 않는다.

빠른 원천의 자료가 계속 쌓이는데 느린 입력을 기다려야 하는 경우 처리 상태가 커지는 문제도 있다. [BD-S3] 수집의 속도 문제를 품질 검사의 예외 처리와 운영 한도까지 연결한다.

3. 형식이 맞아도 의미가 달라질 수 있다

어제의 amount=100이 원 단위였는데 오늘부터 천 원 단위가 되었다고 하자. 숫자형·양수 검사만 통과하면 두 값을 같은 척도로 집계하게 된다. 구조 판본, 단위, 기준 시각과 변환 규칙을 함께 대조해야 한다.

BD-SC1의 자체 계약은 schema=v1, currency=KRW, unit=won을 요구한다. 필드 이름이 같아도 unit이 thousand_won이거나 판본이 비면 수용하지 않는다. 확인되지 않은 판본을 v1로 추정해 넣는 대신 영향과 보완 경로를 남긴다.

구조의 변화는 무조건 나쁜 것이 아니다. 필요한 변화라면 새 판본·해석 규칙·소비자를 검토한 뒤 전환한다. 품질 체계의 목적은 변화 금지가 아니라 무해하다고 확인하지 않은 의미 변경의 통제다.

데이터 변화와 학습·운영 불일치를 구별한다

데이터 드리프트(data drift)는 비교하는 시기 사이에 입력 자료의 통계적 분포가 달라지는 현상이다. 학습·서빙 스큐(training-serving skew)는 모델을 학습할 때와 실제 예측 입력을 만들 때 자료의 분포나 처리 의미가 달라지는 문제다. TensorFlow Data Validation(TFDV)은 머신러닝 데이터의 통계를 살피고 품질을 검사하는 라이브러리다. TFDV는 서로 다른 자료 집합의 통계와 비교 규칙으로 이런 차이를 점검한다. [BD-S4]

방문 채널 비중이 바뀐 현상과 학습은 원 단위·서빙은 천 원 단위를 쓰는 구현 오류는 대응이 다르다. 알림을 받으면 원천 변화·수집 오류·전처리 판본·업무 정책을 나누어 조사한다. 경보 하나만으로 모델의 품질이 떨어졌거나 원인이 밝혀졌다고 단정하지 않는다.

BD-D1: 100건이라는 총수는 같은데 구성은 바뀌었다

가상 기간 D0은 웹 90·창구 10, D1은 웹 50·창구 50이다. 각 기간의 전체는 100건이고 비중은 (0.9,0.1)과 (0.5,0.5)다. 대응 범주의 비중 차이의 최댓값은 max(0.4,0.4)=0.4다.

이 예에서는 사전에 정한 경보 기준 차이 > 0.3을 적용하여 조사 대상으로 표시한다. 임계값 0.3은 자체 예시이며 TFDV의 보편적인 권장값이 아니다. 분모가 0이면 비중과 차이가 정의되지 않으므로 무변화로 처리하지 않는다.

비중 변화는 관찰된 차이를 설명할 뿐 일반화 성능 하락의 측정이 아니다. 실제 정답이 아직 확정되지 않았다면 그 성능은 미확인으로 두고 입력 변화와 구별한다. 작은 표본의 변동을 어떻게 판단할지는 표본·기간·업무 영향과 함께 검토한다.

비정형 자료는 읽힌다는 것과 정답이 맞다는 것이 다르다

영상 파일이 열려도 대상이 프레임 밖에 있거나 흐리고, 텍스트가 파싱되어도 언어·중복·잘못된 라벨 문제가 남을 수 있다. 검사기는 파일의 유효성과 업무에서 필요한 신호·정답 품질을 같은 결과로 합치지 않는다.

가상 영상 묶음의 모든 파일이 정상적으로 읽혔지만 한 상품의 연속 프레임만 들어 있다면 제품 전체를 대표하지 못한다. 단순 파일 수가 늘어난 것과 서로 다른 업무 대상이 늘어난 것을 구별한다. 비정형 표현·평가의 상세 정의는 텍스트·영상 등 비정형 데이터마이닝에서 이어 확인한다.

품질 장부에 표본 단위·수집 범위·라벨 확인·제외 사유·판본을 함께 남기고 자동 검사가 못 보는 의미는 별도 검토 대상으로 둔다. 이 절은 그 독립 라벨 검토를 실제 수행했다고 주장하지 않는다.

수량을 맞춘 뒤 사유와 금액도 맞춘다

BD-E1의 수신 4개는 적합한 신규 사건 3개와 동일 내용 재전송 1개로 나뉜다. 그러나 실제 입력에는 형식 위반·충돌·마감 후 격리·미수신도 생길 수 있다. 각 단계의 ‘수신=수용+보류+거부’처럼 중복 없는 상태 분해를 먼저 정의하고 같은 집합으로 대조한다.

원천에서 아직 안 보낸 자료는 수신 분모 안에 존재하지 않는다. 따라서 수신 후 분해가 맞는다고 원천 전체의 완전성을 승인하지 않고, 원천별 전송 범위와 마감 대조를 별도로 연결한다.

중복 제거 전후 건수만이 아니라 영향 금액·키·기간도 대조한다. 오류를 많이 격리하여 수용률이 떨어진 것과 이전에 놓치던 오류를 발견한 것의 차이를 해석해야 개선의 방향을 잘못 잡지 않는다.

누가 멈추고 누가 정정할지를 결정한다

실시간 집계 담당은 잠정·정정 결과와 지연 상황을 표시하고, 원천 담당은 누락 범위·재전송·식별 근거를 확인한다. 데이터 관리 담당은 의미 판본과 보류를 정리하고, 업무 책임자는 미확인 자료로 허용할 의사결정 범위를 정한다. 역할 이름만 적고 실제 판단 기록을 비워 두지 않는다.

BD-E1의 종료 조건은 170이라는 숫자 하나가 아니다. 세 사건의 식별·금액·구간, 중복 1개와 정정 이유, 전달된 판본·수신자·미해결 예외까지 확인해야 한다. 원천 전체와의 대조를 못 했다면 ‘받은 자료에 대한 정정’이라고 범위를 제한한다.

목표는 늦은 자료를 모두 실패로 만들거나 모든 자료를 무조건 받는 것이 아니라, 사용 목적에 맞는 사실과 미확인을 유지하는 것이다.

자동 수집·검사·재처리가 각각 보장하지 않는 것

실행한 일실제로 확인할 수 있는 범위별도 근거가 필요한 것
수신 로그 수집받은 기록과 처리 시점원천 전체 사건의 존재
형식·분포 검사명시한 구조와 통계의 차이정답·인과·업무 효과
같은 판본으로 재처리정한 입력·규칙의 결과 재현원래 입력의 정확성
지연 입력 제외남은 입력의 진행 조건제외된 입력의 완전성

검사 통과를 한 문장으로 합치기보다 대상·판본·관찰·판정·남은 조건을 함께 적는다. 작은 자체 계산과 실제 분산 실행의 차이도 같은 방식으로 유지한다.

검토 보고서의 짧은 완성 예

W1의 수신 집합 BD-E1-v1은 네 행이다. 동일한 A:e1 한 건을 중복으로 구분하여 세 사건의 합계 170을 계산했다. 초기 잠정판 150과 차이 20은 늦은 e3 때문이며, 중복을 모두 합한 270은 정한 사건 규칙에 맞지 않는다. 두 원천의 진행은 느린 입력을 포함한 경계로 관찰하고, 제외·단절은 완전성 미확인으로 표시한다. 원천 대조와 정정 통지 기록이 없는 상태에서 전체 정산 완료를 승인하지 않는다.

위 문단은 수치·사유·책임·한계를 함께 적은 작성 예다. 실제 운영 보고서를 제출했거나 담당자가 승인한 기록은 아니다. 다음 분석기획 절에서는 이런 자료로 무엇을 결정할 수 있는지와 언제 과제를 보류할지를 연결한다.

공식 범위와 답안의 연결

빅데이터 품질은 기본 품질체계 위에서 사건 식별·발생과 도착의 시간·분산 원천 범위·의미 판본·분포 변화·정정 계보를 추가로 연결한다. 답안은 특성의 나열에 그치지 않고 수집부터 분석까지의 실패 위치와 책임·허용 사용·재측정을 제시한다. 본 절의 유한 사례는 실제 처리기·원천·모델의 품질 인증이 아니다.

4. 자체 10점 문제

빅데이터 품질에서 이벤트 시간·처리 시간·워터마크의 관계를 설명하고, 지연·중복·원천 단절을 구별하여 통제 방안을 제시하시오.

실제 기출이 아닌 자체 작성 문제다. 용어 설명과 서로 다른 실패 원인의 대응을 연결한다. 처리기 이름이나 용량만 나열하지 않는다.

두 시간·진행·정정 풀이 보기

10점 답안 목차

  1. 품질 판단의 범위
  2. 두 시간과 진행 경계
  3. 중복과 지연의 별도 원인
  4. 원천 범위와 정정 책임

10점 답안 도식

앞의 관찰 경로에서 사건·원천·시간을 고정하고 중복/지연/미수신을 구별→잠정 결과→대조·정정·판본·통지를 연결한다.

BD-E1 결과포함 집합과 원인
잠정 150e1·e2를 한 번씩 센 100+50
정정 170늦은 신규 e3의 20을 더한 세 사건
잘못된 270동일 e1 재전송 100까지 두 번 센 네 수신 행

워터마크의 진행, 원천 단절·미수신과 수신 후 상태는 각각 다른 확인이다.

도식의 각 선은 앞 본문에서 설명한 판단·증거의 연결이다.

10점 모범답안

1. 품질 판단의 범위

용도별 품질 기준을 유지하면서 대량·다양·고속 수집의 추가 위험을 단계별로 살핀다. 수신 후 검사가 통과해도 원천 전체가 들어왔는지는 별도로 확인한다.

2. 두 시간과 진행 경계

사건의 발생시각과 처리시각을 나누고 구간 경계를 고정한다. 워터마크는 규약에 따른 진행 정보이지 모든 원천 사건이 도착했다는 무조건적 인증이 아니다.

3. 중복과 지연의 별도 원인

BD-E1의 합계는 재전송을 한 번만 세면 잠정 150이고, 늦은 신규 사건을 반영하면 170이다. 네 수신을 모두 합한 270은 중복 효과를 포함하므로 정정과 중복 제거를 구별한다.

4. 원천 범위와 정정 책임

느린 입력을 평균으로 대신하지 않고 유휴 처리된 입력의 미확인을 표시한다. 허용 마감 뒤 자료의 격리·정정·통지와 재처리 책임을 남긴다.

5. 자체 25점 문제

여러 원천에서 연속 수집하는 거래로 시간 구간 보고서와 모델 입력을 만든다. 재전송·지연·유휴 원천·단위 변경·분포 변화가 발생할 수 있다. BD-E1의 150·170·270을 해석하고 원천부터 결과 사용까지 품질 관찰·통제·정정 방안을 설계하시오.

실제 기출이 아닌 자체 작성 문제다. 구간별 숫자를 실제 사건·판본에 대조하고, 자동 처리 결과를 원천 전체 정확성이나 모델 효과로 확대하지 않는다.

BD-E1의 원천부터 후속 사용까지 풀이 보기

25점 답안 목차

  1. 용도와 관찰 범위
  2. 식별과 시간 구간
  3. 집계와 지연 정정
  4. 원천 진행과 누락
  5. 의미와 분포 검사
  6. 책임과 종료 조건

25점 답안 도식

앞의 수집·사용·정정 경로를 25점 답안에 사용한다. 원천 범위에서 의미·식별·시간을 확인하고 수용/격리/거부 상태를 대사하여 집계·모델 입력으로 연결한다. 사용 제한·통지가 필요한 결과는 원인·정정·계보를 확인하고 같은 기준 재측정으로 되돌린다. 원천 범위의 미수신 확인도 다시 연결해야 한다.

도식의 각 선은 앞 본문에서 설명한 판단·증거의 연결이다.

25점 모범답안

1. 용도와 관찰 범위

알림·정산·모델 입력의 허용 지연과 확정 조건을 나눈다. 원천 가동·전송 범위, 수집시각, 형식·사건 식별·결과 판본을 연결하여 미수신과 수신 후 오류를 구별한다.

2. 식별과 시간 구간

원천과 사건 ID를 키로 정하고 동일 내용 재전송만 중복으로 처리한다. W1은 같은 시간대의 시작 포함·끝 제외 구간이며 다른 내용의 같은 키는 수정 규약 없이는 충돌로 보류한다.

3. 집계와 지연 정정

e1·e2의 잠정 결과는 150, 늦은 e3를 포함한 세 사건의 합계는 170, 재전송까지 모두 더하면 270이다. 결과 판본·포함 집합을 고정하고 명시한 마감과 그 이후의 격리·재처리·통지를 연결한다.

4. 원천 진행과 누락

A 12:10과 B 12:04의 공동 진행은 이 예에서 12:04다. B를 유휴 처리하여 제외하더라도 B 전체 사건의 부재를 증명하지 못하므로 포함 원천·미확인·재개 후 정정 조건을 보고한다.

5. 의미와 분포 검사

스키마 판본·통화·단위가 맞는지 확인하고 불명확한 입력을 임의 변환하지 않는다. BD-D1의 범주 비중 차이 최댓값 0.4는 자체 임계값 0.3을 넘지만 그것만으로 모델 성능 하락이나 원인을 확정하지 않는다.

6. 책임과 종료 조건

원천·처리·데이터·업무 담당의 확인을 나누고 사건별 값·판본·정정 사유와 후속 사용을 대조한다. 원천 전체 대조에 미확인 사항이 있거나 필요한 통지 근거를 확보하지 못했다면 정산·업무 승인을 제한하고, 재처리 결과와 원자료 정확성의 보장을 구분한다.

복습 경로. 150·170·270의 차이는 사건 집합과 원인, 느린 입력 제외의 한계는 BD-W1의 진행 경계, 같은 총수 100건의 구성 변화는 BD-D1의 비중에서 수치와 남은 미확인을 함께 되짚는다.

다시 읽을 핵심

큰 자료에서도 목적·분모·미확인을 지킨다. 사건 식별과 시간·진행·원천 범위를 구별하면 150에서 170으로 바뀐 정정과 270의 중복 오류가 다르게 보인다. 의미·분포·계보를 연결하고 늦은 자료가 바꾼 결과와 책임을 끝까지 추적한다.

출처와 검증의 경계

[BD-S1] NIST. NIST Big Data Interoperability Framework: Volume 1, Definitions. 판본: SP 1500-1r2 publication abstract. 발행일: 2019-10-21. 확인: 2026-09-06. 위치: Abstract; citation and publication metadata 원문: https://www.nist.gov/publications/nist-big-data-interoperability-framework-volume-1-definitions

[BD-S2] Apache Beam. Apache Beam Programming Guide. 판본: Named primary HTML passages observed 2026-09-06. 발행일: 원문에서 최초 발행일 미확정. 확인: 2026-09-06. 위치: 8.4 Watermarks and late data; 9 Triggers 원문: https://beam.apache.org/documentation/programming-guide/

[BD-S3] Apache Flink. Generating Watermarks. 판본: Named primary HTML passages observed 2026-09-06. 발행일: 원문에서 최초 발행일 미확정. 확인: 2026-09-06. 위치: Dealing With Idle Sources; Watermark alignment 원문: https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/datastream/event-time/generating_watermarks/

[BD-S4] TensorFlow. Get started with TensorFlow Data Validation. 판본: Named primary HTML passages observed 2026-09-06. 발행일: 원문에서 최초 발행일 미확정. 확인: 2026-09-06. 위치: Checking data skew and drift; schema validation 원문: https://www.tensorflow.org/tfx/data_validation/get_started?hl=en

주장의 정확한 원문 위치는 명시 입력에도 연결했다. 수치·대상·의사결정·문제·답안·도식은 집필자의 가상 사례이며 원문 실험이나 참가자 관찰의 재현이 아니다. 보존 원문을 공개 재배포하지 않으며 사람 기술·권리·독자 검수와 최종 발행 승인은 남아 있다.