|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Uses of PigContext in org.apache.pig |
|---|
| Fields in org.apache.pig declared as PigContext | |
|---|---|
protected PigContext |
PigServer.pigContext
|
| Methods in org.apache.pig that return PigContext | |
|---|---|
PigContext |
PigServer.getPigContext()
|
| Methods in org.apache.pig with parameters of type PigContext | |
|---|---|
static boolean |
Main.dryrun(String scriptFile,
PigContext pigContext)
|
| Constructors in org.apache.pig with parameters of type PigContext | |
|---|---|
PigServer(PigContext context)
|
|
PigServer(PigContext context,
boolean connect)
|
|
| Uses of PigContext in org.apache.pig.backend.hadoop.executionengine |
|---|
| Fields in org.apache.pig.backend.hadoop.executionengine declared as PigContext | |
|---|---|
protected PigContext |
HJob.pigContext
|
protected PigContext |
HExecutionEngine.pigContext
|
| Constructors in org.apache.pig.backend.hadoop.executionengine with parameters of type PigContext | |
|---|---|
HExecutionEngine(PigContext pigContext)
|
|
HJob(ExecJob.JOB_STATUS status,
PigContext pigContext,
POStore store,
String alias)
|
|
HJob(ExecJob.JOB_STATUS status,
PigContext pigContext,
POStore store,
String alias,
PigStats stats)
|
|
| Uses of PigContext in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type PigContext | |
|---|---|
MROperPlan |
MapReduceLauncher.compile(PhysicalPlan php,
PigContext pc)
|
void |
MapReduceLauncher.explain(PhysicalPlan php,
PigContext pc,
PrintStream ps,
String format,
boolean verbose)
|
abstract void |
Launcher.explain(PhysicalPlan pp,
PigContext pc,
PrintStream ps,
String format,
boolean verbose)
Explain how a pig job will be executed on the underlying infrastructure. |
protected void |
Launcher.getErrorMessages(org.apache.hadoop.mapred.TaskReport[] reports,
String type,
boolean errNotDbg,
PigContext pigContext)
|
protected void |
Launcher.getStats(org.apache.hadoop.mapred.jobcontrol.Job job,
org.apache.hadoop.mapred.JobClient jobClient,
boolean errNotDbg,
PigContext pigContext)
|
PigStats |
MapReduceLauncher.launchPig(PhysicalPlan php,
String grpName,
PigContext pc)
|
abstract PigStats |
Launcher.launchPig(PhysicalPlan php,
String grpName,
PigContext pc)
Method to launch pig for hadoop either for a cluster's job tracker or for a local job runner. |
| Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type PigContext | |
|---|---|
JobControlCompiler(PigContext pigContext,
org.apache.hadoop.conf.Configuration conf)
|
|
LimitAdjuster(MROperPlan plan,
PigContext pigContext)
|
|
MRCompiler(PhysicalPlan plan,
PigContext pigContext)
|
|
SampleOptimizer(MROperPlan plan,
PigContext pigContext)
|
|
| Uses of PigContext in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators that return PigContext | |
|---|---|
PigContext |
POLoad.getPc()
|
PigContext |
POPartitionRearrange.getPigContext()
|
| Methods in org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators with parameters of type PigContext | |
|---|---|
void |
POLoad.setPc(PigContext pc)
|
void |
POPartitionRearrange.setPigContext(PigContext pigContext)
|
| Uses of PigContext in org.apache.pig.backend.hadoop.executionengine.util |
|---|
| Methods in org.apache.pig.backend.hadoop.executionengine.util with parameters of type PigContext | |
|---|---|
static FileSpec |
MapRedUtil.checkLeafIsStore(PhysicalPlan plan,
PigContext pigContext)
|
| Uses of PigContext in org.apache.pig.impl.builtin |
|---|
| Methods in org.apache.pig.impl.builtin with parameters of type PigContext | |
|---|---|
void |
SampleLoader.computeSamples(ArrayList<Pair<FileSpec,Boolean>> inputs,
PigContext pc)
|
void |
PoissonSampleLoader.computeSamples(ArrayList<Pair<FileSpec,Boolean>> inputs,
PigContext pc)
Computes the number of samples for the loader |
| Uses of PigContext in org.apache.pig.impl.io |
|---|
| Methods in org.apache.pig.impl.io with parameters of type PigContext | |
|---|---|
static OutputStream |
FileLocalizer.create(String fileSpec,
boolean append,
PigContext pigContext)
|
static OutputStream |
FileLocalizer.create(String fileSpec,
PigContext pigContext)
|
static boolean |
FileLocalizer.delete(String fileSpec,
PigContext pigContext)
|
static boolean |
FileLocalizer.fileExists(String filename,
PigContext context)
|
static String |
FileLocalizer.fullPath(String filename,
PigContext pigContext)
|
static ElementDescriptor |
FileLocalizer.getTemporaryPath(ElementDescriptor relative,
PigContext pigContext)
Deprecated. Use FileLocalizer.getTemporaryPath(PigContext) instead |
static org.apache.hadoop.fs.Path |
FileLocalizer.getTemporaryPath(PigContext pigContext)
|
static String |
FileLocalizer.hadoopify(String filename,
PigContext pigContext)
|
static boolean |
FileLocalizer.isDirectory(String filename,
PigContext context)
|
static boolean |
FileLocalizer.isFile(String filename,
PigContext context)
|
DataBag |
PigFile.load(LoadFunc lfunc,
PigContext pigContext)
|
static SeekableInputStream |
FileLocalizer.open(String fileSpec,
long offset,
PigContext pigContext)
|
static InputStream |
FileLocalizer.open(String fileSpec,
PigContext pigContext)
|
void |
PigFile.store(DataBag data,
FuncSpec storeFuncSpec,
PigContext pigContext)
|
| Uses of PigContext in org.apache.pig.impl.streaming |
|---|
| Constructors in org.apache.pig.impl.streaming with parameters of type PigContext | |
|---|---|
StreamingCommand(PigContext pigContext,
String[] argv)
Create a new StreamingCommand with the given command. |
|
| Uses of PigContext in org.apache.pig.impl.util |
|---|
| Methods in org.apache.pig.impl.util with parameters of type PigContext | |
|---|---|
static void |
JarManager.createJar(OutputStream os,
Set<String> funcs,
PigContext pigContext)
Create a jarfile in a temporary path, that is a merge of all the jarfiles containing the functions and the core pig classes. |
static String |
Utils.getTmpFileCompressorName(PigContext pigContext)
|
static boolean |
Utils.tmpFileCompression(PigContext pigContext)
|
static String |
Utils.tmpFileCompressionCodec(PigContext pigContext)
|
| Uses of PigContext in org.apache.pig.newplan.logical.expression |
|---|
| Fields in org.apache.pig.newplan.logical.expression declared as PigContext | |
|---|---|
protected PigContext |
ExpToPhyTranslationVisitor.pc
|
| Methods in org.apache.pig.newplan.logical.expression with parameters of type PigContext | |
|---|---|
void |
ExpToPhyTranslationVisitor.setPigContext(PigContext pc)
|
| Uses of PigContext in org.apache.pig.newplan.logical.relational |
|---|
| Fields in org.apache.pig.newplan.logical.relational declared as PigContext | |
|---|---|
protected PigContext |
LogToPhyTranslationVisitor.pc
|
| Methods in org.apache.pig.newplan.logical.relational with parameters of type PigContext | |
|---|---|
void |
LogToPhyTranslationVisitor.setPigContext(PigContext pc)
|
| Uses of PigContext in org.apache.pig.newplan.logical.rules |
|---|
| Constructors in org.apache.pig.newplan.logical.rules with parameters of type PigContext | |
|---|---|
InputOutputFileValidator(OperatorPlan plan,
PigContext pigContext)
|
|
| Uses of PigContext in org.apache.pig.newplan.logical.visitor |
|---|
| Constructors in org.apache.pig.newplan.logical.visitor with parameters of type PigContext | |
|---|---|
ScalarVisitor(OperatorPlan plan,
PigContext pigContext)
|
|
| Uses of PigContext in org.apache.pig.parser |
|---|
| Methods in org.apache.pig.parser with parameters of type PigContext | |
|---|---|
static void |
QueryParserUtils.attachStorePlan(LogicalPlan lp,
String fileName,
String func,
Operator input,
String alias,
PigContext pigContext)
|
| Constructors in org.apache.pig.parser with parameters of type PigContext | |
|---|---|
DryRunGruntParser(Reader stream,
String source,
PigContext context)
|
|
QueryParserDriver(PigContext pigContext,
String scope,
Map<String,String> fileNameMap)
|
|
StreamingCommandUtils(PigContext pigContext)
|
|
| Uses of PigContext in org.apache.pig.pen |
|---|
| Methods in org.apache.pig.pen with parameters of type PigContext | |
|---|---|
void |
LocalMapReduceSimulator.launchPig(PhysicalPlan php,
Map<LOLoad,DataBag> baseData,
LineageTracer lineage,
IllustratorAttacher attacher,
ExampleGenerator eg,
PigContext pc)
|
| Constructors in org.apache.pig.pen with parameters of type PigContext | |
|---|---|
ExampleGenerator(LogicalPlan plan,
PigContext hadoopPigContext)
|
|
Illustrator(LineageTracer lineage,
LinkedList<IdentityHashSet<Tuple>> equivalenceClasses,
IllustratorAttacher attacher,
PigContext hadoopPigContext)
|
|
Illustrator(LineageTracer lineage,
LinkedList<IdentityHashSet<Tuple>> equivalenceClasses,
int maxRecords,
IllustratorAttacher attacher,
LogicalSchema schema,
PigContext hadoopPigContext)
|
|
IllustratorAttacher(PhysicalPlan plan,
LineageTracer lineage,
int maxRecords,
Map<POLoad,LogicalSchema> poLoadToSchemaMap,
PigContext hadoopPigContext)
|
|
LineageTrimmingVisitor(LogicalPlan plan,
Map<LOLoad,DataBag> baseData,
ExampleGenerator eg,
Map<Operator,PhysicalOperator> LogToPhyMap,
PhysicalPlan physPlan,
PigContext pc)
|
|
| Uses of PigContext in org.apache.pig.scripting |
|---|
| Methods in org.apache.pig.scripting that return PigContext | |
|---|---|
PigContext |
ScriptPigContext.getPigContext()
|
| Methods in org.apache.pig.scripting with parameters of type PigContext | |
|---|---|
protected abstract Map<String,List<PigStats>> |
ScriptEngine.main(PigContext context,
String scriptFile)
Actually runs the script file. |
abstract void |
ScriptEngine.registerFunctions(String path,
String namespace,
PigContext pigContext)
Registers scripting language functions as Pig functions with given namespace |
Map<String,List<PigStats>> |
ScriptEngine.run(PigContext pigContext,
String scriptFile)
Runs a script file. |
static ScriptPigContext |
ScriptPigContext.set(PigContext pigContext,
ScriptEngine engine)
|
| Uses of PigContext in org.apache.pig.scripting.js |
|---|
| Methods in org.apache.pig.scripting.js with parameters of type PigContext | |
|---|---|
protected Map<String,List<PigStats>> |
JsScriptEngine.main(PigContext pigContext,
String scriptFile)
|
void |
JsScriptEngine.registerFunctions(String path,
String namespace,
PigContext pigContext)
|
| Uses of PigContext in org.apache.pig.scripting.jython |
|---|
| Methods in org.apache.pig.scripting.jython with parameters of type PigContext | |
|---|---|
protected Map<String,List<PigStats>> |
JythonScriptEngine.main(PigContext pigContext,
String scriptFile)
|
void |
JythonScriptEngine.registerFunctions(String path,
String namespace,
PigContext pigContext)
|
| Uses of PigContext in org.apache.pig.tools |
|---|
| Constructors in org.apache.pig.tools with parameters of type PigContext | |
|---|---|
ToolsPigServer(PigContext ctx)
|
|
| Uses of PigContext in org.apache.pig.tools.grunt |
|---|
| Constructors in org.apache.pig.tools.grunt with parameters of type PigContext | |
|---|---|
Grunt(BufferedReader in,
PigContext pigContext)
|
|
| Uses of PigContext in org.apache.pig.tools.pigstats |
|---|
| Methods in org.apache.pig.tools.pigstats that return PigContext | |
|---|---|
PigContext |
ScriptState.getPigContext()
|
| Methods in org.apache.pig.tools.pigstats with parameters of type PigContext | |
|---|---|
void |
ScriptState.setPigContext(PigContext pigContext)
|
static ScriptState |
ScriptState.start(String commandLine,
PigContext pigContext)
|
static void |
PigStatsUtil.startCollection(PigContext pc,
org.apache.hadoop.mapred.JobClient client,
JobControlCompiler jcc,
MROperPlan plan)
Starts collecting statistics for the given MR plan |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||