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