public class SchemaTupleFrontend extends Object
Constructor and Description |
---|
SchemaTupleFrontend() |
Modifier and Type | Method and Description |
---|---|
static void |
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.
|
protected static void |
lazyReset(PigContext pigContext)
This is a method which caches a PigContext object that has had
relevant key values set by SchemaTupleBackend.
|
static int |
registerToGenerateIfPossible(Schema udfSchema,
boolean isAppendable,
SchemaTupleClassGenerator.GenContext context)
This method "registers" a Schema to be generated.
|
static void |
reset()
This allows the frontend/backend process to be repeated if on the same
JVM (as in testing).
|
public static void reset()
public static int registerToGenerateIfPossible(Schema udfSchema, boolean isAppendable, SchemaTupleClassGenerator.GenContext context)
udfSchema
- This is the Schema of a Tuple that we will potentially generateisAppendable
- This specifies whether or not we want the SchemaTuple to be appendablecontext
- This is the context in which users should be able to access the SchemaTuplepublic static void copyAllGeneratedToDistributedCache(PigContext pigContext, org.apache.hadoop.conf.Configuration conf)
pigContext
- conf
- protected static void lazyReset(PigContext pigContext)
Copyright © 2007-2017 The Apache Software Foundation