| Modifier and Type | Class and Description |
|---|---|
| public static class | |
| public static class | |
| private class | |
| private static class |
| Modifier and Type | Field and Description |
|---|---|
| private final ThreadPoolExecutor | |
| private final Database | |
| private final MVMap | lobMap
The lob metadata map. |
| pack-priv final MVStore | |
| private final AtomicLong | |
| private final Queue | |
| private final MVMap | refMap
The reference map. |
| private final StreamStore | |
| private final MVMap | tempLobMap
The lob metadata map for temporary lobs. |
| private static final boolean |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| private void | |
| public void | close()
Overrides default org. Close LobStorage and release all resources |
| public ValueLob | copyLob(ValueLob
the old lob old, int the new table id tableId)Implements org. Copy a lob. |
| public ValueBlob | createBlob(InputStream
the input stream in, long the maximum length (-1 if not known) maxLength)Implements org. Create a BLOB object. |
| private ValueBlob | |
| public ValueClob | createClob(Reader
the reader reader, long the maximum length (-1 if not known) maxLength)Implements org. Create a CLOB object. |
| private void | |
| private long | |
| public InputStream | getInputStream(long
the lob id lobId, long the number of bytes to read, or -1 if not known byteCount)Implements org. Get the input stream for the given lob, only called on server side of a TCP connection. |
| public InputStream | getInputStream(long
the lob id lobId, int the able id tableId, long the number of bytes to read, or -1 if not known byteCount)Implements org. Get the input stream for the given lob |
| public boolean | isReadOnly()
Implements org. Whether the storage is read-only |
| private static boolean | |
| private boolean | |
| public static MVMap | Returns: MVMap instancecontaining map txStore)Open map used to store LOB data |
| public static MVMap | Returns: MVMap instancecontaining map txStore)Open map used to store LOB metadata |
| public void | removeAllForTable(int
the table id tableId)Implements org. Remove all LOBs for this table. |
| public void | removeLob(ValueLob
the lob lob)Implements org. Delete a LOB (from the database, if it is stored there). |
| private void | |
| private static void |
| cleanupExecutor | back to summary |
|---|---|
| private final ThreadPoolExecutor cleanupExecutor | |
| database | back to summary |
|---|---|
| private final Database database | |
| lobMap | back to summary |
|---|---|
| private final MVMap<Long, LobStorageMap. The lob metadata map. It contains the mapping from the lob id (which is a long) to the blob metadata, including stream store id (which is a byte array). | |
| mvStore | back to summary |
|---|---|
| pack-priv final MVStore mvStore | |
| nextLobId | back to summary |
|---|---|
| private final AtomicLong nextLobId | |
| pendingLobRemovals | back to summary |
|---|---|
| private final Queue<LobStorageMap. | |
| refMap | back to summary |
|---|---|
| private final MVMap<LobStorageMap. The reference map. It is used to remove data from the stream store: if no more entries for the given streamStoreId exist, the data is removed from the stream store. | |
| streamStore | back to summary |
|---|---|
| private final StreamStore streamStore | |
| tempLobMap | back to summary |
|---|---|
| private final MVMap<Long, byte[]> tempLobMap The lob metadata map for temporary lobs. It contains the mapping from the lob id (which is a long) to the stream store id (which is a byte array). Key: lobId (long) Value: streamStoreId (byte[]) | |
| TRACE | back to summary |
|---|---|
| private static final boolean TRACE | |
| LobStorageMap | back to summary |
|---|---|
| public LobStorageMap(Database database) | |
| cleanup | back to summary |
|---|---|
| private void cleanup(long oldestVersionToKeep) | |
| close | back to summary |
|---|---|
| public void close() Overrides default org. Doc from org. Close LobStorage and release all resources
| |
| copyLob | back to summary |
|---|---|
| public ValueLob copyLob(ValueLob old, int tableId) Implements org. Doc from org. Copy a lob. | |
| createBlob | back to summary |
|---|---|
| public ValueBlob createBlob(InputStream in, long maxLength) Implements org. Doc from org. Create a BLOB object.
| |
| createBlob | back to summary |
|---|---|
| private ValueBlob createBlob(InputStream in) throws IOException | |
| createClob | back to summary |
|---|---|
| public ValueClob createClob(Reader reader, long maxLength) Implements org. Doc from org. Create a CLOB object. | |
| doRemoveLob | back to summary |
|---|---|
| private void doRemoveLob(int tableId, long lobId) | |
| generateLobId | back to summary |
|---|---|
| private long generateLobId() | |
| getInputStream | back to summary |
|---|---|
| public InputStream getInputStream(long lobId, long byteCount) throws IOException Implements org. Doc from org. Get the input stream for the given lob, only called on server side of a TCP connection.
| |
| getInputStream | back to summary |
|---|---|
| public InputStream getInputStream(long lobId, int tableId, long byteCount) throws IOException Implements org. Doc from org. Get the input stream for the given lob
| |
| isReadOnly | back to summary |
|---|---|
| public boolean isReadOnly() Implements org. Doc from org. Whether the storage is read-only
| |
| isTemporaryLob | back to summary |
|---|---|
| private static boolean isTemporaryLob(int tableId) | |
| needCleanup | back to summary |
|---|---|
| private boolean needCleanup() | |
| openLobDataMap | back to summary |
|---|---|
| public static MVMap Open map used to store LOB data
| |
| openLobMap | back to summary |
|---|---|
| public static MVMap Open map used to store LOB metadata
| |
| removeAllForTable | back to summary |
|---|---|
| public void removeAllForTable(int tableId) Implements org. Doc from org. Remove all LOBs for this table.
| |
| removeLob | back to summary |
|---|---|
| public void removeLob(ValueLob lob) Implements org. Doc from org. Delete a LOB (from the database, if it is stored there). | |
| requestLobRemoval | back to summary |
|---|---|
| private void requestLobRemoval(int tableId, long lobId) | |
| trace | back to summary |
|---|---|
| private static void trace(String op) | |
| Modifier and Type | Class and Description |
|---|---|
| public static class |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final long | |
| pack-priv final long | |
| public final byte[] | streamStoreId
Stream identifier. |
| pack-priv final int |
| Access | Constructor and Description |
|---|---|
| public |
| byteCount | back to summary |
|---|---|
| pack-priv final long byteCount | |
| hash | back to summary |
|---|---|
| pack-priv final long hash | |
| streamStoreId | back to summary |
|---|---|
| public final byte[] streamStoreId Stream identifier. It is used as a key in LOB data map. | |
| tableId | back to summary |
|---|---|
| pack-priv final int tableId | |
| BlobMeta | back to summary |
|---|---|
| public BlobMeta(byte[] streamStoreId, int tableId, long byteCount, long hash) | |
| Modifier and Type | Field and Description |
|---|---|
| public static final LobStorageMap. |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public LobStorageMap. | createStorage(int
number of values to hold size)Implements org. Create storage object of array type to hold values |
| public int | getMemory(LobStorageMap.
the object blobMetaImplements abstract org. Implements org. Calculates the amount of used memory in bytes. |
| public LobStorageMap. | read(ByteBuffer
the source buffer buff)Implements abstract org. Implements org. Read an object. |
| public void | write(WriteBuffer
the target buffer buff, LobStorageMap.the value blobMetaImplements abstract org. Implements org. Write an object. |
| INSTANCE | back to summary |
|---|---|
| public static final LobStorageMap. | |
| Type | back to summary |
|---|---|
| private Type() | |
| createStorage | back to summary |
|---|---|
| public LobStorageMap. Implements org. Doc from org. Create storage object of array type to hold values
| |
| getMemory | back to summary |
|---|---|
| public int getMemory(LobStorageMap. Implements abstract org. Implements org. Doc from org. Calculates the amount of used memory in bytes.
| |
| read | back to summary |
|---|---|
| public LobStorageMap. Implements abstract org. Implements org. Doc from org. Read an object.
| |
| write | back to summary |
|---|---|
| public void write(WriteBuffer buff, LobStorageMap. Implements abstract org. Implements org. Doc from org. Write an object.
| |
| Modifier and Type | Class and Description |
|---|---|
| public static class |
| Modifier and Type | Field and Description |
|---|---|
| public final long | |
| public final byte[] |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public int | compareTo(LobStorageMap.
the object to be compared. otherImplements java. Compares this object with the specified object for order. |
| lobId | back to summary |
|---|---|
| public final long lobId | |
| streamStoreId | back to summary |
|---|---|
| public final byte[] streamStoreId | |
| BlobReference | back to summary |
|---|---|
| public BlobReference(byte[] streamStoreId, long lobId) | |
| compareTo | back to summary |
|---|---|
| public int compareTo(LobStorageMap. Implements java. Doc from java. Compares this object with the specified object for order. Returns a negative integer, zero, or a positive integer as this object is less than, equal to, or greater than the specified object. The implementor must ensure The implementor must also ensure that the relation is transitive:
Finally, the implementor must ensure that
| |
| Modifier and Type | Field and Description |
|---|---|
| public static final LobStorageMap. |
| Access | Constructor and Description |
|---|---|
| private |
| INSTANCE | back to summary |
|---|---|
| public static final LobStorageMap. | |
| Type | back to summary |
|---|---|
| private Type() | |
| compare | back to summary |
|---|---|
| public int compare(LobStorageMap. Overrides org. Implements org. Doc from org. Compare two keys.
| |
| createStorage | back to summary |
|---|---|
| public LobStorageMap. Implements org. Doc from org. Create storage object of array type to hold values
| |
| getMemory | back to summary |
|---|---|
| public int getMemory(LobStorageMap. Implements abstract org. Implements org. Doc from org. Calculates the amount of used memory in bytes.
| |
| read | back to summary |
|---|---|
| public LobStorageMap. Implements abstract org. Implements org. Doc from org. Read an object.
| |
| write | back to summary |
|---|---|
| public void write(WriteBuffer buff, LobStorageMap. Implements abstract org. Implements org. Doc from org. Write an object.
| |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public int | read(byte[]
the buffer into which the data is read. b, int the start offset in array off, int b
at which the data is written.the maximum number of bytes to read. len)Overrides java. Reads up to |
| public int |
| LobInputStream | back to summary |
|---|---|
| public LobInputStream(InputStream in) | |
| read | back to summary |
|---|---|
| public int read(byte[] b, int off, int len) throws IOException Overrides java. Doc from java. Reads up to
| |
| read | back to summary |
|---|---|
| public int read() throws IOException Overrides java. Doc from java. Reads the next byte of data from the input stream. The value byte is
returned as an
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final long | |
| pack-priv final int | |
| pack-priv final long |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| lobId | back to summary |
|---|---|
| pack-priv final long lobId | |
| mapId | back to summary |
|---|---|
| pack-priv final int mapId | |
| version | back to summary |
|---|---|
| pack-priv final long version | |
| LobRemovalInfo | back to summary |
|---|---|
| pack-priv LobRemovalInfo(long version, long lobId, int mapId) | |