Package com.ibm.fhir.bucket.api

Class BucketLoaderJob

java.lang.Object

com.ibm.fhir.bucket.api.BucketLoaderJob

public class BucketLoaderJob
extends Object

Represents an allocated job to load a bundle

Constructor Summary

Constructors

Constructor	Description
BucketLoaderJob(long resourceBundleLoadId, long resourceBundleId, String bucketName, String bucketPath, String objectName, long objectSize, FileType ft, int version)	Public constructor

Method Summary

Modifier and Type	Method	Description
void	addEntry()	Increment the number of operations inflight
void	fileProcessingComplete()	Called after the file has been read (but the job is not complete until the completedCount matches the itemCount
String	getBucketName()
int	getCompletedCount()	How many rows have been completed so far
int	getEntryCount()
int	getFailureCount()	How many rows have failed
FileType	getFileType()	Get the type of file this object represents
String	getObjectKey()	Get the reconstituted object key which is a concatenation of the bucketPath and the objectName, with some special treatment of objects in the root location because we can't have an empty path (in the database)
long	getObjectSize()
long	getProcessingEndTime()
long	getProcessingStartTime()
long	getResourceBundleId()
long	getResourceBundleLoadId()
int	getVersion()
void	operationComplete(boolean success)	Signal operation complete.
void	registerCallback(Consumer<BucketLoaderJob> cb)	Register a Consumer to call back when the job is done
void	setProcessingStartTime(long processingStartTime)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketLoaderJob

public BucketLoaderJob(long resourceBundleLoadId,
                       long resourceBundleId,
                       String bucketName,
                       String bucketPath,
                       String objectName,
                       long objectSize,
                       FileType ft,
                       int version)

Public constructor

Parameters:

resourceBundleLoadId -

resourceBundleId -

bucketName -

bucketPath -

objectName -

objectSize -

ft -

version -

Method Detail

registerCallback

public void registerCallback(Consumer<BucketLoaderJob> cb)

Register a Consumer to call back when the job is done

Parameters:

cb -

toString

public String toString()

Overrides:

toString in class Object

getBucketName

public String getBucketName()

getObjectKey

public String getObjectKey()

Get the reconstituted object key which is a concatenation of the bucketPath and the objectName, with some special treatment of objects in the root location because we can't have an empty path (in the database)

Returns:

getObjectSize

public long getObjectSize()

Returns:

the objectSize in bytes

getFileType

public FileType getFileType()

Get the type of file this object represents

Returns:

getResourceBundleId

public long getResourceBundleId()

Returns:

the resourceBundleId

addEntry

public void addEntry()

Increment the number of operations inflight

operationComplete

public void operationComplete(boolean success)

Signal operation complete.

fileProcessingComplete

public void fileProcessingComplete()

Called after the file has been read (but the job is not complete until the completedCount matches the itemCount

getFailureCount

public int getFailureCount()

How many rows have failed

Returns:

getCompletedCount

public int getCompletedCount()

How many rows have been completed so far

Returns:

getEntryCount

public int getEntryCount()

Returns:

the entryCount. This value is only meaningful after fileProcessingComplete(). If called before, the value may not representative of all the entries in the file

getResourceBundleLoadId

public long getResourceBundleLoadId()

Returns:

the resourceBundleLoadId

getVersion

public int getVersion()

Returns:

the version

getProcessingStartTime

public long getProcessingStartTime()

Returns:

the processingStartTime

setProcessingStartTime

public void setProcessingStartTime(long processingStartTime)

Parameters:

processingStartTime - the processingStartTime to set

getProcessingEndTime

public long getProcessingEndTime()

Returns:

the processingEndTime