Package | Description |
---|---|
org.apache.pig |
Public interfaces and classes for Pig.
|
org.apache.pig.backend.hadoop.accumulo | |
org.apache.pig.backend.hadoop.executionengine.mapReduceLayer | |
org.apache.pig.backend.hadoop.executionengine.spark | |
org.apache.pig.backend.hadoop.hbase | |
org.apache.pig.builtin |
This package contains builtin Pig UDFs.
|
org.apache.pig.builtin.mock | |
org.apache.pig.impl.builtin | |
org.apache.pig.impl.io | |
org.apache.pig.piggybank.storage | |
org.apache.pig.piggybank.storage.avro |
Modifier and Type | Method and Description |
---|---|
void |
LoadFuncWrapper.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
abstract void |
LoadFunc.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split)
Initializes LoadFunc for reading data.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractAccumuloStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
Modifier and Type | Field and Description |
---|---|
protected PigSplit |
PigInputFormat.RecordReaderFactory.pigSplit |
Modifier and Type | Method and Description |
---|---|
void |
MergeJoinIndexer.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
Constructor and Description |
---|
PigRecordReader(org.apache.hadoop.mapreduce.InputFormat<?,?> inputformat,
PigSplit pigSplit,
LoadFunc loadFunc,
org.apache.hadoop.mapreduce.TaskAttemptContext context,
long limit) |
Modifier and Type | Method and Description |
---|---|
PigSplit |
SparkPigSplit.getWrappedPigSplit() |
PigSplit |
SparkPigSplit.FileSparkPigSplit.getWrappedPigSplit() |
PigSplit |
SparkPigSplit.GenericSparkPigSplit.getWrappedPigSplit() |
Constructor and Description |
---|
FileSparkPigSplit(PigSplit pigSplit) |
GenericSparkPigSplit(PigSplit pigSplit) |
SparkPigRecordReader(org.apache.hadoop.mapreduce.InputFormat<?,?> inputformat,
PigSplit pigSplit,
LoadFunc loadFunc,
org.apache.hadoop.mapreduce.TaskAttemptContext context,
long limit) |
Modifier and Type | Method and Description |
---|---|
void |
HBaseStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
TextLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
PigStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
OrcStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
JsonLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
BinStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
AvroStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader r,
PigSplit s) |
Modifier and Type | Method and Description |
---|---|
void |
Storage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
SampleLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
RandomSampleLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
PoissonSampleLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
DefaultIndexableLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
TFileStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
SequenceFileInterStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
ReadToEndLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
InterStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
Modifier and Type | Method and Description |
---|---|
LoadFunc |
AllLoader.AllReader.prepareLoadFuncForReading(PigSplit split) |
void |
XMLLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
SequenceFileLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
RegExLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
HiveColumnarLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
FixedWidthLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
CSVLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
CSVExcelStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
void |
AllLoader.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
Modifier and Type | Method and Description |
---|---|
void |
AvroStorage.prepareToRead(org.apache.hadoop.mapreduce.RecordReader reader,
PigSplit split) |
Copyright © 2007-2017 The Apache Software Foundation