public final class IoTrace extends Object
Modifier and Type | Class and Description |
---|---|
static class |
IoTrace.RangesSrc |
Modifier and Type | Field and Description |
---|---|
static int |
ADD_STREAM |
static int |
CACHE_COLLISION |
static int |
COLUMN_READ |
static int |
COMPOSITE_ORC_CB |
static int |
INVALID_ORC_CB |
static int |
ORC_CB |
static int |
PARTIAL_CB |
static int |
PARTIAL_UNCOMPRESSED_DATA |
static int |
RANGES |
static int |
READING_STRIPE |
static int |
SARG_RESULT |
static int |
SARG_RESULT2 |
static int |
SKIP_STREAM |
static int |
START_COL |
static int |
START_READ |
static int |
START_RG |
static int |
START_STREAM |
static int |
START_STRIPE_STREAM |
static int |
TREE_READER_NEXT_VECTOR |
static int |
UNCOMPRESSED_DATA |
static int |
VALID_UNCOMPRESSEED_CHUNK |
Constructor and Description |
---|
IoTrace(int byteSize,
boolean isAlwaysDump) |
Modifier and Type | Method and Description |
---|---|
static FixedSizedObjectPool<IoTrace> |
createTracePool(org.apache.hadoop.conf.Configuration conf) |
void |
dumpLog(org.slf4j.Logger logger) |
void |
logAddStream(int colIx,
org.apache.orc.OrcProto.Stream.Kind streamKind,
long streamOffset,
long length,
int indexIx,
boolean isEntire) |
void |
logCacheCollision(org.apache.hadoop.hive.common.io.DiskRange replacedChunk,
org.apache.hadoop.hive.common.io.encoded.MemoryBuffer replacementBuffer) |
void |
logColumnRead(int colIx,
int includedIx,
org.apache.orc.OrcProto.ColumnEncoding.Kind kind) |
void |
logCompositeOrcCb(int lastChunkTaken,
int lastChunkRemaining,
org.apache.hadoop.hive.common.io.DiskRange cc) |
void |
logInvalidOrcCb(long cbStartOffset,
long end) |
void |
logOrcCb(long cbStartOffset,
int cbLength,
boolean isUncompressed) |
void |
logPartialCb(org.apache.hadoop.hive.common.io.DiskRange current) |
void |
logPartialUncompressedData(long partOffset,
long candidateEnd,
boolean fromCache) |
void |
logRanges(Object fileKey,
long baseOffset,
org.apache.hadoop.hive.common.io.DiskRangeList range,
IoTrace.RangesSrc src) |
void |
logReadingStripe(int stripeIx,
long stripeOffset,
long length) |
void |
logSargResult(int stripeIx,
boolean[] rgsToRead) |
void |
logSargResult(int stripeIx,
int rgCount) |
void |
logSkipStream(int colIx,
org.apache.orc.OrcProto.Stream.Kind streamKind,
long streamOffset,
long length) |
void |
logStartCol(int colIx) |
void |
logStartRead(org.apache.hadoop.hive.common.io.DiskRangeList current) |
void |
logStartRg(int rgIx) |
void |
logStartStream(org.apache.orc.OrcProto.Stream.Kind kind,
long cOffset,
long endCOffset,
long unlockUntilCOffset) |
void |
logStartStripeStream(org.apache.orc.OrcProto.Stream.Kind kind) |
void |
logTreeReaderNextVector(int idx) |
void |
logUncompressedData(long dataOffset,
long end) |
void |
logValidUncompresseedChunk(int totalLength,
org.apache.hadoop.hive.common.io.DiskRange chunk) |
void |
reset() |
public static final int TREE_READER_NEXT_VECTOR
public static final int READING_STRIPE
public static final int SARG_RESULT
public static final int RANGES
public static final int COLUMN_READ
public static final int SKIP_STREAM
public static final int ADD_STREAM
public static final int START_RG
public static final int START_COL
public static final int START_STRIPE_STREAM
public static final int START_STREAM
public static final int START_READ
public static final int UNCOMPRESSED_DATA
public static final int PARTIAL_UNCOMPRESSED_DATA
public static final int VALID_UNCOMPRESSEED_CHUNK
public static final int CACHE_COLLISION
public static final int ORC_CB
public static final int INVALID_ORC_CB
public static final int PARTIAL_CB
public static final int COMPOSITE_ORC_CB
public static final int SARG_RESULT2
public void reset()
public void dumpLog(org.slf4j.Logger logger)
public void logTreeReaderNextVector(int idx)
public void logReadingStripe(int stripeIx, long stripeOffset, long length)
public void logSargResult(int stripeIx, int rgCount)
public void logSargResult(int stripeIx, boolean[] rgsToRead)
public void logRanges(Object fileKey, long baseOffset, org.apache.hadoop.hive.common.io.DiskRangeList range, IoTrace.RangesSrc src)
public void logColumnRead(int colIx, int includedIx, org.apache.orc.OrcProto.ColumnEncoding.Kind kind)
public void logSkipStream(int colIx, org.apache.orc.OrcProto.Stream.Kind streamKind, long streamOffset, long length)
public void logAddStream(int colIx, org.apache.orc.OrcProto.Stream.Kind streamKind, long streamOffset, long length, int indexIx, boolean isEntire)
public void logStartRg(int rgIx)
public void logStartCol(int colIx)
public void logStartStripeStream(org.apache.orc.OrcProto.Stream.Kind kind)
public void logStartStream(org.apache.orc.OrcProto.Stream.Kind kind, long cOffset, long endCOffset, long unlockUntilCOffset)
public void logStartRead(org.apache.hadoop.hive.common.io.DiskRangeList current)
public void logUncompressedData(long dataOffset, long end)
public void logPartialUncompressedData(long partOffset, long candidateEnd, boolean fromCache)
public void logValidUncompresseedChunk(int totalLength, org.apache.hadoop.hive.common.io.DiskRange chunk)
public void logCacheCollision(org.apache.hadoop.hive.common.io.DiskRange replacedChunk, org.apache.hadoop.hive.common.io.encoded.MemoryBuffer replacementBuffer)
public void logOrcCb(long cbStartOffset, int cbLength, boolean isUncompressed)
public void logInvalidOrcCb(long cbStartOffset, long end)
public void logPartialCb(org.apache.hadoop.hive.common.io.DiskRange current)
public void logCompositeOrcCb(int lastChunkTaken, int lastChunkRemaining, org.apache.hadoop.hive.common.io.DiskRange cc)
public static FixedSizedObjectPool<IoTrace> createTracePool(org.apache.hadoop.conf.Configuration conf)
Copyright © 2022 The Apache Software Foundation. All rights reserved.