DerbyObserver, StreamContainerHandlefinal 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 StreamContainerHandleprop - Property list to fill in.StandardException - Standard exception policy.StreamContainerHandle.getContainerProperties(java.util.Properties)public boolean fetchNext(DataValueDescriptor[] row) throws StandardException
fetchNext in interface StreamContainerHandlerow - 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 StreamContainerHandleStandardException - Standard exception policy.StreamContainerHandle.close()public void removeContainer()
throws StandardException
removeContainer in interface StreamContainerHandleStandardException - Standard Derby error policyStreamContainerHandle.removeContainer()public ContainerKey getId()
getId in interface StreamContainerHandlepublic void update(DerbyObservable obj, java.lang.Object arg)
update in interface DerbyObserverobj - 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.ObjectApache Derby V10.14 Internals - Copyright © 2004,2018 The Apache Software Foundation. All Rights Reserved.