Package org.cdlib.mrt.s3.tools

Class S3Reader

java.lang.Object
org.cdlib.mrt.s3.tools.S3Reader
public class S3Reader extends Object
Author:
replic

  • Field Details

    • log4j

      protected static final org.apache.logging.log4j.Logger log4j

    • NAME

      protected static final String NAME
      See Also:

    • MESSAGE

      protected static final String MESSAGE
      See Also:

    • DEBUG

      protected static final boolean DEBUG
      See Also:

    • RETRY

      protected static int RETRY

    • readBufSize

      protected int readBufSize

    • maxBufSize

      protected int maxBufSize

    • nextCnt

      protected int nextCnt

    • segCnt

      protected int segCnt

    • readTimeMs

      protected long readTimeMs

    • inputSize

      protected long inputSize

    • service

      protected CloudStoreInf service

    • bucket

      protected String bucket

    • key

      protected String key

    • metaObjectSize

      protected long metaObjectSize

    • physicalObjectSize

      protected long physicalObjectSize

    • metaSha256

      protected String metaSha256

    • metaTimeMs

      protected long metaTimeMs

    • buf

      protected byte[] buf

    • byteBuf

      protected ByteBuffer byteBuf

    • start

      protected long start

    • stop

      protected long stop

    • more

      protected boolean more

  • Constructor Details

    • S3Reader

      protected S3Reader(CloudStoreInf service, String bucket, String key, Integer maxsize) throws org.cdlib.mrt.utility.TException
      Throws:
      org.cdlib.mrt.utility.TException

  • Method Details

    • getS3Reader

      public static S3Reader getS3Reader(CloudStoreInf service, String bucket, String key, Integer maxsize) throws org.cdlib.mrt.utility.TException
      Throws:
      org.cdlib.mrt.utility.TException

    • dump

      public void dump(String header)

    • startRead

      public long startRead()

    • nextRead

      public byte[] nextRead() throws org.cdlib.mrt.utility.TException
      Throws:
      org.cdlib.mrt.utility.TException

    • getStream

      protected InputStream getStream(long start, long stop, int retry) throws org.cdlib.mrt.utility.TException
      Throws:
      org.cdlib.mrt.utility.TException

    • getMetaObjectSize

      public Long getMetaObjectSize()

    • getMetaSha256

      public String getMetaSha256()

    • getSegCnt

      public int getSegCnt()

    • getReadBufSize

      public int getReadBufSize()

    • getReadTimeMs

      public long getReadTimeMs()

    • getBucket

      public String getBucket()

    • getKey

      public String getKey()

    • getAlgorithm

      public static org.cdlib.mrt.utility.MessageDigestType getAlgorithm(String algorithmS)

    • getInputSize

      public long getInputSize()

    • isMore

      public boolean isMore()

    • getMaxBufSize

      public int getMaxBufSize()

    • getMetaTimeMs

      public long getMetaTimeMs()

    • getNextCnt

      public int getNextCnt()