|
||||||||||
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)
|
ExecutionEngine |
ExecType.getExecutionEngine(PigContext pigContext)
Returns the Execution Engine that this ExecType is associated with. |
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.executionengine |
---|
Methods in org.apache.pig.backend.executionengine with parameters of type PigContext | |
---|---|
void |
ExecutionEngine.explain(LogicalPlan lp,
PigContext pc,
PrintStream ps,
String format,
boolean verbose,
File dir,
String suffix)
This method handles the backend processing of the Explain command. |
PigStats |
ExecutionEngine.launchPig(LogicalPlan lp,
String grpName,
PigContext pc)
This method is responsible for the actual execution of a LogicalPlan. |
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
|
Methods in org.apache.pig.backend.hadoop.executionengine with parameters of type PigContext | |
---|---|
void |
HExecutionEngine.explain(LogicalPlan lp,
PigContext pc,
PrintStream ps,
String format,
boolean verbose,
File file,
String suffix)
|
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)
|
PigStats |
HExecutionEngine.launchPig(LogicalPlan lp,
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 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.fetch |
---|
Methods in org.apache.pig.backend.hadoop.executionengine.fetch with parameters of type PigContext | |
---|---|
void |
FetchLauncher.explain(PhysicalPlan pp,
PigContext pc,
PrintStream ps,
String format)
Creates an empty MR plan |
static boolean |
FetchOptimizer.isFetchEnabled(PigContext pc)
Checks whether the fetch is enabled |
static boolean |
FetchOptimizer.isPlanFetchable(PigContext pc,
PhysicalPlan pp)
Visits the plan with FetchablePlanVisitor and checks whether the
plan is fetchable. |
Constructors in org.apache.pig.backend.hadoop.executionengine.fetch with parameters of type PigContext | |
---|---|
FetchLauncher(PigContext pigContext)
|
|
FetchPOStoreImpl(PigContext pc)
|
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)
|
ExecutionEngine |
MRExecType.getExecutionEngine(PigContext pigContext)
|
ExecutionEngine |
LocalExecType.getExecutionEngine(PigContext pigContext)
|
PigStats |
MapReduceLauncher.launchPig(PhysicalPlan php,
String grpName,
PigContext pc)
|
Constructors in org.apache.pig.backend.hadoop.executionengine.mapReduceLayer with parameters of type PigContext | |
---|---|
JobControlCompiler(PigContext pigContext,
org.apache.hadoop.conf.Configuration conf)
|
|
JobControlCompiler(PigContext pigContext,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.conf.Configuration defaultConf)
|
|
LimitAdjuster(MROperPlan plan,
PigContext pigContext)
|
|
MRCompiler(PhysicalPlan plan,
PigContext pigContext)
|
|
MRExecutionEngine(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)
|
static void |
MapRedUtil.setupStreamingDirsConfMulti(PigContext pigContext,
org.apache.hadoop.conf.Configuration conf)
Sets up output and log dir paths for a multi-store streaming job |
static void |
MapRedUtil.setupStreamingDirsConfSingle(POStore st,
PigContext pigContext,
org.apache.hadoop.conf.Configuration conf)
Sets up output and log dir paths for a single-store streaming job |
Uses of PigContext in org.apache.pig.builtin.mock |
---|
Methods in org.apache.pig.builtin.mock with parameters of type PigContext | |
---|---|
static Storage.Data |
Storage.resetData(PigContext context)
reset the store and get the Data object to access it |
Uses of PigContext in org.apache.pig.data |
---|
Methods in org.apache.pig.data with parameters of type PigContext | |
---|---|
static void |
SchemaTupleFrontend.copyAllGeneratedToDistributedCache(PigContext pigContext,
org.apache.hadoop.conf.Configuration conf)
This must be called when the code has been generated and the generated code needs to be shipped to the cluster, so that it may be used by the mappers and reducers. |
static void |
SchemaTupleBackend.initialize(org.apache.hadoop.conf.Configuration jConf,
PigContext pigContext)
|
static void |
SchemaTupleBackend.initialize(org.apache.hadoop.conf.Configuration jConf,
PigContext pigContext,
boolean isLocal)
|
protected static void |
SchemaTupleFrontend.lazyReset(PigContext pigContext)
This is a method which caches a PigContext object that has had relevant key values set by SchemaTupleBackend. |
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)
|
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 org.apache.hadoop.fs.Path |
FileLocalizer.getTemporaryPath(PigContext pigContext)
|
static org.apache.hadoop.fs.Path |
FileLocalizer.getTemporaryPath(PigContext pigContext,
String suffix)
|
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)
|
Constructors in org.apache.pig.impl.io with parameters of type PigContext | |
---|---|
ReadToEndLoader(LoadFunc wrappedLoadFunc,
org.apache.hadoop.conf.Configuration conf,
String inputLocation,
int splitIndex,
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.isLocal(PigContext pigContext,
org.apache.hadoop.conf.Configuration conf)
|
static void |
Utils.setTmpFileCompressionOnConf(PigContext pigContext,
org.apache.hadoop.conf.Configuration conf)
|
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 |
LogicalPlan.optimize(PigContext pigContext)
|
void |
LogToPhyTranslationVisitor.setPigContext(PigContext pc)
|
void |
LogicalPlan.validate(PigContext pigContext,
String scope,
boolean skipInputOutputValidation)
|
Uses of PigContext in org.apache.pig.newplan.logical.visitor |
---|
Constructors in org.apache.pig.newplan.logical.visitor with parameters of type PigContext | |
---|---|
InputOutputFileValidatorVisitor(OperatorPlan plan,
PigContext pigContext)
|
|
ScalarVisitor(OperatorPlan plan,
PigContext pigContext,
String scope)
|
Uses of PigContext in org.apache.pig.parser |
---|
Methods in org.apache.pig.parser with parameters of type PigContext | |
---|---|
static void |
QueryParserUtils.attachStorePlan(String scope,
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.groovy |
---|
Methods in org.apache.pig.scripting.groovy with parameters of type PigContext | |
---|---|
protected Map<String,List<PigStats>> |
GroovyScriptEngine.main(PigContext context,
String scriptFile)
|
void |
GroovyScriptEngine.registerFunctions(String path,
String namespace,
PigContext pigContext)
|
Uses of PigContext in org.apache.pig.scripting.jruby |
---|
Methods in org.apache.pig.scripting.jruby with parameters of type PigContext | |
---|---|
protected Map<String,List<PigStats>> |
JrubyScriptEngine.main(PigContext pigContext,
String scriptFile)
|
void |
JrubyScriptEngine.registerFunctions(String path,
String namespace,
PigContext pigContext)
Evaluates the script containing ruby udfs to determine what udfs are defined as well as what libaries and other external resources are necessary. |
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 | |
---|---|
void |
JythonScriptEngine.load(InputStream script,
String scriptFile,
PigContext pigContext)
execs the script text using the interpreter. |
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.scripting.streaming.python |
---|
Methods in org.apache.pig.scripting.streaming.python with parameters of type PigContext | |
---|---|
protected Map<String,List<PigStats>> |
PythonScriptEngine.main(PigContext context,
String scriptFile)
|
void |
PythonScriptEngine.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 |
---|
Fields in org.apache.pig.tools.pigstats declared as PigContext | |
---|---|
protected PigContext |
ScriptState.pigContext
|
protected PigContext |
PigStats.pigContext
|
Methods in org.apache.pig.tools.pigstats that return PigContext | |
---|---|
PigContext |
ScriptState.getPigContext()
|
PigContext |
PigStats.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)
Deprecated. use ScriptState.start(ScriptState) instead. |
Constructors in org.apache.pig.tools.pigstats with parameters of type PigContext | |
---|---|
EmptyPigStats(PigContext pigContext,
POStore poStore)
|
Uses of PigContext in org.apache.pig.tools.pigstats.mapreduce |
---|
Methods in org.apache.pig.tools.pigstats.mapreduce with parameters of type PigContext | |
---|---|
static void |
MRPigStatsUtil.startCollection(PigContext pc,
org.apache.hadoop.mapred.JobClient client,
JobControlCompiler jcc,
MROperPlan plan)
Starts collecting statistics for the given MR plan |
Uses of PigContext in org.apache.pig.validator |
---|
Constructors in org.apache.pig.validator with parameters of type PigContext | |
---|---|
BlackAndWhitelistValidator(PigContext pigContext,
OperatorPlan operatorPlan)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |