Package | Description |
---|---|
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators | |
org.apache.pig.data |
This package contains implementations of Pig specific data types as well as
support functions for reading, writing, and using all Pig data types.
|
Modifier and Type | Class and Description |
---|---|
class |
CombinerPackager
The package operator that packages the globally rearranged tuples into
output format after the combiner stage.
|
class |
JoinPackager |
class |
LitePackager
This package operator is a specialization
of POPackage operator used for the specific
case of the order by query.
|
class |
MultiQueryPackager
The package operator that packages the globally rearranged tuples
into output format as required by multi-query de-multiplexer.
|
Modifier and Type | Field and Description |
---|---|
protected Packager |
POPackage.pkgr |
Modifier and Type | Method and Description |
---|---|
Packager |
Packager.clone() |
Packager |
POPackage.getPkgr() |
Modifier and Type | Method and Description |
---|---|
List<Packager> |
MultiQueryPackager.getPackagers()
Returns the list of packages.
|
Modifier and Type | Method and Description |
---|---|
void |
MultiQueryPackager.addPackager(Packager pkgr)
Appends the specified package object to the end of
the package list.
|
void |
MultiQueryPackager.addPackager(Packager pkgr,
byte mapKeyType)
Appends the specified package object to the end of
the package list.
|
void |
POPackage.setPkgr(Packager pkgr) |
Constructor and Description |
---|
CombinerPackager(Packager pkg,
boolean[] bags)
A new POPostCombinePackage will be constructed as a near clone of the
provided POPackage.
|
JoinPackager(Packager p,
POForEach f) |
POPackage(OperatorKey k,
int rp,
List<PhysicalOperator> inp,
Packager pkgr) |
Modifier and Type | Field and Description |
---|---|
protected Packager |
ReadOnceBag.pkgr |
Constructor and Description |
---|
ReadOnceBag(Packager pkgr,
Iterator<NullableTuple> tupIter,
PigNullableWritable keyWritable)
This constructor creates a bag out of an existing iterator
of tuples by taking ownership of the iterator and NOT
copying the elements of the iterator.
|
Copyright © 2007-2012 The Apache Software Foundation