Page Comparison

Export data to a HiveServer1 or HiveServer2 database. 

...

A HiveServer1 or HiveServer2 connection with Datameer must be created before exporting data (see Hive or HiveServer2 connection documentation).

As of Datameer 7.4.x, export behavior and validation for partitioned and unpartitioned tables is the same. Incorrect mapping will result in a failed export, and invalid records will be dropped from the export results. However, for unpartitioned tables with mode RECREATE, the original table definition is used to recreate the table and only columns with name and type are replaced by export sheet definition.

Note that it is possible to disable value validation, should you choose, by setting the custom Hadoop property hive.server2.export.record.validation=false.

Configuring Export Jobs with a Hive Connection

...

1. Select the + (plus) at the top left of the File Browser and select Export Job or right-click on the workbook to export from and select New Export Job.
   

2. Select the workbook to export from in the browser.
   Image Removed Image Added

   Note
   title As of Datameer 7.5
   Datameer 7.5 has implemented automatic sorting of data via partitioned Hive columns before an export job runs. For Hive exports in Datameer prior to version 7.5, we recommend that workbook be sorted via partitioned columns for the best performance.

3. Select the worksheet to export from the drop down menu.
   Image Removed Image Added

4. Select the Hive or HiveServer2 connector.
   Image Removed Image Added

5. Anchor
   data_details data_details

   Select a database on the Hive server from the drop down menu.
   
   If a database filter has been added to the Hive connection settings, that filter is respected when displaying databases in the drop down list.
   Image Removed Image Added 
   To export to an existing table on the Hive server, select the radio button Use  existing. 
   Image Removed Image Added 
   To export to a new table on a database, select the radio button Create new if not exist and enter a new table name. Creating a new partitioned table is not supported.
   Image Removed  
    Image Added 
   Select the expected output format from the drop-down. INFO: Selecting the file format will be ignored for already existing tables.
   Select a record replacement policy. Learn more about database record replacement.  
   
   • Drop and create new table - The existing table is dropped from the database. A new table is created with the schema defined from the worksheet being exported. If the initial table was an external one, Datameer will drop it and create a new external table. This replacement policy is only available for unpartitioned tables and is written as a TEXTFILE (plain text).
   • Overwrite records - All records from the existing table are deleted and the new records are written to the table. No table properties are modified and the data is written into the original file type. (e.g., ORC)
   • Append records - The records append to the existing table.
   Image RemovedImage Added

   Anchor
   classic_map classic_map

   Exporting: Datameer Versions Through 7.4.x ("Classic")

   Anchor
   partitioned_mapping partitioned_mapping

   Exporting into partitioned tables

   • Supports exporting to an existing table on the Hive server.
   • If exporting to a Hive table in a Sentry secured HDFS, the table being exported to requires read, write, and execute permissions.  

   • Datameer exports support the Hive data types listed below in the table. 
     

     Datameer type	Hive type
     	void	boolean	tinyint	smallint	int	bigint	float	double	decimal	string	varchar	char	timestamp	date	binary	array< data_type >
     STRING
     BOOLEAN
     FLOAT
     INTEGER
     DATE
     BIG_DECIMAL
     BIG_INTEGER
     LIST

   • The export is written into the existing Hive output format. (e.g., ORC, Parquet, …)

     Tip
     Users have run into Null Pointer Exceptions when exporting into a parquet table. The root cause is a bug in the Hive implementation that uses a default codec for compression. You can solve this issue by configuring the codec: (e.g., org.apache.hadoop.io.compress.DefaultCodec) Panel mapreduce.output.fileoutputformat.compress.codec=org.apache.hadoop.io.compress.DefaultCodec

   Limitations on exporting to existing partitioned tables:

   • Unable to write a list inside another list.

   • Unable to write the Hive data types "void" and "binary".

   • If a record being written to the Hive server doesn't fit correctly into the Hive data type, it is dropped. The response to invalid data can be configured on the Mapping tab under "How to handle invalid data?" (see Step 6).
   • This feature has been tested on a Sentry secured environment with Cloudera but has not been tested in a Ranger secured environment with Hortonworks.

   Exporting into unpartitioned tables

   Anchor
   unpartitioned_mapping unpartitioned_mapping

   • For unpartitioned tables with mode RECREATE, the original table definition is used to recreate the table - only columns with name and type are replaced by the export sheet definition.

   • Supports both exporting to a new table or into an existing table on the Hive server.
   • If exporting to a Hive table in a Sentry secured HDFS, the table being exported to requires read, write, and execute permissions.  
   • Datameer exports support a limited number of Hive data types (see the tables below).
     • The list of supported types is related to the data field mapping mode that can be configured in the Hive plug-in.

       • Datameer classic
         

         Datameer type	In Hive (Datameer classic)
         	boolean	bigint	double	string	array< data_type >
         STRING					array<string>
         BOOLEAN					array<boolean>
         FLOAT					array<double>
         INTEGER					array<bigint>
         DATE				YYYY-mm-dd hh:MM:ss	array<string>
         BIG_DECIMAL					array<string>
         BIG_INTEGER					array<string>
         LIST

       • Hive specific 
         

         Datameer type	In Hive (Hive specific)
         	boolean	bigint	double	decimal	string	date	timestamp	array< data_type >
         STRING								array<string>
         BOOLEAN								array<boolean>
         FLOAT								array<double>
         INTEGER								array<bigint>
         DATE								array<date> or array<timestamp>
         BIG_DECIMAL								array<decimal>
         BIG_INTEGER								array<string>
         LIST

   • The export is written in the output format TEXTFILE (plain text).

6. Anchor
   preview preview

   Preview how the data is being mapped to the Hive table and select how to handle invalid data.
   Image Removed Image Added
   

   Requirements for exporting:

   • A minimum of one column must be included.
   • The column names must be unique.
   
   Requirements for exporting into an existing partitioned table:
   
   • Column names in Datameer must match the column names in the Hive table (case sensitivity applies).
   • Partitioned columns must match to the existing partition of the Hive table.
   • The Datameer column data types must match the Hive column data types. 
   • The number of included columns from the Datameer worksheet in the export must match the number of columns in the Hive table.
     
   
   Requirements for exporting into an existing unpartitioned table:
   
   • Column names in Datameer must match the column names in the Hive table. (Case insensitive)
   • The column order in the Datameer export must match the column order in the Hive table.
   • The Datameer column data types must match the Hive column data types. 
   • The number of included columns from the Datameer worksheet in the export must match the number of columns in the Hive table.
7. Select when to run the export job. This can be done manually by a user, run each time the workbook in Datameer is calculated, or at specifically scheduled times.
   Custom properties can be added in the advanced section as well as logging specifications. 
   Image Removed Image Added
8. Enter a description and click Save.
   Image Removed Image Added 

Anchor
implicit_map implicit_map

Exporting: Datameer Versions 7.5+

...