| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Data.Hadoop.Protobuf.DataTransfer
Description
This module contains protocol buffers that are used to transfer data to and from the datanode, as well as between datanodes.
- data DataTransferEncryptorStatus
- data DataTransferEncryptorMessage = DataTransferEncryptorMessage {
- dtesStatus :: Required 1 (Enumeration DataTransferEncryptorStatus)
- dtesPayload :: Optional 2 (Value ByteString)
- dtesData :: Optional 3 (Value Text)
- data BaseHeader = BaseHeader {}
- data ClientOperationHeader = ClientOperationHeader {
- cohBaseHeader :: Required 1 (Message BaseHeader)
- cohClientName :: Required 2 (Value Text)
- data CachingStrategy = CachingStrategy {
- csDropBehind :: Optional 1 (Value Bool)
- csReadahead :: Optional 2 (Value Int64)
- data OpReadBlock = OpReadBlock {
- orbHeader :: Required 1 (Message ClientOperationHeader)
- orbOffset :: Required 2 (Value Word64)
- orbLen :: Required 3 (Value Word64)
- orbSendChecksums :: Optional 4 (Value Bool)
- orbCachingStrategy :: Optional 5 (Message CachingStrategy)
- data Checksum = Checksum {
- csType :: Required 1 (Message ChecksumType)
- csBytesPerChecksum :: Required 2 (Value Word32)
- data BlockConstructionStage
- data OpWriteBlock = OpWriteBlock {
- owbHeader :: Required 1 (Message ClientOperationHeader)
- owbTargets :: Repeated 2 (Message DataNodeInfo)
- owbSource :: Optional 3 (Message DataNodeInfo)
- owbStage :: Required 4 (Enumeration BlockConstructionStage)
- owbPipelineSize :: Required 5 (Value Word32)
- owbMinBytesRcvd :: Required 6 (Value Word64)
- owbMaxBytesRcvd :: Required 7 (Value Word64)
- owbLatestGenerationStamp :: Required 8 (Value Word64)
- owbRequestedChecksum :: Required 9 (Message Checksum)
- owbCachingStrategy :: Optional 10 (Message CachingStrategy)
- data OpTransferBlock = OpTransferBlock {}
- data OpReplaceBlock = OpReplaceBlock {
- orpHeader :: Required 1 (Message BaseHeader)
- orpDelHint :: Required 2 (Value Text)
- orpSource :: Required 3 (Message DataNodeInfo)
- data OpCopyBlock = OpCopyBlock {
- ocbHeader :: Required 1 (Message BaseHeader)
- data OpBlockChecksum = OpBlockChecksum {
- obcHeader :: Required 1 (Message BaseHeader)
- data OpRequestShortCircuitAccess = OpRequestShortCircuitAccess {
- orscHeader :: Required 1 (Message BaseHeader)
- orscMaxVersion :: Required 2 (Value Word32)
- data PacketHeader = PacketHeader {}
- data DataTransferStatus
- data PipelineAck = PipelineAck {
- psSeqno :: Required 1 (Value (Signed Int64))
- paStatus :: Optional 2 (Enumeration DataTransferStatus)
- paDownstreamAckTimeNanos :: Optional 3 (Value Word64)
- data ReadOpChecksumInfo = ReadOpChecksumInfo {
- rociChecksum :: Required 1 (Message Checksum)
- rociChunkOffset :: Required 2 (Value Word64)
- data BlockOpResponse = BlockOpResponse {
- borStatus :: Required 1 (Enumeration DataTransferStatus)
- borFirstBadLink :: Optional 2 (Value String)
- borChecksumResponse :: Optional 3 (Message OpBlockChecksumResponse)
- borReadOpChecksumInfo :: Optional 4 (Message ReadOpChecksumInfo)
- borData :: Optional 5 (Value Text)
- borShortCircuitAccessVersion :: Optional 6 (Value Word32)
- data ClientReadStatus = ClientReadStatus {}
- data DNTransferAck = DNTransferAck {}
- data OpBlockChecksumResponse = OpBlockChecksumResponse {
- obcrBytesPerCrc :: Required 1 (Value Word32)
- obcrCrcPerBlock :: Required 2 (Value Word64)
- obcrMd5 :: Required 3 (Value ByteString)
- obcrCrcType :: Optional 4 (Message ChecksumType)
Documentation
data DataTransferEncryptorStatus Source
Constructors
| DTES_SUCCESS | |
| DTES_ERROR_UNKNOWN_KEY | |
| DTES_ERROR |
data DataTransferEncryptorMessage Source
Constructors
| DataTransferEncryptorMessage | |
Fields
| |
data ClientOperationHeader Source
Constructors
| ClientOperationHeader | |
Fields
| |
data CachingStrategy Source
Constructors
| CachingStrategy | |
Fields
| |
data OpReadBlock Source
Constructors
| OpReadBlock | |
Fields
| |
Instances
Constructors
| Checksum | |
Fields
| |
data BlockConstructionStage Source
Constructors
| BCS_PIPELINE_SETUP_APPEND | |
| BCS_PIPELINE_SETUP_APPEND_RECOVERY | pipeline set up for failed PIPELINE_SETUP_APPEND recovery |
| BCS_DATA_STREAMING | data streaming |
| BCS_PIPELINE_SETUP_STREAMING_RECOVERY | pipeline setup for failed data streaming recovery |
| BCS_PIPELINE_CLOSE | close the block and pipeline |
| BCS_PIPELINE_CLOSE_RECOVERY | Recover a failed PIPELINE_CLOSE |
| BCS_PIPELINE_SETUP_CREATE | pipeline set up for block creation |
| BCS_TRANSFER_RBW | transfer RBW for adding datanodes |
| BCS_TRANSFER_FINALIZED | transfer Finalized for adding datanodes |
data OpWriteBlock Source
Constructors
| OpWriteBlock | |
Fields
| |
Instances
data OpTransferBlock Source
Constructors
| OpTransferBlock | |
Fields
| |
data OpReplaceBlock Source
Constructors
| OpReplaceBlock | |
Fields
| |
data OpCopyBlock Source
Constructors
| OpCopyBlock | |
Fields
| |
Instances
data OpBlockChecksum Source
Constructors
| OpBlockChecksum | |
Fields
| |
data OpRequestShortCircuitAccess Source
Constructors
| OpRequestShortCircuitAccess | |
Fields
| |
data DataTransferStatus Source
data PipelineAck Source
Constructors
| PipelineAck | |
Fields
| |
Instances
data ReadOpChecksumInfo Source
Sent as part of the BlockOpResponse for READ_BLOCK and COPY_BLOCK operations.
Constructors
| ReadOpChecksumInfo | |
Fields
| |
data BlockOpResponse Source
Constructors
| BlockOpResponse | |
Fields
| |
data ClientReadStatus Source
Message sent from the client to the DN after reading the entire read request.
Constructors
| ClientReadStatus | |
Fields | |
data OpBlockChecksumResponse Source
Constructors
| OpBlockChecksumResponse | |
Fields
| |