flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveDelimitedTextSerializer.java [47:62]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @Override
  public void write(TransactionBatch txnBatch, Event e)
          throws StreamingException, IOException, InterruptedException {
    txnBatch.write(e.getBody());
  }

  @Override
  public void write(TransactionBatch txnBatch, Collection<byte[]> events)
          throws StreamingException, IOException, InterruptedException {
    txnBatch.write(events);
  }


  @Override
  public RecordWriter createRecordWriter(HiveEndPoint endPoint)
      throws StreamingException, IOException, ClassNotFoundException {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flume-hive-sink/src/main/java/org/apache/flume/sink/hive/HiveJsonSerializer.java [39:53]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  @Override
  public void write(TransactionBatch txnBatch, Event e)
          throws StreamingException, IOException, InterruptedException {
    txnBatch.write(e.getBody());
  }

  @Override
  public void write(TransactionBatch txnBatch, Collection<byte[]> events)
          throws StreamingException, IOException, InterruptedException {
    txnBatch.write(events);
  }

  @Override
  public RecordWriter createRecordWriter(HiveEndPoint endPoint)
          throws StreamingException, IOException, ClassNotFoundException {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -