src/org/apache/pig/impl/PigImplConstants.java

/*
 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.pig.impl;

import org.apache.pig.classification.InterfaceAudience;

/**
 * Private, internal constants for use by Pig itself. Please see
 * {@link org.apache.pig.PigConstants} if looking for public constants.
 */
@InterfaceAudience.Private
public class PigImplConstants {

    private PigImplConstants() {
        throw new IllegalStateException();
    }

    /**
     * {@value} is a pig-internal properties key for serializing
     * the set of disabled optimizer rules.
     */
    public static final String PIG_OPTIMIZER_RULES_KEY = "pig.optimizer.rules";

    /**
     * Used by pig to indicate that current job is running in local mode (local/tez_local)
     * ie. ExecType.isLocal() is true
     */
    public static final String PIG_EXECTYPE_MODE_LOCAL = "pig.exectype.mode.local";

    /**
     * Used by pig to indicate that current job has been converted to run in local mode
     */
    public static final String CONVERTED_TO_LOCAL = "pig.job.converted.local";

    /**
     * Used by pig to indicate that current job has been converted to run in fetch mode
     */
    public static final String CONVERTED_TO_FETCH = "pig.job.converted.fetch";

    /**
     * Indicate the split index of the task. Used by merge cogroup
     */
    public static final String PIG_SPLIT_INDEX = "pig.split.index";

    /**
     * Parallelism for the reducer
     */
    public static final String REDUCER_DEFAULT_PARALLELISM = "pig.info.reducers.default.parallel";
    public static final String REDUCER_REQUESTED_PARALLELISM = "pig.info.reducers.requested.parallel";
    public static final String REDUCER_ESTIMATED_PARALLELISM = "pig.info.reducers.estimated.parallel";

    /**
     * Parallelism to be used for CROSS operation by GFCross UDF
     */
    public static final String PIG_CROSS_PARALLELISM = "pig.cross.parallelism";

    /**
     * Pig context
     */
    public static final String PIG_CONTEXT = "pig.pigContext";

    /**
     * Pig log4j properties
     */
    public static final String PIG_LOG4J_PROPERTIES = "pig.log4j.properties";

    /**
     * A unique id for a Pig session used as callerId for underlining component
     */
    public static final String PIG_AUDIT_ID = "pig.script.id";

    /**
     * Used to carry zone ID list from frontend to backend (generated by frontend during Job creation)
     */
    public static final String PIG_DATETIME_ZONES_LIST = "pig.datetime.zones.list";

    // Kill the jobs before cleaning up tmp files
    public static int SHUTDOWN_HOOK_JOB_KILL_PRIORITY = 3;
    public static int SHUTDOWN_HOOK_TMP_FILES_CLEANUP_PRIORITY = 2;
    public static int SHUTDOWN_HOOK_ATS_CLIENT_PRIORITY = 1;
}