com.actian.dataflow.hive.shims

Class HiveShimImpl

java.lang.Object

com.pervasive.datarush.hadoop.shims.common.AbstractShim

com.actian.dataflow.hive.shims.HiveShimImpl

All Implemented Interfaces:

HiveShim

public class HiveShimImpl
extends com.pervasive.datarush.hadoop.shims.common.AbstractShim
implements HiveShim

Implementation of the HiveShim interface.

Constructor Summary

Constructors

Constructor and Description
HiveShimImpl(Module module) Construct with the given module which is used to load the correct dependent classes.

Method Summary

Methods

Modifier and Type	Method and Description
ORCFileShim	getORCFile(FileClient client, Path path) Get an ORC file shim for the given file path.
ORCFormatterShim	getORCFormatter(ORCOptions orcOptions)
ParquetFileShim	getParquetFile(FileClient client, Path path) Get an Parquet file shim for the given file path.
boolean	isSupportedWriterType(ScalarTokenType type)

Methods inherited from class com.pervasive.datarush.hadoop.shims.common.AbstractShim

getModule

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HiveShimImpl

public HiveShimImpl(Module module)

Construct with the given module which is used to load the correct dependent classes.

Parameters:

module - hadoop module to use

Method Detail

getORCFile

public ORCFileShim getORCFile(FileClient client,
                     Path path)
                       throws IOException

Description copied from interface: HiveShim

Get an ORC file shim for the given file path.

Specified by:

getORCFile in interface HiveShim

Parameters:

client - file client

path - path to the source file

Returns:

ORC file shim

Throws:

IOException - thrown if an I/O error occurs accessing the ORC file

getORCFormatter

public ORCFormatterShim getORCFormatter(ORCOptions orcOptions)

Specified by:

getORCFormatter in interface HiveShim

isSupportedWriterType

public boolean isSupportedWriterType(ScalarTokenType type)

Specified by:

isSupportedWriterType in interface HiveShim

getParquetFile

public ParquetFileShim getParquetFile(FileClient client,
                             Path path)
                               throws IOException

Description copied from interface: HiveShim

Get an Parquet file shim for the given file path.

Specified by:

getParquetFile in interface HiveShim

Parameters:

client - file client

path - path to the source file

Returns:

Parquet file shim

Throws:

IOException - thrown if an I/O error occurs accessing the Parquet file