Package org.apache.pig.backend.hadoop.executionengine.fetch

Class Summary
FetchContext A dummy counter handling context for fetch tasks
FetchLauncher This class is responsible for executing the fetch task, saving the result to disk and do the necessary cleanup afterwards.
FetchOptimizer FetchOptimizer determines whether the entire physical plan is fetchable, meaning that the task's result can be directly read (fetched) from the underlying storage rather than creating MR jobs.
FetchPOStoreImpl This class is used to have a POStore write the output to the underlying storage via a output collector/record writer in case of a fetch task.
FetchProgressableReporter A dummy ProgressableReporter used for fetch tasks

Copyright © 2007-2012 The Apache Software Foundation