Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
STORER_ERROR_COUNT |
"bad_record_count" |
public static final String |
STORER_ERROR_HANDLER_COUNTER_GROUP |
"storer_Error_Handler" |
public static final String |
STORER_RECORD_COUNT |
"record__count" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
PROGRESS_NOTIFICATION_LISTENER_ARG_KEY |
"pig.notification.listener.arg" |
protected static final String |
PROGRESS_NOTIFICATION_LISTENER_KEY |
"pig.notification.listener" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CALLER_ID |
"pig.log.trace.id" |
public static final String |
ENABLE_ATS |
"pig.ats.enabled" |
public static final String |
INSERT_ENABLED |
"pig.script.info.enabled" |
public static final String |
MAX_SCRIPT_SIZE |
"pig.script.max.size" |
public static final String |
OPT_FETCH |
"opt.fetch" |
public static final String |
PARTAGG_MINREDUCTION |
"pig.exec.mapPartAgg.minReduction" |
public static final String |
PIG_ACCUMULATIVE_BATCHSIZE |
"pig.accumulative.batchsize" |
public static final String |
PIG_ARTIFACTS_DOWNLOAD_LOCATION |
"pig.artifacts.download.location" |
public static final String |
PIG_ATS_ENABLED |
"pig.ats.enabled" |
public static final String |
PIG_AUTO_LOCAL_ENABLED |
"pig.auto.local.enabled" |
public static final String |
PIG_AUTO_LOCAL_INPUT_MAXBYTES |
"pig.auto.local.input.maxbytes" |
public static final String |
PIG_BLACKLIST |
"pig.blacklist" |
public static final String |
PIG_BLOOMJOIN_HASH_FUNCTIONS |
"pig.bloomjoin.hash.functions" |
public static final String |
PIG_BLOOMJOIN_HASH_TYPE |
"pig.bloomjoin.hash.type" |
public static final String |
PIG_BLOOMJOIN_NUM_FILTERS |
"pig.bloomjoin.num.filters" |
public static final String |
PIG_BLOOMJOIN_STRATEGY |
"pig.bloomjoin.strategy" |
public static final String |
PIG_BLOOMJOIN_VECTORSIZE_BYTES |
"pig.bloomjoin.vectorsize.bytes" |
public static final String |
PIG_BZIP_USE_HADOOP_INPUTFORMAT |
"pig.bzip.use.hadoop.inputformat" |
public static final String |
PIG_CACHEDBAG_DISTINCT_TYPE |
"pig.cachedbag.distinct.type" |
public static final String |
PIG_CACHEDBAG_MEMUSAGE |
"pig.cachedbag.memusage" |
public static final String |
PIG_CACHEDBAG_SORT_TYPE |
"pig.cachedbag.sort.type" |
public static final String |
PIG_CACHEDBAG_TYPE |
"pig.cachedbag.type" |
public static final String |
PIG_COMPRESS_INPUT_SPLITS |
"pig.compress.input.splits" |
public static final boolean |
PIG_COMPRESS_INPUT_SPLITS_DEFAULT |
false |
public static final String |
PIG_DATETIME_DEFAULT_TIMEZONE |
"pig.datetime.default.tz" |
public static final String |
PIG_DEFAULT_LOAD_FUNC |
"pig.default.load.func" |
public static final String |
PIG_DEFAULT_STORE_FUNC |
"pig.default.store.func" |
public static final String |
PIG_DELETE_TEMP_FILE |
"pig.delete.temp.files" |
public static final String |
PIG_ENABLE_TEMP_FILE_COMPRESSION |
"pig.tmpfilecompression" |
public static final String |
PIG_ERROR_HANDLING_ENABLED |
"pig.error-handling.enabled" |
public static final String |
PIG_ERROR_HANDLING_MIN_ERROR_RECORDS |
"pig.error-handling.min.error.records" |
public static final String |
PIG_ERROR_HANDLING_THRESHOLD_PERCENT |
"pig.error-handling.error.threshold" |
public static final String |
PIG_EXEC_MAP_PARTAGG |
"pig.exec.mapPartAgg" |
public static final String |
PIG_EXEC_MAP_PARTAGG_MINREDUCTION |
"pig.exec.mapPartAgg.minReduction" |
public static final String |
PIG_EXEC_NO_COMBINER |
"pig.exec.nocombiner" |
public static final String |
PIG_EXEC_NO_COMBINER_REDUCER |
"pig.exec.nocombiner.reducer" |
public static final String |
PIG_EXEC_NO_SECONDARY_KEY |
"pig.exec.nosecondarykey" |
public static final String |
PIG_EXEC_REDUCER_ESTIMATOR |
"pig.exec.reducer.estimator" |
public static final String |
PIG_EXEC_REDUCER_ESTIMATOR_CONSTRUCTOR_ARG_KEY |
"pig.exec.reducer.estimator.arg" |
public static final String |
PIG_JOIN_REPLICATED_MAX_BYTES |
"pig.join.replicated.max.bytes" |
public static final String |
PIG_LOG_TRACE_ID |
"pig.log.trace.id" |
public static final String |
PIG_MAX_COMBINED_SPLIT_SIZE |
"pig.maxCombinedSplitSize" |
public static final String |
PIG_NO_SPLIT_COMBINATION |
"pig.noSplitCombination" |
public static final String |
PIG_NO_TASK_REPORT |
"pig.stats.notaskreport" |
public static final String |
PIG_OPT_ACCUMULATOR |
"opt.accumulator" |
public static final String |
PIG_OPT_FETCH |
"opt.fetch" |
public static final String |
PIG_OPT_MULTIQUERY |
"opt.multiquery" |
public static final String |
PIG_OUTPUT_COMMITTER_RECOVERY |
"pig.output.committer.recovery.support" |
public static final String |
PIG_OUTPUT_LAZY |
"pig.output.lazy" |
public static final String |
PIG_POISSON_SAMPLER_SAMPLE_RATE |
"pig.sksampler.samplerate" |
public static final String |
PIG_PRINT_EXEC_PLAN |
"pig.print.exec.plan" |
public static final String |
PIG_RANDOM_SAMPLER_SAMPLE_SIZE |
"pig.random.sampler.sample.size" |
public static final String |
PIG_SCHEMA_TUPLE_ALLOW_FORCE |
"pig.schematuple.force" |
public static final String |
PIG_SCHEMA_TUPLE_ENABLED |
"pig.schematuple" |
public static final String |
PIG_SCHEMA_TUPLE_USE_IN_FOREACH |
"pig.schematuple.foreach" |
public static final String |
PIG_SCHEMA_TUPLE_USE_IN_FRJOIN |
"pig.schematuple.fr_join" |
public static final String |
PIG_SCHEMA_TUPLE_USE_IN_MERGEJOIN |
"pig.schematuple.merge_join" |
public static final String |
PIG_SCHEMA_TUPLE_USE_IN_UDF |
"pig.schematuple.udf" |
public static final String |
PIG_SCRIPT_INFO_ENABLED |
"pig.script.info.enabled" |
public static final String |
PIG_SCRIPT_MAX_SIZE |
"pig.script.max.size" |
public static final String |
PIG_SKEWEDJOIN_REDUCE_MEM |
"pig.skewedjoin.reduce.mem" |
public static final String |
PIG_SKEWEDJOIN_REDUCE_MEMUSAGE |
"pig.skewedjoin.reduce.memusage" |
public static final String |
PIG_SORT_READONCE_LOADFUNCS |
"pig.sort.readonce.loadfuncs" |
public static final String |
PIG_SPARK_USE_NETTY_FILESERVER |
"pig.spark.rpc.useNettyFileServer" |
public static final String |
PIG_SPILL_COLLECTION_THRESHOLD_FRACTION |
"pig.spill.collection.threshold.fraction" |
public static final String |
PIG_SPILL_MEMORY_USAGE_THRESHOLD_FRACTION |
"pig.spill.memory.usage.threshold.fraction" |
public static final String |
PIG_SPILL_UNUSED_MEMORY_THRESHOLD_SIZE |
"pig.spill.unused.memory.threshold.size" |
public static final String |
PIG_SPLIT_COMBINATION |
"pig.splitCombination" |
public static final String |
PIG_STORE_SCHEMA_DISAMBIGUATE |
"pig.store.schema.disambiguate" |
public static final String |
PIG_STORE_SCHEMA_DISAMBIGUATE_DEFAULT |
"true" |
public static final String |
PIG_STREAMING_ENVIRONMENT |
"pig.streaming.environment" |
public static final String |
PIG_STREAMING_UDF_PYTHON_COMMAND |
"pig.streaming.udf.python.command" |
public static final String |
PIG_TEMP_DIR |
"pig.temp.dir" |
public static final String |
PIG_TEMP_FILE_COMPRESSION_CODEC |
"pig.tmpfilecompression.codec" |
public static final String |
PIG_TEMP_FILE_COMPRESSION_STORAGE |
"pig.tmpfilecompression.storage" |
public static final String |
PIG_TEZ_AUTO_PARALLELISM |
"pig.tez.auto.parallelism" |
public static final String |
PIG_TEZ_AUTO_PARALLELISM_DISABLE_DAG_RECOVERY |
"pig.tez.auto.parallelism.disable.dag.recovery" |
public static final String |
PIG_TEZ_CONFIGURE_AM_MEMORY |
"pig.tez.configure.am.memory" |
public static final String |
PIG_TEZ_DAG_STATUS_REPORT_INTERVAL |
"pig.tez.dag.status.report.interval" |
public static final String |
PIG_TEZ_GRACE_PARALLELISM |
"pig.tez.grace.parallelism" |
public static final String |
PIG_TEZ_INPUT_SPLITS_MEM_THRESHOLD |
"pig.tez.input.splits.mem.threshold" |
public static final int |
PIG_TEZ_INPUT_SPLITS_MEM_THRESHOLD_DEFAULT |
33554432 |
public static final String |
PIG_TEZ_OPT_UNION |
"pig.tez.opt.union" |
public static final String |
PIG_TEZ_OPT_UNION_SUPPORTED_STOREFUNCS |
"pig.tez.opt.union.supported.storefuncs" |
public static final String |
PIG_TEZ_OPT_UNION_UNSUPPORTED_STOREFUNCS |
"pig.tez.opt.union.unsupported.storefuncs" |
public static final String |
PIG_TEZ_SESSION_REUSE |
"pig.tez.session.reuse" |
public static final String |
PIG_UDF_PROFILE |
"pig.udf.profile" |
public static final String |
PIG_UDF_PROFILE_FREQUENCY |
"pig.udf.profile.frequency" |
public static final String |
PIG_USER_CACHE_ENABLED |
"pig.user.cache.enabled" |
public static final String |
PIG_USER_CACHE_LOCATION |
"pig.user.cache.location" |
public static final String |
PIG_USER_CACHE_REPLICATION |
"pig.user.cache.replication" |
public static final String |
PIG_WHITELIST |
"pig.whitelist" |
public static final String |
PROP_CACHEDBAG_MEMUSAGE |
"pig.cachedbag.memusage" |
public static final String |
PROP_EXEC_MAP_PARTAGG |
"pig.exec.mapPartAgg" |
public static final String |
PROP_NO_COMBINER |
"pig.exec.nocombiner" |
public static final String |
SCHEMA_TUPLE_SHOULD_ALLOW_FORCE |
"pig.schematuple.force" |
public static final String |
SCHEMA_TUPLE_SHOULD_USE_IN_FOREACH |
"pig.schematuple.foreach" |
public static final String |
SCHEMA_TUPLE_SHOULD_USE_IN_FRJOIN |
"pig.schematuple.fr_join" |
public static final String |
SCHEMA_TUPLE_SHOULD_USE_IN_MERGEJOIN |
"pig.schematuple.merge_join" |
public static final String |
SCHEMA_TUPLE_SHOULD_USE_IN_UDF |
"pig.schematuple.udf" |
public static final String |
SHOULD_USE_SCHEMA_TUPLE |
"pig.schematuple" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
GENERATED_CLASSES_KEY |
"pig.schematuple.classes" |
public static final String |
LOCAL_CODE_DIR |
"pig.schematuple.local.dir" |
public static final String |
PIG_LOCAL_CONF_PREFIX |
"pig.local." |
public static final String |
PIG_OPTIMIZER_RULES_DISABLED_KEY |
"pig.optimizer.rules.disabled" |
public static final boolean |
SCHEMA_TUPLE_ON_BY_DEFAULT |
false |
public static final String |
TASK_INDEX |
"mapreduce.task.index" |
public static final String |
TIME_UDFS_ELAPSED_TIME_COUNTER |
"approx_microsecs" |
public static final String |
TIME_UDFS_INVOCATION_COUNTER |
"approx_invocations" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
BUG |
4 |
public static final byte |
ERROR |
-1 |
public static final byte |
INPUT |
2 |
public static final byte |
REMOTE_ENVIRONMENT |
16 |
public static final byte |
USER_ENVIRONMENT |
8 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
FAILURE |
2 |
public static final int |
ILLEGAL_ARGS |
4 |
public static final int |
IO_EXCEPTION |
5 |
public static final int |
PARSE_EXCEPTION |
7 |
public static final int |
PARTIAL_FAILURE |
3 |
public static final int |
PIG_EXCEPTION |
6 |
public static final int |
RETRIABLE_EXCEPTION |
1 |
public static final int |
SUCCESS |
0 |
public static final int |
THROWABLE_EXCEPTION |
8 |
public static final int |
UNKNOWN |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PRETTY_PRINT_SCHEMA_PROPERTY |
"pig.pretty.print.schema" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
RAW_CAPACITY_KEY |
"pig.raw.capacity.bytes" |
public static final String |
RAW_USED_KEY |
"pig.raw.used.capacity.bytes" |
public static final String |
USED_BYTES_KEY |
"pig.used.bytes" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BLOCK_REPLICATION_KEY |
"pig.path.block.replication" |
public static final String |
BLOCK_SIZE_KEY |
"pig.path.block.size" |
public static final String |
LENGTH_KEY |
"pig.path.length" |
public static final String |
MODIFICATION_TIME_KEY |
"pig.path.modification.time" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PROGRESS_KEY |
"job.progress" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
AUDIT_ID_MAX_LENGTH |
128 |
public static final String |
CALLER_CONTEXT |
"PIG" |
public static final String |
ENTITY_CALLERID |
"callerId" |
public static final String |
ENTITY_TYPE |
"PIG_SCRIPT_ID" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
ASTERISK |
"*" |
protected static final char |
COLON |
58 |
protected static final char |
COMMA |
44 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CORE_DEFAULT_SITE |
"core-default.xml" |
public static final String |
CORE_SITE |
"core-site.xml" |
public static final String |
HADOOP_SITE |
"hadoop-site.xml" |
public static final String |
LOCAL |
"local" |
public static final String |
MAPRED_DEFAULT_SITE |
"mapred-default.xml" |
public static final String |
YARN_DEFAULT_SITE |
"yarn-default.xml" |
public static final String |
YARN_SITE |
"yarn-site.xml" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BIG_JOB_LOG_MSG |
"This job cannot be converted run in-process" |
public static final String |
END_OF_INP_IN_MAP |
"pig.invoke.close.in.map" |
public static final String |
LOG_DIR |
"_logs" |
public static final String |
PIG_MAP_COUNTER |
"pig.counters.counter_" |
public static final String |
PIG_MAP_RANK_NAME |
"pig.rank_" |
public static final String |
PIG_MAP_SEPARATOR |
"_" |
public static final String |
PIG_MAP_STORES |
"pig.map.stores" |
public static final String |
PIG_REDUCE_STORES |
"pig.reduce.stores" |
public static final String |
SMALL_JOB_LOG_MSG |
"This job was detected as a small job, will run in-process instead" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SUCCEEDED_FILE_NAME |
"_SUCCESS" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FILE_CONCATENATION_THRESHOLD |
"pig.files.concatenation.threshold" |
public static final String |
OPTIMISTIC_FILE_CONCATENATION |
"pig.optimistic.files.concatenation" |
public static final String |
USER_COMPARATOR_MARKER |
"user.comparator.func:" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CHILD_JAVA_OPTS |
"mapred.child.java.opts" |
public static final String |
FILEOUTPUTCOMMITTER_MARKSUCCESSFULJOBS |
"mapreduce.fileoutputcommitter.marksuccessfuljobs" |
public static final String |
FRAMEWORK_NAME |
"mapreduce.framework.name" |
public static final String |
INPUT_DIR |
"mapred.input.dir" |
public static final String |
INPUT_DIR_RECURSIVE |
"mapred.input.dir.recursive" |
public static final String |
INPUTFORMAT_CLASS |
"mapreduce.inputformat.class" |
public static final String |
IO_SORT_MB |
"mapred.io.sort.mb" |
public static final String |
JAR |
"mapred.jar" |
public static final String |
JOB_APPLICATION_ATTEMPT_ID |
"mapreduce.job.application.attempt.id" |
public static final String |
JOB_CACHE_FILES |
"mapreduce.job.cache.files" |
public static final String |
JOB_CREDENTIALS_BINARY |
"mapreduce.job.credentials.binary" |
public static final String |
JOB_CREDENTIALS_JSON |
"mapreduce.job.credentials.json" |
public static final String |
JOB_END_NOTIFICATION_RETRY_INTERVAL |
"mapreduce.job.end-notification.retry.interval" |
public static final String |
JOB_HDFS_SERVERS |
"mapreduce.job.hdfs-servers" |
public static final String |
JOB_ID |
"mapred.job.id" |
public static final String |
JOB_NAME |
"mapred.job.name" |
public static final String |
JOB_PRIORITY |
"mapred.job.priority" |
public static final String |
JOB_QUEUE_NAME |
"mapred.job.queue.name" |
public static final String |
JOB_REDUCE_MARKRESET_BUFFER_PERCENT |
"mapred.job.reduce.markreset.buffer.percent" |
public static final String |
JOB_REDUCES |
"mapreduce.job.reduces" |
public static final String |
JOB_TRACKER |
"mapred.job.tracker" |
public static final String |
JOB_TRACKER_HTTP_ADDRESS |
"mapred.job.tracker.http.address" |
public static final String |
LINERECORDREADER_MAXLENGTH |
"mapred.linerecordreader.maxlength" |
public static final String |
MAP_MAX_ATTEMPTS |
"mapred.map.max.attempts" |
public static final String |
MAP_TASKS |
"mapred.map.tasks" |
public static final String |
MAPPER_NEW_API |
"mapred.mapper.new-api" |
public static final String |
MAX_SPLIT_SIZE |
"mapred.max.split.size" |
public static final String |
OUTPUT_BASENAME |
"mapreduce.output.basename" |
public static final String |
OUTPUT_COMPRESS |
"mapred.output.compress" |
public static final String |
OUTPUT_COMPRESSION_CODEC |
"mapred.output.compression.codec" |
public static final String |
OUTPUT_DIR |
"mapred.output.dir" |
public static final String |
REDUCE_MAX_ATTEMPTS |
"mapred.reduce.max.attempts" |
public static final String |
REDUCE_TASKS |
"mapred.reduce.tasks" |
public static final String |
REDUCER_NEW_API |
"mapred.reducer.new-api" |
public static final String |
SUMIT_REPLICATION |
"mapred.submit.replication" |
public static final String |
TASK_ID |
"mapred.task.id" |
public static final String |
TASK_IS_MAP |
"mapred.task.is.map" |
public static final String |
TASK_PARTITION |
"mapred.task.partition" |
public static final String |
TASK_TIMEOUT |
"mapred.task.timeout" |
public static final String |
TEXTOUTPUTFORMAT_SEPARATOR |
"mapred.textoutputformat.separator" |
public static final String |
WORK_OUPUT_DIR |
"mapred.work.output.dir" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PIG_INPUT_LIMITS |
"pig.inpLimits" |
public static final String |
PIG_INPUT_SIGNATURES |
"pig.inpSignatures" |
public static final String |
PIG_INPUT_TARGETS |
"pig.inpTargets" |
public static final String |
PIG_INPUTS |
"pig.inputs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
PIG_MAPRED_OUTPUT_DIR |
"pig.mapred.output.dir" |
public static final String |
PIG_TMP_PATH |
"pig.tmp.path" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
BYTES_PER_REDUCER_PARAM |
"pig.exec.reducers.bytes.per.reducer" |
public static final long |
DEFAULT_BYTES_PER_REDUCER |
1000000000L |
public static final int |
DEFAULT_MAX_REDUCER_COUNT_PARAM |
999 |
public static final String |
MAX_REDUCER_COUNT_PARAM |
"pig.exec.reducers.max" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
OUTPUT_SIZE_READER_KEY |
"pig.stats.output.size.reader" |
public static final String |
OUTPUT_SIZE_READER_UNSUPPORTED |
"pig.stats.output.size.reader.unsupported" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
STATUS_BATCH_OK |
5 |
public static final byte |
STATUS_EARLY_TERMINATION |
6 |
public static final byte |
STATUS_EOP |
3 |
public static final byte |
STATUS_EOS |
4 |
public static final byte |
STATUS_ERR |
2 |
public static final byte |
STATUS_NULL |
1 |
public static final byte |
STATUS_OK |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final short |
BIGDECIMAL_MINIMAL_SCALE |
6 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
FINAL |
2 |
public static final byte |
INITIAL |
0 |
public static final byte |
INTERMEDIATE |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_CHUNK_SIZE |
"1000" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_SAMPLE_RATE |
17 |
protected static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final long |
serialVersionUID |
1L |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
NULLPART_JOB_ID |
-1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FILE_CONCATENATION_THRESHOLD |
"pig.files.concatenation.threshold" |
public static final String |
OPTIMISTIC_FILE_CONCATENATION |
"pig.optimistic.files.concatenation" |
public static final String |
USER_COMPARATOR_MARKER |
"user.comparator.func:" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
DEFAULT_BLOOM_HASH_TYPE |
"murmur" |
public static final String |
DEFAULT_BLOOM_STRATEGY |
"map" |
public static final int |
DEFAULT_BLOOM_VECTOR_SIZE_BYTES |
1048576 |
public static final int |
DEFAULT_NUM_BLOOM_FILTERS_REDUCE |
11 |
public static final int |
DEFAULT_NUM_BLOOM_HASH_FUNCTIONS |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
COMBINE_PLAN |
"pig.exec.tez.combine.plan" |
public static final String |
ESTIMATE_PARALLELISM |
"pig.exec.estimate.parallelism" |
public static final String |
ESTIMATED_NUM_PARALLELISM |
"pig.exec.estimated.num.parallelism" |
public static final String |
PLAN |
"pig.exec.tez.plan" |
public static final String |
SAMPLE_VERTEX |
"pig.sampleVertex" |
public static final String |
SORT_VERTEX |
"pig.sortVertex" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FILE_SYSTEM_NAME |
"fs.defaultFS" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
INPUT_AVRO_SCHEMA |
"org.apache.pig.builtin.AvroStorage.input.schema" |
public static final String |
OUTPUT_AVRO_SCHEMA |
"org.apache.pig.builtin.AvroStorage.output.schema" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
BAG |
22 |
public static final byte |
BIGDECIMAL |
47 |
public static final byte |
BIGINTEGER |
46 |
public static final byte |
BOOLEAN_FALSE |
1 |
public static final byte |
BOOLEAN_TRUE |
0 |
public static final byte |
BYTE |
2 |
public static final byte |
BYTEARRAY |
11 |
public static final byte |
CHARARRAY |
14 |
public static final byte |
DATETIME |
48 |
public static final byte |
DOUBLE |
10 |
public static final byte |
FLOAT |
9 |
public static final byte |
GENERIC_WRITABLECOMPARABLE |
25 |
public static final byte |
INTEGER |
3 |
public static final byte |
INTEGER_0 |
4 |
public static final byte |
INTEGER_1 |
5 |
public static final byte |
INTEGER_INBYTE |
7 |
public static final byte |
INTEGER_INSHORT |
6 |
public static final byte |
INTERNALMAP |
26 |
public static final byte |
LONG |
8 |
public static final byte |
LONG_0 |
34 |
public static final byte |
LONG_1 |
35 |
public static final byte |
LONG_INBYTE |
31 |
public static final byte |
LONG_ININT |
33 |
public static final byte |
LONG_INSHORT |
32 |
public static final byte |
MAP |
16 |
public static final byte |
NULL |
27 |
public static final byte |
SCHEMA_TUPLE |
30 |
public static final byte |
SCHEMA_TUPLE_BYTE_INDEX |
28 |
public static final byte |
SCHEMA_TUPLE_SHORT_INDEX |
29 |
public static final byte |
SMALLBAG |
23 |
public static final byte |
SMALLBYTEARRAY |
12 |
public static final byte |
SMALLCHARARRAY |
15 |
public static final byte |
SMALLMAP |
17 |
public static final byte |
SMALLTUPLE |
20 |
public static final byte |
TINYBAG |
24 |
public static final byte |
TINYBYTEARRAY |
13 |
public static final byte |
TINYMAP |
18 |
public static final byte |
TINYTUPLE |
21 |
public static final byte |
TUPLE |
19 |
public static final byte |
TUPLE_0 |
36 |
public static final byte |
TUPLE_1 |
37 |
public static final byte |
TUPLE_2 |
38 |
public static final byte |
TUPLE_3 |
39 |
public static final byte |
TUPLE_4 |
40 |
public static final byte |
TUPLE_5 |
41 |
public static final byte |
TUPLE_6 |
42 |
public static final byte |
TUPLE_7 |
43 |
public static final byte |
TUPLE_8 |
44 |
public static final byte |
TUPLE_9 |
45 |
public static final int |
UNSIGNED_BYTE_MAX |
255 |
public static final int |
UNSIGNED_SHORT_MAX |
65535 |
public static final String |
UTF8 |
"UTF-8" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
UTF8 |
"UTF-8" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
BAG |
120 |
public static final byte |
BIGCHARARRAY |
60 |
public static final byte |
BIGDECIMAL |
70 |
public static final byte |
BIGINTEGER |
65 |
public static final byte |
BOOLEAN |
5 |
public static final byte |
BYTE |
6 |
public static final byte |
BYTEARRAY |
50 |
public static final byte |
CHARARRAY |
55 |
public static final byte |
DATETIME |
30 |
public static final byte |
DOUBLE |
25 |
public static final byte |
ERROR |
-1 |
public static final byte |
FLOAT |
20 |
public static final byte |
GENERIC_WRITABLECOMPARABLE |
123 |
public static final byte |
INTEGER |
10 |
public static final byte |
INTERNALMAP |
127 |
public static final byte |
LONG |
15 |
public static final byte |
MAP |
100 |
public static final byte |
NULL |
1 |
public static final byte |
TUPLE |
110 |
public static final byte |
UNKNOWN |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final int |
MAX_SPILL_FILES |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
NOTNULL |
1 |
public static final byte |
NULL |
0 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
JOB_NAME |
"jobName" |
public static final String |
JOB_NAME_PREFIX |
"PigLatin" |
public static final String |
JOB_PRIORITY |
"jobPriority" |
public static final String |
PIG_CMD_ARGS_REMAINDERS |
"pig.cmd.args.remainders" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
CONVERTED_TO_FETCH |
"pig.job.converted.fetch" |
public static final String |
CONVERTED_TO_LOCAL |
"pig.job.converted.local" |
public static final String |
PIG_AUDIT_ID |
"pig.script.id" |
public static final String |
PIG_CONTEXT |
"pig.pigContext" |
public static final String |
PIG_CROSS_PARALLELISM |
"pig.cross.parallelism" |
public static final String |
PIG_DATETIME_ZONES_LIST |
"pig.datetime.zones.list" |
public static final String |
PIG_EXECTYPE_MODE_LOCAL |
"pig.exectype.mode.local" |
public static final String |
PIG_LOG4J_PROPERTIES |
"pig.log4j.properties" |
public static final String |
PIG_OPTIMIZER_RULES_KEY |
"pig.optimizer.rules" |
public static final String |
PIG_SPLIT_INDEX |
"pig.split.index" |
public static final String |
REDUCER_DEFAULT_PARALLELISM |
"pig.info.reducers.default.parallel" |
public static final String |
REDUCER_ESTIMATED_PARALLELISM |
"pig.info.reducers.estimated.parallel" |
public static final String |
REDUCER_REQUESTED_PARALLELISM |
"pig.info.reducers.requested.parallel" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
QUANTILES_LIST |
"quantiles.list" |
public static final String |
WEIGHTED_PARTS |
"weighted.parts" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
defaultNumGroups |
1000 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final float |
DEFAULT_PERCENT_MEMUSAGE |
0.30000001192092896f |
public static final String |
PARTITION_LIST |
"partition.list" |
public static final String |
TOTAL_REDUCERS |
"totalreducers" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NUMROWS_TUPLE_MARKER |
"\u4956\u3838_pig_inTeRnal-spEcial_roW_num_tuple3kt579CFLehkblah" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
TURN_ON_OUTPUT_CAPTURING |
"TURN_ON_OUTPUT_CAPTURING" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
RECORD_1 |
1 |
public static final int |
RECORD_2 |
2 |
public static final int |
RECORD_3 |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
RECORD_1 |
1 |
public static final int |
RECORD_2 |
2 |
public static final int |
RECORD_3 |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
LOCAL_PREFIX |
"file:" |
public static final int |
STYLE_UNIX |
0 |
public static final int |
STYLE_WINDOWS |
1 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
RECORD_1 |
1 |
public static final int |
RECORD_2 |
2 |
public static final int |
RECORD_3 |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
RECORD_1 |
1 |
public static final int |
RECORD_2 |
2 |
public static final int |
RECORD_3 |
3 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
useLog |
"Pig Internal storage in use" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final byte |
idxSpace |
127 |
public static final byte |
mqFlag |
-128 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
useLog |
"SequenceFile storage in use" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
useLog |
"TFile storage in use" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_TASKS |
100 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected final int |
hashPrime |
31 |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
DEFAULT_SCOPE |
"scope" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
INPUTUIDS |
"ColumnPrune:InputUids" |
public static final String |
OUTPUTUIDS |
"ColumnPrune:OutputUids" |
protected static final String |
REQUIREDCOLS |
"ColumnPrune:RequiredColumns" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
REQUIRED_MAPKEYS |
"MapPruner:RequiredKeys" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ERR_MSG_SCALAR |
"Expression in Limit/Sample should be scalar" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
MAX_DATAATOM_LENGTH |
25 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
EMPTY_STRING |
"" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final byte |
CARRIAGE_RETURN |
13 |
protected static final byte |
DOUBLE_QUOTE |
34 |
protected static final byte |
LINEFEED |
10 |
protected static final byte |
RECORD_DEL |
10 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FILE_EXTENSION_LOADERS |
"file.extension.loaders" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DETAILS |
5 |
public static final int |
FUNC_CALL |
3 |
public static final int |
INFO |
2 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final int |
DEFAULT_DEFLATE_LEVEL |
1 |
public static final String |
DEFLATE_CODEC |
"deflate" |
public static final String |
DEFLATE_LEVEL_KEY |
"avro.mapred.deflate.level" |
public static final String |
EXT |
".avro" |
public static final String |
OUTPUT_CODEC |
"avro.output.codec" |
public static final String |
SYNC_INTERVAL_KEY |
"avro.mapred.sync.interval" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FIELD_NAME |
"FIELD" |
public static final String |
TUPLE_NAME |
"TUPLE" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
NAMESPACE_SEPARATOR |
"." |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final char |
EndOfOpts |
45 |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
ALIAS |
"JobStatistics:alias" |
public static final String |
ALIAS_LOCATION |
"JobStatistics:alias_location" |
public static final String |
FEATURE |
"JobStatistics:feature" |
Modifier and Type | Constant Field | Value |
---|---|---|
protected static final String |
DATE_FORMAT |
"yyyy-MM-dd HH:mm:ss" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FILE_BYTES_READ |
"FILE_BYTES_READ" |
public static final String |
FILE_BYTES_WRITTEN |
"FILE_BYTES_WRITTEN" |
public static final String |
FS_COUNTER_GROUP |
"org.apache.hadoop.mapreduce.FileSystemCounter" |
public static final String |
HDFS_BYTES_READ |
"HDFS_BYTES_READ" |
public static final String |
HDFS_BYTES_WRITTEN |
"HDFS_BYTES_WRITTEN" |
public static final String |
MAP_INPUT_RECORDS |
"MAP_INPUT_RECORDS" |
public static final String |
MAP_OUTPUT_RECORDS |
"MAP_OUTPUT_RECORDS" |
public static final String |
MULTI_INPUTS_COUNTER_GROUP |
"MultiInputCounters" |
public static final String |
MULTI_INPUTS_RECORD_COUNTER |
"Input records from " |
public static final String |
MULTI_STORE_COUNTER_GROUP |
"MultiStoreCounters" |
public static final String |
MULTI_STORE_RECORD_COUNTER |
"Output records in " |
public static final String |
REDUCE_INPUT_RECORDS |
"REDUCE_INPUT_RECORDS" |
public static final String |
REDUCE_OUTPUT_RECORDS |
"REDUCE_OUTPUT_RECORDS" |
public static final String |
TASK_COUNTER_GROUP |
"org.apache.hadoop.mapred.Task$Counter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FAILURE_HEADER |
"JobId\tAlias\tFeature\tMessage\tOutputs" |
public static final String |
SUCCESS_HEADER |
"JobId\tMaps\tReduces\tMaxMapTime\tMinMapTime\tAvgMapTime\tMedianMapTime\tMaxReduceTime\tMinReduceTime\tAvgReduceTime\tMedianReducetime\tAlias\tFeature\tOutputs" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
FS_COUNTER_GROUP |
"org.apache.hadoop.mapreduce.FileSystemCounter" |
public static final String |
TASK_COUNTER_GROUP |
"org.apache.hadoop.mapred.Task$Counter" |
Modifier and Type | Constant Field | Value |
---|---|---|
public static final String |
SPARK_INPUT_COUNTER_GROUP |
"MultiInputCounters" |
public static final String |
SPARK_INPUT_RECORD_COUNTER |
"Input records from " |
public static final String |
SPARK_STORE_COUNTER_GROUP |
"MultiStoreCounters" |
public static final String |
SPARK_STORE_RECORD_COUNTER |
"Output records in " |
Copyright © 2007-2017 The Apache Software Foundation