hdfs-lzo-text-scanner.h

Go to the documentation of this file.

// Copyright (c) 2012 Cloudera, Inc. All rights reserved.
//
// Licensed 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.

#ifndef IMPALA_EXEC_HDFS_LZO_TEXT_SCANNER_H
#define IMPALA_EXEC_HDFS_LZO_TEXT_SCANNER_H

#include <common/status.h>
#include <exec/scan-node.h>
#include <exec/hdfs-scanner.h>
#include <exec/hdfs-scan-node.h>
#include <boost/thread/locks.hpp>

namespace impala {

class HdfsLzoTextScanner {
 public:
  static HdfsScanner* GetHdfsLzoTextScanner(HdfsScanNode* scan_node, RuntimeState* state);
  static Status IssueInitialRanges(HdfsScanNode* scan_node,
                                   const std::vector<HdfsFileDesc*>& files);

 private:
  const static std::string LIB_IMPALA_LZO;

  static Status library_load_status_;

  static boost::mutex lzo_load_lock_;

  static HdfsScanner* (*CreateLzoTextScanner)
      (HdfsScanNode* scan_node, RuntimeState* state);

  static Status (*LzoIssueInitialRanges)(
      HdfsScanNode* scan_node, const std::vector<HdfsFileDesc*>& files);

  static Status LoadLzoLibrary();
};
}
#endif