Skip to content
This repository

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP

An input format that returns a single split with a single row

branch: master
Octocat-spinner-32 src Licence April 30, 2012
Octocat-spinner-32 NOTICE.txt Yay! First code drop. April 30, 2012
Octocat-spinner-32 README.md Better readme! April 30, 2012
Octocat-spinner-32 pom.xml Yay! First code drop. April 30, 2012
README.md

DualInputFormat

An input format that returns a single split with a single row.

Can be used from hive like this.

client.execute ( "add jar "+jarFile);
client.execute("create table  dual  (fake string) "+
        "STORED AS INPUTFORMAT 'com.m6d.dualinputformat.DualInputFormat'"+
        "OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.HiveIgnoreKeyTextOutputFormat'");
client.execute("load data local inpath '" + p.toString() + "' into table dual");
client.execute("select count(1) as cnt from dual");
String row = client.fetchOne();
assertEquals( "1", row);

client.execute("select * from dual");
row = client.fetchOne();
assertEquals( "", row);

client.execute("drop table dual");
Something went wrong with that request. Please try again.