DerbyObserver
, StreamContainerHandle
final class StreamFileContainerHandle extends java.lang.Object implements StreamContainerHandle, DerbyObserver
This class is an Observer to observe RawTransactions
MT - Mutable - Immutable identity - Thread Aware
Modifier and Type | Field | Description |
---|---|---|
protected boolean |
active |
Is this StreamContainerHandle active.
|
protected StreamFileContainer |
container |
The actual container we are accessing.
|
private boolean |
hold |
Whether this container should be held open across commit.
|
protected ContainerKey |
identity |
Container identifier
MT - Immutable |
private UUID |
rawStoreId |
Raw Store identifier
MT - Immutable |
protected RawTransaction |
xact |
our transaction.
|
TEMPORARY_SEGMENT
Constructor | Description |
---|---|
StreamFileContainerHandle(UUID rawStoreId,
RawTransaction xact,
ContainerKey identity,
boolean hold) |
|
StreamFileContainerHandle(UUID rawStoreId,
RawTransaction xact,
StreamFileContainer container,
boolean hold) |
Modifier and Type | Method | Description |
---|---|---|
void |
close() |
Close me.
|
boolean |
fetchNext(DataValueDescriptor[] row) |
fetch a row from the container.
|
void |
getContainerProperties(java.util.Properties prop) |
Request the system properties associated with a container.
|
ContainerKey |
getId() |
get the container key for the stream container
|
RawTransaction |
getTransaction() |
Return the RawTransaction this object was opened in.
|
void |
removeContainer() |
remove the stream container
|
java.lang.String |
toString() |
|
void |
update(DerbyObservable obj,
java.lang.Object arg) |
Called when the transaction is about to complete.
|
boolean |
useContainer() |
Attach me to a container.
|
private final UUID rawStoreId
protected final ContainerKey identity
protected boolean active
protected StreamFileContainer container
protected RawTransaction xact
private boolean hold
public StreamFileContainerHandle(UUID rawStoreId, RawTransaction xact, ContainerKey identity, boolean hold)
public StreamFileContainerHandle(UUID rawStoreId, RawTransaction xact, StreamFileContainer container, boolean hold)
public void getContainerProperties(java.util.Properties prop) throws StandardException
getContainerProperties
in interface StreamContainerHandle
prop
- Property list to fill in.StandardException
- Standard exception policy.StreamContainerHandle.getContainerProperties(java.util.Properties)
public boolean fetchNext(DataValueDescriptor[] row) throws StandardException
fetchNext
in interface StreamContainerHandle
row
- Row to be filled in with information from the record.StandardException
- Standard exception policy.public void close()
StreamContainerHandle
ref.close(); ref = null;
close
in interface StreamContainerHandle
StandardException
- Standard exception policy.StreamContainerHandle.close()
public void removeContainer() throws StandardException
removeContainer
in interface StreamContainerHandle
StandardException
- Standard Derby error policyStreamContainerHandle.removeContainer()
public ContainerKey getId()
getId
in interface StreamContainerHandle
public void update(DerbyObservable obj, java.lang.Object arg)
update
in interface DerbyObserver
obj
- The object which is being observedarg
- Extra information being passed to the callbackDerbyObserver.update(org.apache.derby.iapi.services.monitor.DerbyObservable, java.lang.Object)
public boolean useContainer() throws StandardException
StandardException
- Standard Derby error policypublic final RawTransaction getTransaction()
public java.lang.String toString()
toString
in class java.lang.Object
Apache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.