Package com.ibm.fhir.bulkdata.jbatch.load.data

Class ImportCheckPointData

java.lang.Object

com.ibm.fhir.bulkdata.jbatch.load.data.ImportCheckPointData

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

ImportTransientUserData

public class ImportCheckPointData
extends Object
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ImportCheckPointData.Builder

Field Summary

Fields

Modifier and Type	Field	Description
protected long	currentBytes
protected List<com.ibm.cloud.objectstorage.services.s3.model.PartETag>	dataPacksForFailureOperationOutcomes
protected List<com.ibm.cloud.objectstorage.services.s3.model.PartETag>	dataPacksForOperationOutcomes
protected long	importFileSize
protected String	importPartitionResourceType
protected String	importPartitionWorkitem
protected long	inFlyRateBeginMilliSeconds
protected String	matrixWorkItem
protected long	numOfImportedResources
protected long	numOfImportFailures
protected long	numOfParseFailures
protected long	numOfProcessedResources
protected long	numOfSkipped
protected long	numOfToBeImported
protected int	partNumForFailureOperationOutcomes
protected int	partNumForOperationOutcomes
protected long	totalReadMilliSeconds
protected long	totalValidationMilliSeconds
protected long	totalWriteMilliSeconds
protected String	uniqueIDForImportFailureOperationOutcomes
protected String	uniqueIDForImportOperationOutcomes
protected String	uploadIdForFailureOperationOutcomes
protected String	uploadIdForOperationOutcomes

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ImportCheckPointData()

Method Summary

Modifier and Type	Method	Description
void	addToNumOfImportedResources(long numOfImportedResources)
void	addToNumOfImportFailures(long numOfImportFailures)
void	addToNumOfParseFailures(long numOfParseFailures)
void	addToNumOfProcessedResources(long numOfProcessedResources)
void	addToNumOfSkippedResources(long skipped)
void	addTotalValidationMilliSeconds(long validationMilliSeconds)
void	addToTotalReadMilliSeconds(long totalReadMilliSeconds)
void	addToTotalWriteMilliSeconds(long totalWriteMilliSeconds)
static ImportCheckPointData	fromImportTransientUserData(ImportTransientUserData userData)
long	getCurrentBytes()
List<com.ibm.cloud.objectstorage.services.s3.model.PartETag>	getDataPacksForFailureOperationOutcomes()
List<com.ibm.cloud.objectstorage.services.s3.model.PartETag>	getDataPacksForOperationOutcomes()
long	getImportFileSize()
String	getImportPartitionResourceType()
String	getImportPartitionWorkitem()
long	getInFlyRateBeginMilliSeconds()
String	getMatrixWorkItem()
long	getNumOfImportedResources()
long	getNumOfImportFailures()
long	getNumOfParseFailures()
long	getNumOfProcessedResources()
long	getNumOfSkippedResources()
long	getNumOfToBeImported()
int	getPartNumForFailureOperationOutcomes()
int	getPartNumForOperationOutcomes()
long	getTotalReadMilliSeconds()
long	getTotalValidationMilliSeconds()
long	getTotalWriteMilliSeconds()
String	getUniqueIDForImportFailureOperationOutcomes()
String	getUniqueIDForImportOperationOutcomes()
String	getUploadIdForFailureOperationOutcomes()
String	getUploadIdForOperationOutcomes()
void	setCurrentBytes(long currentBytes)
void	setImportFileSize(long importFileSize)
void	setInFlyRateBeginMilliSeconds(long inFlyRateBeginMilliSeconds)
void	setMatrixWorkItem(String matrixWorkItem)
void	setNumOfImportedResources(long numOfImportedResources)
void	setNumOfImportFailures(long numOfImportFailures)
void	setNumOfParseFailures(long numOfParseFailures)
void	setNumOfProcessedResources(long numOfProcessedResources)
void	setNumOfSkippedResources(long skipped)
void	setNumOfToBeImported(long numOfToBeImported)
void	setPartNumForFailureOperationOutcomes(int partNumForFailureOperationOutcomes)
void	setPartNumForOperationOutcomes(int partNumForOperationOutcomes)
void	setTotalReadMilliSeconds(long totalReadMilliSeconds)
void	setTotalValidationMilliSeconds(long totalValidationMilliSeconds)
void	setTotalWriteMilliSeconds(long totalWriteMilliSeconds)
void	setUploadIdForFailureOperationOutcomes(String uploadIdForFailureOperationOutcomes)
void	setUploadIdForOperationOutcomes(String uploadIdForOperationOutcomes)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

importPartitionWorkitem

protected String importPartitionWorkitem

matrixWorkItem

protected String matrixWorkItem

numOfProcessedResources

protected long numOfProcessedResources

numOfImportedResources

protected long numOfImportedResources

numOfImportFailures

protected long numOfImportFailures

numOfSkipped

protected long numOfSkipped

totalReadMilliSeconds

protected long totalReadMilliSeconds

totalWriteMilliSeconds

protected long totalWriteMilliSeconds

totalValidationMilliSeconds

protected long totalValidationMilliSeconds

importFileSize

protected long importFileSize

currentBytes

protected long currentBytes

inFlyRateBeginMilliSeconds

protected long inFlyRateBeginMilliSeconds

numOfToBeImported

protected long numOfToBeImported

numOfParseFailures

protected long numOfParseFailures

importPartitionResourceType

protected String importPartitionResourceType

uniqueIDForImportOperationOutcomes

protected String uniqueIDForImportOperationOutcomes

partNumForOperationOutcomes

protected int partNumForOperationOutcomes

uploadIdForOperationOutcomes

protected String uploadIdForOperationOutcomes

dataPacksForOperationOutcomes

protected List<com.ibm.cloud.objectstorage.services.s3.model.PartETag> dataPacksForOperationOutcomes

uniqueIDForImportFailureOperationOutcomes

protected String uniqueIDForImportFailureOperationOutcomes

partNumForFailureOperationOutcomes

protected int partNumForFailureOperationOutcomes

uploadIdForFailureOperationOutcomes

protected String uploadIdForFailureOperationOutcomes

dataPacksForFailureOperationOutcomes

protected List<com.ibm.cloud.objectstorage.services.s3.model.PartETag> dataPacksForFailureOperationOutcomes

Constructor Detail

ImportCheckPointData

protected ImportCheckPointData()

Method Detail

getImportPartitionWorkitem

public String getImportPartitionWorkitem()

getNumOfProcessedResources

public long getNumOfProcessedResources()

setNumOfProcessedResources

public void setNumOfProcessedResources(long numOfProcessedResources)

addToNumOfProcessedResources

public void addToNumOfProcessedResources(long numOfProcessedResources)

getNumOfImportedResources

public long getNumOfImportedResources()

setNumOfImportedResources

public void setNumOfImportedResources(long numOfImportedResources)

addToNumOfImportedResources

public void addToNumOfImportedResources(long numOfImportedResources)

getNumOfSkippedResources

public long getNumOfSkippedResources()

setNumOfSkippedResources

public void setNumOfSkippedResources(long skipped)

addToNumOfSkippedResources

public void addToNumOfSkippedResources(long skipped)

getNumOfImportFailures

public long getNumOfImportFailures()

setNumOfImportFailures

public void setNumOfImportFailures(long numOfImportFailures)

addToNumOfImportFailures

public void addToNumOfImportFailures(long numOfImportFailures)

getNumOfToBeImported

public long getNumOfToBeImported()

setNumOfToBeImported

public void setNumOfToBeImported(long numOfToBeImported)

getImportPartitionResourceType

public String getImportPartitionResourceType()

getCurrentBytes

public long getCurrentBytes()

setCurrentBytes

public void setCurrentBytes(long currentBytes)

fromImportTransientUserData

public static ImportCheckPointData fromImportTransientUserData(ImportTransientUserData userData)

getUniqueIDForImportOperationOutcomes

public String getUniqueIDForImportOperationOutcomes()

getUniqueIDForImportFailureOperationOutcomes

public String getUniqueIDForImportFailureOperationOutcomes()

getPartNumForOperationOutcomes

public int getPartNumForOperationOutcomes()

setPartNumForOperationOutcomes

public void setPartNumForOperationOutcomes(int partNumForOperationOutcomes)

getUploadIdForOperationOutcomes

public String getUploadIdForOperationOutcomes()

setUploadIdForOperationOutcomes

public void setUploadIdForOperationOutcomes(String uploadIdForOperationOutcomes)

getDataPacksForOperationOutcomes

public List<com.ibm.cloud.objectstorage.services.s3.model.PartETag> getDataPacksForOperationOutcomes()

getPartNumForFailureOperationOutcomes

public int getPartNumForFailureOperationOutcomes()

setPartNumForFailureOperationOutcomes

public void setPartNumForFailureOperationOutcomes(int partNumForFailureOperationOutcomes)

getUploadIdForFailureOperationOutcomes

public String getUploadIdForFailureOperationOutcomes()

setUploadIdForFailureOperationOutcomes

public void setUploadIdForFailureOperationOutcomes(String uploadIdForFailureOperationOutcomes)

getDataPacksForFailureOperationOutcomes

public List<com.ibm.cloud.objectstorage.services.s3.model.PartETag> getDataPacksForFailureOperationOutcomes()

getNumOfParseFailures

public long getNumOfParseFailures()

setNumOfParseFailures

public void setNumOfParseFailures(long numOfParseFailures)

addToNumOfParseFailures

public void addToNumOfParseFailures(long numOfParseFailures)

getTotalReadMilliSeconds

public long getTotalReadMilliSeconds()

setTotalReadMilliSeconds

public void setTotalReadMilliSeconds(long totalReadMilliSeconds)

addToTotalReadMilliSeconds

public void addToTotalReadMilliSeconds(long totalReadMilliSeconds)

getTotalWriteMilliSeconds

public long getTotalWriteMilliSeconds()

setTotalWriteMilliSeconds

public void setTotalWriteMilliSeconds(long totalWriteMilliSeconds)

addToTotalWriteMilliSeconds

public void addToTotalWriteMilliSeconds(long totalWriteMilliSeconds)

getTotalValidationMilliSeconds

public long getTotalValidationMilliSeconds()

setTotalValidationMilliSeconds

public void setTotalValidationMilliSeconds(long totalValidationMilliSeconds)

addTotalValidationMilliSeconds

public void addTotalValidationMilliSeconds(long validationMilliSeconds)

getImportFileSize

public long getImportFileSize()

setImportFileSize

public void setImportFileSize(long importFileSize)

getInFlyRateBeginMilliSeconds

public long getInFlyRateBeginMilliSeconds()

setInFlyRateBeginMilliSeconds

public void setInFlyRateBeginMilliSeconds(long inFlyRateBeginMilliSeconds)

setMatrixWorkItem

public void setMatrixWorkItem(String matrixWorkItem)

getMatrixWorkItem

public String getMatrixWorkItem()

toString

public String toString()

Overrides:

toString in class Object