일괄처리 데이터 스트림

일괄처리 데이터 스트림(BDS)은 일괄처리 단계에서 처리되는 데이터 스트림의 요약을 제공하는 Java™ 오브젝트입니다. 일괄처리 단계는 연관된 하나 이상의 BDS 오브젝트를 포함할 수 있습니다. 눈금 엔드포인트는 런타임 시에 사용 가능한 일괄처리 단계와 BDS를 연관시킵니다. 눈금 엔드포인트는 일괄처리별 콜백을 호출하여 BDS의 라이프사이클도 관리합니다.

BDS 오브젝트는 com.ibm.websphere.batch.BatchDataStream 인터페이스를 구현합니다. 이 인터페이스는 서버에 독립적입니다. 구현 오브젝트는 모든 유형의 데이터 소스(예: 파일 및 데이터베이스)에서 데이터를 검색할 수 있습니다. BatchDataStream 인터페이스의 콜백 메소드를 사용하여 눈금 엔드포인트는 런타임 시에 BDS를 관리할 수 있습니다. BDS의 주요 기능 중 하나는 스트림에서의 현재 위치를 눈금 엔드포인트에 전달하는 기능과 자체를 데이터 스트림의 지정 위치로 이동하는 기능입니다. 이 기능으로 인해 눈금 엔드포인트는 일괄처리 단계에서 처리한 데이터 양을 기록(눈금 엔드포인트 데이터베이스에)할 수 있습니다. 이 정보는 모든 체크포인트에서 기록됩니다. 따라서, 눈금 엔드포인트는 작업이 복구 가능한 형식으로 취소 또는 실패하는 경우 데이터 스트림의 기록된 위치에서 일괄처리 작업을 다시 시작할 수 있습니다.

다음은 BatchDataStream 인터페이스에 대해 존재하는 기본 메소드를 나열합니다. 추가 정보는 BatchDataStream 인터페이스에 대한 API를 참조하십시오.

void open()
BDS를 열기 위해 눈금 엔드포인트에서 호출
void close()
BDS를 닫기 위해 눈금 엔드포인트에서 호출
void initialize(String ilogicalname, String ijobstepid)
BDS를 초기화하고 해당하는 원래 이름과 일괄처리 단계 ID를 인지시키기 위해 눈금 엔드포인트에서 호출
String externalizeCheckpointInformation()
BDS의 현재 커서를 기록하기 위해 체크포인트 전에 눈금 엔드포인트에서 호출
void internalizeCheckpointInformation(String chkpointInfo()
이전에 기록된 커서 chkpointInfo를 BDS에 통지하기 위해 눈금 엔드포인트에서 호출. 일반적으로 positionAtCurrentCheckpoint는 BDS를 이 커서로 이동하기 위해 이 호출 다음에 호출됩니다.
void positionAtCurrentCheckpoint()
internalizeCheckpointInformation 호출을 통해 전달되는 chkpointInfo로 표시되는 커서로 BDS를 이동하기 위해 internalizeCheckpointInformation 호출 후에 눈금 엔드포인트에서 호출

BatchDataStream 인터페이스는 데이터를 검색하거나 작성하기 위한 메소드를 가지고 있지 않습니다. 인터페이스에는 일괄처리 단계에서 BDS 오브젝트를 읽거나 BDS 오브젝트에 쓰기 위해 호출하는 인터페이스에 정의된 getNextRecord 및 putNextRecord 메소드가 없습니다. 일괄처리 단계와 BDS 오브젝트 사이에서 데이터를 전달하는 메소드가 BDS 오브젝트를 구현해야 합니다. 일괄처리 데이터 스트림을 구현하는 방법의 예제를 보려면 이 제품에서 지원하는 일괄처리 샘플을 검토하십시오.

트랜잭션 환경
BDS 오브젝트의 모든 메소드는 글로벌 트랜잭션 환경에서 호출됩니다. 트랜잭션은 BDS 오브젝트가 아닌 눈금 엔드포인트에서 소유하기 때문에 BDS 오브젝트에 대한 연속 메소드 호출이 동일한 트랜잭션에서 발생한다고 보장할 수 없습니다.

주제 유형을 표시하는 아이콘 개념 주제



시간소인 아이콘 마지막 업데이트 날짜: last_date
http://www14.software.ibm.com/webapp/wsbroker/redirect?version=cord&product=was-nd-mp&topic=cgrid_xdbatchds
파일 이름:cgrid_xdbatchds.html