org.apache.flume.sink.hive
Class HiveJsonSerializer

java.lang.Object
  extended by org.apache.flume.sink.hive.HiveJsonSerializer
All Implemented Interfaces:
Configurable, HiveEventSerializer

public class HiveJsonSerializer
extends Object
implements HiveEventSerializer

Forwards the incoming event body to Hive unmodified Sets up the delimiter and the field to column mapping


Field Summary
static String ALIAS
           
 
Constructor Summary
HiveJsonSerializer()
           
 
Method Summary
 void configure(Context context)
           Request the implementing class to (re)configure itself.
 org.apache.hive.hcatalog.streaming.RecordWriter createRecordWriter(org.apache.hive.hcatalog.streaming.HiveEndPoint endPoint)
           
 void write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Collection<byte[]> events)
           
 void write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Event e)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

ALIAS

public static final String ALIAS
See Also:
Constant Field Values
Constructor Detail

HiveJsonSerializer

public HiveJsonSerializer()
Method Detail

write

public void write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch,
                  Event e)
           throws org.apache.hive.hcatalog.streaming.StreamingException,
                  IOException,
                  InterruptedException
Specified by:
write in interface HiveEventSerializer
Throws:
org.apache.hive.hcatalog.streaming.StreamingException
IOException
InterruptedException

write

public void write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch,
                  Collection<byte[]> events)
           throws org.apache.hive.hcatalog.streaming.StreamingException,
                  IOException,
                  InterruptedException
Specified by:
write in interface HiveEventSerializer
Throws:
org.apache.hive.hcatalog.streaming.StreamingException
IOException
InterruptedException

createRecordWriter

public org.apache.hive.hcatalog.streaming.RecordWriter createRecordWriter(org.apache.hive.hcatalog.streaming.HiveEndPoint endPoint)
                                                                   throws org.apache.hive.hcatalog.streaming.StreamingException,
                                                                          IOException,
                                                                          ClassNotFoundException
Specified by:
createRecordWriter in interface HiveEventSerializer
Throws:
org.apache.hive.hcatalog.streaming.StreamingException
IOException
ClassNotFoundException

configure

public void configure(Context context)
Description copied from interface: Configurable

Request the implementing class to (re)configure itself.

When configuration parameters are changed, they must be reflected by the component asap.

There are no thread safety guarrantees on when configure might be called.

Specified by:
configure in interface Configurable


Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.