本文整理了Java中org.apache.flume.Event.getBody()方法的一些代码示例，展示了Event.getBody()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Event.getBody()方法的具体详情如下：
包路径：org.apache.flume.Event
类名称：Event
方法名：getBody

Event.getBody介绍

[英]Returns the raw byte array of the data contained in this event.
[中]返回此事件中包含的数据的原始字节数组。

代码示例

代码示例来源：origin: apache/flume

@Override
public void initialize(Event event, byte[] cf) {
 this.payload = event.getBody();
 this.cf = cf;
}

代码示例来源：origin: apache/flume

private long estimateEventSize(Event event) {
 byte[] body = event.getBody();
 if (body != null && body.length != 0) {
  return body.length;
 }
 //Each event occupies at least 1 slot, so return 1.
 return 1;
}

代码示例来源：origin: apache/flume

private long estimateEventSize(Event event) {
 byte[] body = event.getBody();
 if (body != null && body.length != 0) {
  return body.length;
 }
 //Each event occupies at least 1 slot, so return 1.
 return 1;
}

代码示例来源：origin: apache/flume

@Override
public void initialize(Event event, byte[] cf) {
 this.payload = event.getBody();
 this.cf = cf;
}

代码示例来源：origin: apache/flume

@Override
public byte[] format(Event event) {
 String body = event.getBody().length > 0 ? new String(event.getBody()) : "";
 return (body + "\n").getBytes();
}

代码示例来源：origin: apache/flume

private Text makeText(Event e) {
 Text textObject = new Text();
 textObject.set(e.getBody(), 0, e.getBody().length);
 return textObject;
}

代码示例来源：origin: apache/flume

@Override
public void write(Event e) throws IOException {
 out.write(e.getBody());
 if (appendNewline) {
  out.write('\n');
 }
}

代码示例来源：origin: apache/flume

private BytesWritable makeByteWritable(Event e) {
 BytesWritable bytesObject = new BytesWritable();
 bytesObject.set(e.getBody(), 0, e.getBody().length);
 return bytesObject;
}

代码示例来源：origin: apache/flume

@Override
public void initialize(Event event, byte[] columnFamily) {
 this.headers = event.getHeaders();
 this.payload = event.getBody();
 this.cf = columnFamily;
}

代码示例来源：origin: apache/flume

@Override
public void write(TransactionBatch txnBatch, Event e)
    throws StreamingException, IOException, InterruptedException {
 txnBatch.write(e.getBody());
}

代码示例来源：origin: apache/flume

private void appendBody(XContentBuilder builder, Event event)
  throws IOException, UnsupportedEncodingException {
 byte[] body = event.getBody();
 ContentBuilderUtil.appendField(builder, "@message", body);
}

代码示例来源：origin: apache/flume

@Override
public Event intercept(Event event) {
 String origBody = new String(event.getBody(), charset);
 Matcher matcher = searchPattern.matcher(origBody);
 String newBody = matcher.replaceAll(replaceString);
 event.setBody(newBody.getBytes(charset));
 return event;
}

代码示例来源：origin: apache/flume

@Override
public void initialize(Event event, byte[] columnFamily) {
 this.headers = event.getHeaders();
 this.payload = event.getBody();
 this.cf = columnFamily;
}

代码示例来源：origin: apache/flume

@Override
public void write(Event e) throws IOException {
 out.write((e.getHeaders() + " ").getBytes());
 out.write(e.getBody());
 if (appendNewline) {
  out.write('\n');
 }
}

代码示例来源：origin: apache/flume

@Override
public void write(TransactionBatch txnBatch, Event e)
    throws StreamingException, IOException, InterruptedException {
 txnBatch.write(e.getBody());
}

代码示例来源：origin: apache/flume

private List<Event> getSimpleEvents(List<Event> events) {
  List<Event> newEvents = new ArrayList<Event>(events.size());
  for (Event e:events) {
   newEvents.add(EventBuilder.withBody(e.getBody(), e.getHeaders()));
  }
  return newEvents;
 }
}

代码示例来源：origin: apache/flume

private void sendLine(Event event) {
 String body = new String(event.getBody());
 
 if (splitLines) {
  String[] lines = body.split(splitChars);
  for (String line: lines) {
   connection.doPrivmsg(IRC_CHANNEL_PREFIX + this.chan, line);
  }
 } else {
  connection.doPrivmsg(IRC_CHANNEL_PREFIX + this.chan, body);
 }
 
}

代码示例来源：origin: apache/flume

@Override
public void write(Event event) throws IOException {
 if (dataFileWriter == null) {
  initialize(event);
 }
 dataFileWriter.appendEncoded(ByteBuffer.wrap(event.getBody()));
}

代码示例来源：origin: apache/flume

@Test
public void testBody() {
 Event e1 = EventBuilder.withBody("e1".getBytes());
 Assert.assertNotNull(e1);
 Assert.assertArrayEquals("body is correct", "e1".getBytes(), e1.getBody());
 Event e2 = EventBuilder.withBody(Long.valueOf(2).toString().getBytes());
 Assert.assertNotNull(e2);
 Assert.assertArrayEquals("body is correct", Long.valueOf(2L).toString()
   .getBytes(), e2.getBody());
}

代码示例来源：origin: apache/flume

@Test
public void testHeaders() {
 Map<String, String> headers = new HashMap<String, String>();
 headers.put("one", "1");
 headers.put("two", "2");
 Event e1 = EventBuilder.withBody("e1".getBytes(), headers);
 Assert.assertNotNull(e1);
 Assert.assertArrayEquals("e1 has the proper body", "e1".getBytes(),
   e1.getBody());
 Assert.assertEquals("e1 has the proper headers", 2, e1.getHeaders().size());
 Assert.assertEquals("e1 has a one key", "1", e1.getHeaders().get("one"));
}