Modifier and Type | Class and Description |
---|---|
class |
JVMReuseImpl |
interface |
LoadPredicatePushdown
This interface defines how a loader can support predicate pushdown.
|
class |
SortColInfo
A class representing information about a sort column in
SortInfo |
class |
SortInfo
Class to communicate sort column information based on
order by statment's sort columns and schema
|
Constructor and Description |
---|
ResourceSchema(LogicalSchema pigSchema,
SortInfo sortInfo)
Only for use by Pig internal code.
|
ResourceSchema(Schema pigSchema,
SortInfo sortInfo)
Only for use by Pig internal code.
|
Modifier and Type | Class and Description |
---|---|
class |
SecondaryKeyOptimizerMR |
Modifier and Type | Interface and Description |
---|---|
interface |
SecondaryKeyOptimizer |
Modifier and Type | Interface and Description |
---|---|
interface |
PigLogger
An interface to allow aggregation of messages
|
Modifier and Type | Class and Description |
---|---|
class |
POBloomFilterRearrangeTez |
class |
POBuildBloomRearrangeTez
This operator writes out the key value for the hash join reduce operation similar to POLocalRearrangeTez.
|
Modifier and Type | Class and Description |
---|---|
class |
SecondaryKeyOptimizerTez |
Modifier and Type | Class and Description |
---|---|
class |
MRToTezHelper |
class |
SecurityHelper
This class duplicates some security related private methods from
org.apache.hadoop.mapreduce.JobSubmitter for Tez.
|
Modifier and Type | Class and Description |
---|---|
class |
CombinerOptimizerUtil |
class |
SecondaryKeyOptimizerUtil |
Modifier and Type | Class and Description |
---|---|
class |
BinInterSedes
A class to handle reading and writing of intermediate results of data types.
|
class |
BinSedesTuple
This tuple has a faster (de)serialization mechanism.
|
class |
BinSedesTupleFactory
Default implementation of TupleFactory.
|
class |
DataReaderWriter
This class was used to handle reading and writing of intermediate
results of data types.
|
class |
InternalCachedBag |
class |
InternalDistinctBag
An unordered collection of Tuples with no multiples.
|
interface |
InterSedes
A class to handle reading and writing of intermediate results of data
types.
|
class |
InterSedesFactory
Used to get hold of the single instance of InterSedes .
|
class |
SchemaTupleClassGenerator
This class encapsulates the generation of SchemaTuples, as well as some logic
around shipping code to the distributed cache.
|
class |
SelfSpillBag
Class to hold code common to self spilling bags such as InternalCachedBag
|
static class |
SelfSpillBag.MemoryLimits
This class helps to compute the number of entries that should be held in
memory so that memory consumption is limited.
|
class |
SizeUtil
Utility functions for estimating size of objects of pig types
|
class |
SortedSpillBag
Common functionality for proactively spilling bags that need to keep the data
sorted.
|
Modifier and Type | Method and Description |
---|---|
void |
DataBag.markStale(boolean stale)
This is used by FuncEvalSpec.FakeDataBag.
|
Modifier and Type | Class and Description |
---|---|
class |
MethodHelper |
class |
SedesHelper |
Modifier and Type | Class and Description |
---|---|
class |
PigImplConstants
Private, internal constants for use by Pig itself.
|
Modifier and Type | Class and Description |
---|---|
class |
InterStorage
LOAD FUNCTION FOR PIG INTERNAL USE ONLY!
This load function is used for storing intermediate data between MR jobs of
a pig query.
|
class |
TFileStorage
LOAD FUNCTION FOR PIG INTERNAL USE ONLY! This load function is used for
storing intermediate data between MR jobs of a pig query.
|
Modifier and Type | Interface and Description |
---|---|
interface |
GroupingSpillable
Interface to be implemented by classes that group data in memory
|
Modifier and Type | Interface and Description |
---|---|
interface |
OperatorPlan
An interface that defines graph operations on plans.
|
Modifier and Type | Interface and Description |
---|---|
interface |
LogicalRelationalNodeValidator
Implementors of this interface would define validations based on logical
operators within a Pig script.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PlanTransformListener
An interface to describe listeners that are notified when a plan is
modified.
|
Modifier and Type | Method and Description |
---|---|
PigContext |
PigStats.getPigContext() |
void |
PigStats.setBackendException(java.lang.String jobId,
java.lang.Exception e) |
Modifier and Type | Method and Description |
---|---|
static void |
MRPigStatsUtil.setBackendException(org.apache.hadoop.mapred.jobcontrol.Job job,
java.lang.Exception e) |
Modifier and Type | Interface and Description |
---|---|
interface |
PigCommandFilter
Interface defining Pig commands and a
PigCommandFilter.validate(Command) method to operate on it |
Copyright © 2007-2017 The Apache Software Foundation