@NotThreadSafe public final class InStreamOptions extends Object
OpenFilePOptions
as well as the URIStatus
being read. In addition to
providing access to the fields, it provides convenience functions for various nested
fields and creating alluxio.proto.dataserver.Protocol.ReadRequest
s.Constructor and Description |
---|
InStreamOptions(URIStatus status,
AlluxioConfiguration alluxioConf)
Creates with the default
OpenFilePOptions . |
InStreamOptions(URIStatus status,
OpenFilePOptions options,
AlluxioConfiguration alluxioConf)
Creates with given
OpenFilePOptions instance. |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
BlockInfo |
getBlockInfo(long blockId) |
Protocol.OpenUfsBlockOptions |
getOpenUfsBlockOptions(long blockId) |
OpenFilePOptions |
getOptions() |
boolean |
getPositionShort() |
URIStatus |
getStatus() |
BlockLocationPolicy |
getUfsReadLocationPolicy() |
int |
hashCode() |
void |
setPositionShort(boolean positionShort)
Sets whether the operation is positioned read to a small buffer.
|
void |
setUfsReadLocationPolicy(BlockLocationPolicy ufsReadLocationPolicy)
Sets block read location policy.
|
String |
toString() |
public InStreamOptions(URIStatus status, AlluxioConfiguration alluxioConf)
OpenFilePOptions
.status
- the file to create the options foralluxioConf
- Alluxio configurationpublic InStreamOptions(URIStatus status, OpenFilePOptions options, AlluxioConfiguration alluxioConf)
OpenFilePOptions
instance.status
- URI statusoptions
- OpenFile optionsalluxioConf
- Alluxio configurationpublic OpenFilePOptions getOptions()
OpenFilePOptions
associated with the instreampublic void setUfsReadLocationPolicy(BlockLocationPolicy ufsReadLocationPolicy)
ufsReadLocationPolicy
- block location policy implementationpublic void setPositionShort(boolean positionShort)
positionShort
- whether the operation is positioned read to a small bufferpublic BlockLocationPolicy getUfsReadLocationPolicy()
BlockLocationPolicy
associated with the instreampublic boolean getPositionShort()
public BlockInfo getBlockInfo(long blockId)
blockId
- id of the blockpublic Protocol.OpenUfsBlockOptions getOpenUfsBlockOptions(long blockId)
blockId
- id of the blockProtocol.OpenUfsBlockOptions
based on the block id and optionsCopyright © 2023. All Rights Reserved.