orgcdc.core

Class CDCDecompressor

java.lang.Object

orgcdc.core.CDCDecompressor

@Component
public class CDCDecompressor
extends java.lang.Object

압축된 데이터를 복원(decompress)하는 기능을 제공하는 컴포넌트 클래스이다.

이 클래스는 특정 평가 ID와 청크 타입에 따라 압축된 데이터를 조회하고 복원하는 역할을 한다. 압축된 데이터를 복원하여 원래의 데이터 형식으로 변환하는 여러 메서드를 포함하고 있다.

사용자는 decompress(String, short) 메서드를 통해 사이클 단위로, decompress(String, short, short) 메서드를 통해 Step 단위로 데이터를 복원할 수 있다. 또한, decompress(String) 메서드를 통해 평가 ID에 해당하는 모든 데이터를 복원할 수 있다.

주요 기능:

• 압축된 데이터 복원
• 평가 ID를 기반으로 데이터 조회
• 청크 타입 확인
• 데이터베이스와의 상호작용

Author:

JuJonghun

See Also:

CDCCompressor, ChunkType, CompressedChunkData

Constructor Summary

Constructors

Constructor and Description
CDCDecompressor(javax.sql.DataSource dataSource) 주어진 Datasource를 사용하여 CDCDecompressor 객체를 생성한다.

Method Summary

Modifier and Type	Method and Description
java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	decompress(java.lang.String evaluationId) 주어진 평가 ID에 해당하는 모든 데이터를 복원한다.
java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	decompress(java.lang.String evaluationId, short cycle) 주어진 평가 ID, cycle을 기반으로 데이터를 복원한다.
java.util.List<java.util.Map<java.lang.String,java.lang.Object>>	decompress(java.lang.String evaluationId, short cycle, short step) 주어진 평가 ID, cycle, Step을 기반으로 데이터를 복원한다.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CDCDecompressor

public CDCDecompressor(@Autowired @Qualifier(value="cdcDataSource")
                       javax.sql.DataSource dataSource)

주어진 Datasource를 사용하여 CDCDecompressor 객체를 생성한다.

Parameters:

dataSource - 데이터베이스 연결을 위한 데이터 소스

Method Detail

decompress

public java.util.List<java.util.Map<java.lang.String,java.lang.Object>> decompress(java.lang.String evaluationId)

주어진 평가 ID에 해당하는 모든 데이터를 복원한다.

평가 ID에 해당하는 모든 Cycle에 대해 데이터를 조회하고 복원하며, 복원된 데이터를 하나의 리스트로 병합하여 반환한다.

Parameters:

evaluationId - 평가 ID

Returns:

복원된 모든 데이터의 리스트

decompress

public java.util.List<java.util.Map<java.lang.String,java.lang.Object>> decompress(java.lang.String evaluationId,
                                                                                   short cycle)

주어진 평가 ID, cycle을 기반으로 데이터를 복원한다.

압축된 데이터베이스에서 해당 평가 ID와 사이클에 대한 데이터를 조회하고, 압축된 데이터를 복원하여 원래의 형식으로 변환한다.

Parameters:

evaluationId - 평가 ID

cycle - 복원할 데이터의 사이클

Returns:

복원된 데이터의 리스트

decompress

public java.util.List<java.util.Map<java.lang.String,java.lang.Object>> decompress(java.lang.String evaluationId,
                                                                                   short cycle,
                                                                                   short step)

주어진 평가 ID, cycle, Step을 기반으로 데이터를 복원한다.

데이터베이스에서 해당 평가 ID, Cycle, Step에 대한 데이터를 조회하고, 압축된 데이터를 복원하여 원래의 형식으로 변환한다.

Parameters:

evaluationId - 평가 ID

cycle - 복원할 데이터의 Cycle

step - 복원할 데이터의 Step

Returns:

복원된 데이터의 리스트