|
SMILA (incubation) API documentation | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.eclipse.smila.bulkbuilder.outputs.BulkOutput
public abstract class BulkOutput
base class. for bulk output.
Field Summary | |
---|---|
protected Output |
_bulk
bulk writer. |
Constructor Summary | |
---|---|
BulkOutput(java.lang.String jobName,
java.lang.String bulkId,
BulkType bulkType)
create instance. |
Method Summary | |
---|---|
abstract void |
addRecord(Record record)
put a record to the bulk. |
void |
commit()
committing the output. |
Output |
getBulk()
|
long |
getBulkSizeLimit()
|
long |
getBulkStartTime()
|
BulkType |
getBulkType()
|
abstract long |
getBytesWritten()
get the number of bytes written. |
long |
getCommitTimeout()
|
java.lang.String |
getCurrentBulkId()
|
java.lang.String |
getJobName()
|
long |
getLastModificationTime()
|
IODataObject |
getOutput()
access output object. |
boolean |
hasGrownBeyondLimit()
|
boolean |
isTimedOut()
|
void |
setBulk(Output bulk)
|
void |
setBulkSizeLimit(long bulkSizeLimit)
Set the bulk size limit (in bytes). |
void |
setCommitTimeout(long commitTimeout)
|
void |
setCurrentBulkId(java.lang.String currentBulkId)
|
void |
setLastModificationTime(long lastModificationTime)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected Output _bulk
Constructor Detail |
---|
public BulkOutput(java.lang.String jobName, java.lang.String bulkId, BulkType bulkType)
Method Detail |
---|
public java.lang.String getJobName()
public java.lang.String getCurrentBulkId()
public void setCurrentBulkId(java.lang.String currentBulkId)
currentBulkId
- the current bulk id.public BulkType getBulkType()
public Output getBulk()
public void setBulk(Output bulk)
bulk
- output bulk to set.public long getBulkStartTime()
public long getLastModificationTime()
public void setLastModificationTime(long lastModificationTime)
lastModificationTime
- the last modification time to set.public long getCommitTimeout()
public boolean isTimedOut()
true
if the bulk has timed out (if a timeout is set).public void setCommitTimeout(long commitTimeout)
commitTimeout
- the commit timeout (in ms) to set.public void setBulkSizeLimit(long bulkSizeLimit)
bulkSizeLimit
- public long getBulkSizeLimit()
public boolean hasGrownBeyondLimit()
true
if the bulk has grown beyond its limit (if any).public void commit() throws BulkbuilderException
java.io.IOException
ObjectStoreException
BulkbuilderException
public IODataObject getOutput()
public abstract void addRecord(Record record) throws BulkbuilderException
BulkbuilderException
public abstract long getBytesWritten()
|
SMILA (incubation) API documentation | ||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |