Package org.apache.hadoop.hdfs.protocol.datatransfer


@Evolving package org.apache.hadoop.hdfs.protocol.datatransfer
This package contains classes related to hdfs data transfer protocol.
  • Class
    Description
    org.apache.hadoop.hdfs.protocol.datatransfer.BlackListBasedTrustedChannelResolver
    Implements TrustedChannelResolver to trust ips/host/subnets based on a blackList.
    org.apache.hadoop.hdfs.protocol.datatransfer.BlockConstructionStage
    Block Construction Stage
    org.apache.hadoop.hdfs.protocol.datatransfer.BlockPinningException
    Indicates a failure due to block pinning.
    org.apache.hadoop.hdfs.protocol.datatransfer.DataTransferProtocol
    Transfer data to/from datanode using a streaming protocol.
    org.apache.hadoop.hdfs.protocol.datatransfer.DataTransferProtoUtil
    Static utilities for dealing with the protocol buffers used by the Data Transfer Protocol.
    org.apache.hadoop.hdfs.protocol.datatransfer.InvalidEncryptionKeyException
    Encryption key verification failed.
    org.apache.hadoop.hdfs.protocol.datatransfer.IOStreamPair
    A little struct class to wrap an InputStream and an OutputStream.
    org.apache.hadoop.hdfs.protocol.datatransfer.Op
    Operation
    org.apache.hadoop.hdfs.protocol.datatransfer.PacketHeader
    Header data for each packet that goes through the read/write pipelines.
    org.apache.hadoop.hdfs.protocol.datatransfer.PacketReceiver
    Class to handle reading packets one-at-a-time from the wire.
    org.apache.hadoop.hdfs.protocol.datatransfer.PipelineAck
    Pipeline Acknowledgment
     
     
    org.apache.hadoop.hdfs.protocol.datatransfer.Receiver
    Receiver
    org.apache.hadoop.hdfs.protocol.datatransfer.ReplaceDatanodeOnFailure
    The setting of replace-datanode-on-failure feature.
    The replacement policies
    org.apache.hadoop.hdfs.protocol.datatransfer.Sender
    Sender
    org.apache.hadoop.hdfs.protocol.datatransfer.TrustedChannelResolver
    Class used to indicate whether a channel is trusted or not.
    org.apache.hadoop.hdfs.protocol.datatransfer.WhitelistBasedTrustedChannelResolver