Examples of LogHelper

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

79
80
81
82
83
84
85
      // this here - but would have hit it in SemanticAnalyzer
      LOG.error(StringUtils.stringifyException(e));
      throw new RuntimeException (e);
    }

    console = new LogHelper(LOG);
  }
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

62
63
64
65
66
67
68
69
70
71
72
  transient protected Log LOG;
  transient protected LogHelper console;

  public FetchOperator(fetchWork work, JobConf job) {
    LOG = LogFactory.getLog(this.getClass().getName());
    console = new LogHelper(LOG);

    this.work = work;
    this.job = job;
   
    currRecReader = null;
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

81
82
83
84
85
86
87
88
89
90
91
    try {
      this.conf = conf;
      db = Hive.get(conf);
      rootTasks = new ArrayList<Task<? extends Serializable>>();
      LOG = LogFactory.getLog(this.getClass().getName());
      console = new LogHelper(LOG);
      this.idToTableNameMap = new  HashMap<String, String>();
      inputs = new LinkedHashSet<ReadEntity>();
      outputs = new LinkedHashSet<WriteEntity>();
    } catch (Exception e) {
      throw new SemanticException (e);
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

178
179
180
181
182
183
184
185
186
187
188
   * @param ss
   */
  public HiveHistory(SessionState ss) {

    try {
      console = new LogHelper(LOG);
      String conf_file_loc = ss.getConf().getVar(
          HiveConf.ConfVars.HIVEHISTORYFILELOC);
      if ((conf_file_loc == null) || conf_file_loc.length() == 0)
      {
        console.printError("No history file location given");
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

137
138
139
140
141
142
143
  public ExecDriver(mapredWork plan, JobConf job, boolean isSilent)
      throws HiveException {
    setWork(plan);
    this.job = job;
    LOG = LogFactory.getLog(this.getClass().getName());
    console = new LogHelper(LOG, isSilent);
  }
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
  @Override
  public void run(SessionState sess, Set<ReadEntity> inputs,
      Set<WriteEntity> outputs, UserGroupInformation ugi)
    throws Exception {

    LogHelper console = SessionState.getConsole();

    if (console == null)
      return;

    if (sess != null) {
      console.printError("POSTHOOK: query: " + sess.getCmd().trim());
      console.printError("POSTHOOK: type: " + sess.getCommandType());
    }

    for(ReadEntity re: inputs) {
      console.printError("POSTHOOK: Input: " + re.toString());
    }
    for(WriteEntity we: outputs) {
      console.printError("POSTHOOK: Output: " + we.toString());
    }
  }
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
  @Override
  public void run(SessionState sess, Set<ReadEntity> inputs,
      Set<WriteEntity> outputs, UserGroupInformation ugi)
    throws Exception {

    LogHelper console = SessionState.getConsole();

    if (console == null)
      return;

    if (sess != null) {
      console.printError("PREHOOK: query: " + sess.getCmd().trim());
      console.printError("PREHOOK: type: " + sess.getCommandType());
    }

    for(ReadEntity re: inputs) {
      console.printError("PREHOOK: Input: " + re.toString());
    }
    for(WriteEntity we: outputs) {
      console.printError("PREHOOK: Output: " + we.toString());
    }
  }
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

89
90
91
92
93
94
95
  public CliDriver() {
    SessionState ss = SessionState.get();
    conf = (ss != null) ? ss.getConf() : new Configuration();
    Log LOG = LogFactory.getLog("CliDriver");
    console = new LogHelper(LOG);
  }
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
    HiveConf hiveConf = new HiveConf(conf, BlockMergeTask.class);

    Log LOG = LogFactory.getLog(BlockMergeTask.class.getName());
    boolean isSilent = HiveConf.getBoolVar(conf,
        HiveConf.ConfVars.HIVESESSIONSILENT);
    LogHelper console = new LogHelper(LOG, isSilent);

    // print out the location of the log file for the user so
    // that it's easy to find reason for local mode execution failures
    for (Appender appender : Collections
        .list((Enumeration<Appender>) LogManager.getRootLogger()
            .getAllAppenders())) {
      if (appender instanceof FileAppender) {
        console.printInfo("Execution log at: "
            + ((FileAppender) appender).getFile());
      }
    }

    MergeWork mergeWork = new MergeWork(inputPaths, outputDir);
View Full Code Here

Examples of org.apache.hadoop.hive.ql.session.SessionState.LogHelper

221
222
223
224
225
226
227
228
229
230
231
   * @param ss
   */
  public HiveHistory(SessionState ss) {

    try {
      console = new LogHelper(LOG);
      String conf_file_loc = ss.getConf().getVar(
          HiveConf.ConfVars.HIVEHISTORYFILELOC);
      if ((conf_file_loc == null) || conf_file_loc.length() == 0) {
        console.printError("No history file location given");
        return;
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.