Search Java Classes and Packages
#Org.apache.pig.impl Classes and Interfaces - 117 results found.
| Name | Description | Type | Package | Framework |
| BagFormat | Class | org.apache.pig.impl.util | Apache Pig | |
| BinStorageInputFormat | Class | org.apache.pig.impl.io | Apache Pig | |
| BinStorageOutputFormat | Class | org.apache.pig.impl.io | Apache Pig | |
| BinStorageRecordReader | Treats keys as offset in file and value as line. | Class | org.apache.pig.impl.io | Apache Pig |
| BinStorageRecordWriter | Class | org.apache.pig.impl.io | Apache Pig | |
| BufferedPositionedInputStream | Class | org.apache.pig.impl.io | Apache Pig | |
| CanonicalNamer | A visitor to walk the logical plan and give canonical names fields. | Class | org.apache.pig.impl.logicalLayer | Apache Pig |
| CastUtils | Class | org.apache.pig.impl.util | Apache Pig | |
| CompilationMessageCollector | This class is used for collecting all messages (error + warning) in compilation process. | Class | org.apache.pig.impl.plan | Apache Pig |
| CompilationMessageCollector .Message | Class | org.apache.pig.impl.plan.CompilationMessageCollector | Apache Pig | |
| CompilationMessageCollector .MessageType | Class | org.apache.pig.impl.plan.CompilationMessageCollector | Apache Pig | |
| CompilerUtils | Class | org.apache.pig.impl.util | Apache Pig | |
| ConfigurationValidator | Class | org.apache.pig.impl.util | Apache Pig | |
| DefaultIndexableLoader | Used by MergeJoin . | Class | org.apache.pig.impl.builtin | Apache Pig |
| DefaultInputHandler | DefaultInputHandler handles the input for the Pig-Streaming executable in a synchronous manner by feeding it input | Class | org.apache.pig.impl.streaming | Apache Pig |
| DefaultOutputHandler | FileOutputHandler handles the output from the Pig-Streaming executable in an synchronous manner by reading its output | Class | org.apache.pig.impl.streaming | Apache Pig |
| DependencyOrderWalker | DependencyOrderWalker traverses the graph in such a way that no node is visited before all the nodes it depends on have been visited. | Class | org.apache.pig.impl.plan | Apache Pig |
| DepthFirstWalker | DepthFirstWalker traverses a plan in a depth first manner. | Class | org.apache.pig.impl.plan | Apache Pig |
| DotPlanDumper | This class puts everything that is needed to dump a plan in a format readable by graphviz's dot algorithm. | Class | org.apache.pig.impl.plan | Apache Pig |
| ExecutableManager | ExecutableManager manages an external executable which processes data The ExecutableManager is responsible for startup/teardown of | Class | org.apache.pig.impl.streaming | Apache Pig |
| FileInputHandler | FileInputHandler handles the input for the Pig-Streaming executable in an asynchronous manner by feeding it input | Class | org.apache.pig.impl.streaming | Apache Pig |
| FileLocalizer | Class | org.apache.pig.impl.io | Apache Pig | |
| FileLocalizer .DataStorageInputStreamIterator | Class | org.apache.pig.impl.io.FileLocalizer | Apache Pig | |
| FileLocalizer .FetchFileRet | Class | org.apache.pig.impl.io.FileLocalizer | Apache Pig | |
| FileOutputHandler | FileOutputHandler handles the output from the Pig-Streaming executable in an asynchronous manner by reading it from | Class | org.apache.pig.impl.streaming | Apache Pig |
| FileSpec | A simple class that specifies a file name and storage function which is used to read/write itSee Also:Serialized Form | Class | org.apache.pig.impl.io | Apache Pig |
| FindQuantiles | Class | org.apache.pig.impl.builtin | Apache Pig | |
| FrontendException | Class | org.apache.pig.impl.logicalLayer | Apache Pig | |
| GetMemNumRows | UDF to get memory size of a tuple and extracts number of rows value from special tuple created by PoissonSampleLoader | Class | org.apache.pig.impl.builtin | Apache Pig |
| GFAny | built-in grouping function; permits system to choose any grouping. | Class | org.apache.pig.impl.builtin | Apache Pig |
| GFCross | Class | org.apache.pig.impl.builtin | Apache Pig | |
| GFReplicate | Class | org.apache.pig.impl.builtin | Apache Pig | |
| HandlerFactory | Factory to create an InputHandler or OutputHandler depending on the specification of the StreamingCommand. | Class | org.apache.pig.impl.streaming | Apache Pig |
| IdentityColumn | Returns the input, used by DuplicateForEachColumnRewrite to rewrite duplicate columns in ForEach. | Class | org.apache.pig.impl.builtin | Apache Pig |
| IdentityHashSet | Class | org.apache.pig.impl.util | Apache Pig | |
| InputHandler | InputHandler is responsible for handling the input to the Pig-Streaming external command. | Class | org.apache.pig.impl.streaming | Apache Pig |
| InputHandler .InputType | Class | org.apache.pig.impl.streaming.InputHandler | Apache Pig | |
| InterRecordReader | A record reader used to read data written using InterRecordWriter It uses the default InterSedes object for deserialization. | Class | org.apache.pig.impl.io | Apache Pig |
| InterRecordWriter | A record reader used to write data compatible with InterRecordWriter It uses the default InterSedes object for serialization. | Class | org.apache.pig.impl.io | Apache Pig |
| InterStorage | LOAD FUNCTION FOR PIG INTERNAL USE ONLY! This load function is used for storing intermediate data between MR jobs of | Class | org.apache.pig.impl.io | Apache Pig |
| InterStorage .InterInputFormat | Class | org.apache.pig.impl.io.InterStorage | Apache Pig | |
| InterStorage .InterOutputFormat | Class | org.apache.pig.impl.io.InterStorage | Apache Pig | |
| JarManager | Class | org.apache.pig.impl.util | Apache Pig | |
| JavaCompilerHelper | Class | org.apache.pig.impl.util | Apache Pig | |
| JavaCompilerHelper .JavaSourceFromString | Class | org.apache.pig.impl.util.JavaCompilerHelper | Apache Pig | |
| LineageTracer | Class | org.apache.pig.impl.util | Apache Pig | |
| LinkedMultiMap | Class | org.apache.pig.impl.util | Apache Pig | |
| LogUtils | Class | org.apache.pig.impl.util | Apache Pig | |
| MapKeysInfo | Class | org.apache.pig.impl.plan | Apache Pig | |
| MultiMap | An implementation of multi-map. | Class | org.apache.pig.impl.util | Apache Pig |
| NodeIdGenerator | Class | org.apache.pig.impl.plan | Apache Pig | |
| NullableBag | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableBooleanWritable | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableBytesWritable | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableDateTimeWritable | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableDoubleWritable | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableFloatWritable | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableIntWritable | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableLongWritable | Class | org.apache.pig.impl.io | Apache Pig | |
| NullablePartitionWritable | NullablePartitionWritable is an adaptor class around PigNullableWritable that adds a partition index to the class. | Class | org.apache.pig.impl.io | Apache Pig |
| NullableText | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableTuple | Class | org.apache.pig.impl.io | Apache Pig | |
| NullableUnknownWritable | This class can be used when data type is 'Unknown' and there is a need for PigNullableWritable object. | Class | org.apache.pig.impl.io | Apache Pig |
| NumValCarrier | Class | org.apache.pig.impl.util | Apache Pig | |
| ObjectSerializer | Class | org.apache.pig.impl.util | Apache Pig | |
| Operator | Base class for all types of operators. | Class | org.apache.pig.impl.plan | Apache Pig |
| OperatorKey | Class | org.apache.pig.impl.plan | Apache Pig | |
| OperatorPlan | A generic graphing class for use by LogicalPlan, PhysicalPlan, etc. | Class | org.apache.pig.impl.plan | Apache Pig |
| OperatorPlan .IndexHelper | Class | org.apache.pig.impl.plan.OperatorPlan | Apache Pig | |
| OptimizerException | Class | org.apache.pig.impl.plan.optimizer | Apache Pig | |
| OutputHandler | OutputHandler is responsible for handling the output of the Pig-Streaming external command. | Class | org.apache.pig.impl.streaming | Apache Pig |
| OutputHandler .OutputType | Class | org.apache.pig.impl.streaming.OutputHandler | Apache Pig | |
| Pair | Copy of C++ STL pair container. | Class | org.apache.pig.impl.util | Apache Pig |
| PartitionSkewedKeys | Partition reducers for skewed keys. | Class | org.apache.pig.impl.builtin | Apache Pig |
| PigContext | Class | org.apache.pig.impl | Apache Pig | |
| PigFile | Class | org.apache.pig.impl.io | Apache Pig | |
| PigNullableWritable | A base class for all types that pig uses to move data between map and reduce. | Class | org.apache.pig.impl.io | Apache Pig |
| PlanDumper | This class dumps a nested plan to a print stream. | Class | org.apache.pig.impl.plan | Apache Pig |
| PlanException | Class | org.apache.pig.impl.plan | Apache Pig | |
| PlanValidationException | Class | org.apache.pig.impl.plan | Apache Pig | |
| PlanVisitor | A visitor mechanism for navigating and operating on a plan of Operators. | Class | org.apache.pig.impl.plan | Apache Pig |
| PlanWalker | PlanWalker encapsulates the logic to traverse a plan. | Class | org.apache.pig.impl.plan | Apache Pig |
| PoissonSampleLoader | See "Skewed Join sampler" in http://wiki. | Class | org.apache.pig.impl.builtin | Apache Pig |
| ProjectionMap | A struct detailing how a projection is altered by an operator. | Class | org.apache.pig.impl.plan | Apache Pig |
| ProjectionMap .Column | A wrapper for projection map columns to contain the input number, input column. | Class | org.apache.pig.impl.plan.ProjectionMap | Apache Pig |
| PropertiesUtil | Class | org.apache.pig.impl.util | Apache Pig | |
| RandomSampleLoader | A loader that samples the data. | Class | org.apache.pig.impl.builtin | Apache Pig |
| ReadScalars | ReadScalars reads a line from a file and returns it as its value. | Class | org.apache.pig.impl.builtin | Apache Pig |
| ReadToEndLoader | This is wrapper Loader which wraps a real LoadFunc underneath and allows to read a file completely starting a given split (indicated by a split index | Class | org.apache.pig.impl.io | Apache Pig |
| RequiredFields | A struct detailing how a projection is altered by an operator. | Class | org.apache.pig.impl.plan | Apache Pig |
| ResourceNotFoundException | Class | org.apache.pig.impl.io | Apache Pig | |
| ReverseDependencyOrderWalker | ReverseDependencyOrderWalker traverses the graph in such a way that no node is visited before all the nodes that are its successors on have been visited. | Class | org.apache.pig.impl.plan | Apache Pig |
| RewindableIterator | Class | org.apache.pig.impl.util | Apache Pig | |
| SampleLoader | Class | org.apache.pig.impl.builtin | Apache Pig | |
| Schema | The Schema class encapsulates the notion of a schema for a relational operator. | Class | org.apache.pig.impl.logicalLayer.schema | Apache Pig |
| Schema .FieldSchema | Class | org.apache.pig.impl.logicalLayer.schema.Schema | Apache Pig | |
| SchemaMergeException | Class | org.apache.pig.impl.logicalLayer.schema | Apache Pig | |
| SchemaUtil | A utility class for simplify the schema creation, especially for bag and tuple schema. | Class | org.apache.pig.impl.logicalLayer.schema | Apache Pig |
| Spillable | Interface | org.apache.pig.impl.util | Apache Pig | |
| SpillableMemoryManager | This class Tracks the tenured pool and a list of Spillable objects. | Class | org.apache.pig.impl.util | Apache Pig |
| StorageUtil | This util class provides methods that are shared by storage class PigStorage and streaming class PigStreaming | Class | org.apache.pig.impl.util | Apache Pig |
| StreamingCommand | StreamingCommand represents the specification of an external command to be executed in a Pig Query. | Class | org.apache.pig.impl.streaming | Apache Pig |
| StreamingCommand .Handle | Handle to communicate with the external process. | Class | org.apache.pig.impl.streaming.StreamingCommand | Apache Pig |
| StreamingCommand .HandleSpec | Specification about the usage of the StreamingCommand. | Class | org.apache.pig.impl.streaming.StreamingCommand | Apache Pig |
| StringUtils | Class | org.apache.pig.impl.util | Apache Pig | |
| TFileRecordReader | A record reader used to read data written using InterRecordWriter It uses the default InterSedes object for deserialization. | Class | org.apache.pig.impl.io | Apache Pig |
| TFileRecordWriter | A record reader used to write data compatible with InterRecordWriter It uses the default InterSedes object for serialization. | Class | org.apache.pig.impl.io | Apache Pig |
| TFileStorage | LOAD FUNCTION FOR PIG INTERNAL USE ONLY! This load function is used for storing intermediate data between MR jobs of a pig query. | Class | org.apache.pig.impl.io | Apache Pig |
| TFileStorage .TFileInputFormat | Class | org.apache.pig.impl.io.TFileStorage | Apache Pig | |
| TFileStorage .TFileOutputFormat | Class | org.apache.pig.impl.io.TFileStorage | Apache Pig | |
| TupleFormat | Default implementation of format of Tuple. | Class | org.apache.pig.impl.util | Apache Pig |
| TypeCheckerException | Class | org.apache.pig.impl.logicalLayer.validators | Apache Pig | |
| UDFContext | Class | org.apache.pig.impl.util | Apache Pig | |
| UriUtil | Class | org.apache.pig.impl.util | Apache Pig | |
| Utils | Class | org.apache.pig.impl.util | Apache Pig | |
| VisitorException | Class | org.apache.pig.impl.plan | Apache Pig | |
| WrappedIOException | Class | org.apache.pig.impl.util | Apache Pig | |