| 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.