Package | Description |
---|---|
org.apache.tez.runtime.library.common.shuffle |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
org.apache.tez.runtime.library.common.shuffle.impl |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Modifier and Type | Field and Description |
---|---|
protected FetchedInputCallback |
FetchedInput.callback |
Constructor and Description |
---|
DiskFetchedInput(long actualSize,
long compressedSize,
InputAttemptIdentifier inputAttemptIdentifier,
FetchedInputCallback callbackHandler,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.LocalDirAllocator localDirAllocator,
TezTaskOutputFiles filenameAllocator) |
FetchedInput(FetchedInput.Type type,
long actualSize,
long compressedSize,
InputAttemptIdentifier inputAttemptIdentifier,
FetchedInputCallback callbackHandler) |
LocalDiskFetchedInput(long startOffset,
long actualSize,
long compressedSize,
InputAttemptIdentifier inputAttemptIdentifier,
org.apache.hadoop.fs.Path inputFile,
org.apache.hadoop.conf.Configuration conf,
FetchedInputCallback callbackHandler) |
MemoryFetchedInput(long actualSize,
long compressedSize,
InputAttemptIdentifier inputAttemptIdentifier,
FetchedInputCallback callbackHandler) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleFetchedInputAllocator
Usage: Create instance, setInitialMemoryAvailable(long), configureAndStart()
|
Copyright © 2016 Apache Software Foundation. All rights reserved.