org.elasticsearch.hadoop.hive
Class EsStorageHandler
java.lang.Object
org.apache.hadoop.hive.ql.metadata.DefaultStorageHandler
org.elasticsearch.hadoop.hive.EsStorageHandler
- All Implemented Interfaces:
- Configurable, HiveStorageHandler
public class EsStorageHandler
- extends DefaultStorageHandler
Hive storage for writing data into an ElasticSearch index.
The ElasticSearch host/port can be specified through Hadoop properties (see package description)
or passed to EsStorageHandler() through Hive TBLPROPERTIES
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
EsStorageHandler
public EsStorageHandler()
getInputFormatClass
public Class<? extends InputFormat> getInputFormatClass()
- Specified by:
getInputFormatClass in interface HiveStorageHandler- Overrides:
getInputFormatClass in class DefaultStorageHandler
getOutputFormatClass
public Class<? extends OutputFormat> getOutputFormatClass()
- Specified by:
getOutputFormatClass in interface HiveStorageHandler- Overrides:
getOutputFormatClass in class DefaultStorageHandler
getSerDeClass
public Class<? extends SerDe> getSerDeClass()
- Specified by:
getSerDeClass in interface HiveStorageHandler- Overrides:
getSerDeClass in class DefaultStorageHandler
getMetaHook
public HiveMetaHook getMetaHook()
- Specified by:
getMetaHook in interface HiveStorageHandler- Overrides:
getMetaHook in class DefaultStorageHandler
configureInputJobProperties
public void configureInputJobProperties(TableDesc tableDesc,
Map<String,String> jobProperties)
- Specified by:
configureInputJobProperties in interface HiveStorageHandler- Overrides:
configureInputJobProperties in class DefaultStorageHandler
configureOutputJobProperties
public void configureOutputJobProperties(TableDesc tableDesc,
Map<String,String> jobProperties)
- Specified by:
configureOutputJobProperties in interface HiveStorageHandler- Overrides:
configureOutputJobProperties in class DefaultStorageHandler
configureTableJobProperties
@Deprecated
public void configureTableJobProperties(TableDesc tableDesc,
Map<String,String> jobProperties)
- Deprecated.
- Specified by:
configureTableJobProperties in interface HiveStorageHandler- Overrides:
configureTableJobProperties in class DefaultStorageHandler