Package | Description |
---|---|
org.apache.flume.thrift |
Modifier and Type | Field and Description |
---|---|
ThriftFlumeEvent |
ThriftSourceProtocol.append_args.event |
Modifier and Type | Field and Description |
---|---|
List<ThriftFlumeEvent> |
ThriftSourceProtocol.appendBatch_args.events |
Modifier and Type | Method and Description |
---|---|
ThriftFlumeEvent |
ThriftFlumeEvent.deepCopy() |
ThriftFlumeEvent |
ThriftSourceProtocol.append_args.getEvent() |
ThriftFlumeEvent |
ThriftFlumeEvent.setBody(byte[] body) |
ThriftFlumeEvent |
ThriftFlumeEvent.setBody(ByteBuffer body) |
ThriftFlumeEvent |
ThriftFlumeEvent.setHeaders(Map<String,String> headers) |
Modifier and Type | Method and Description |
---|---|
List<ThriftFlumeEvent> |
ThriftSourceProtocol.appendBatch_args.getEvents() |
Iterator<ThriftFlumeEvent> |
ThriftSourceProtocol.appendBatch_args.getEventsIterator() |
Modifier and Type | Method and Description |
---|---|
void |
ThriftSourceProtocol.appendBatch_args.addToEvents(ThriftFlumeEvent elem) |
Status |
ThriftSourceProtocol.Iface.append(ThriftFlumeEvent event) |
Status |
ThriftSourceProtocol.Client.append(ThriftFlumeEvent event) |
void |
ThriftSourceProtocol.AsyncIface.append(ThriftFlumeEvent event,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
ThriftSourceProtocol.AsyncClient.append(ThriftFlumeEvent event,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
int |
ThriftFlumeEvent.compareTo(ThriftFlumeEvent other) |
boolean |
ThriftFlumeEvent.equals(ThriftFlumeEvent that) |
void |
ThriftSourceProtocol.Client.send_append(ThriftFlumeEvent event) |
ThriftSourceProtocol.append_args |
ThriftSourceProtocol.append_args.setEvent(ThriftFlumeEvent event) |
Modifier and Type | Method and Description |
---|---|
Status |
ThriftSourceProtocol.Iface.appendBatch(List<ThriftFlumeEvent> events) |
Status |
ThriftSourceProtocol.Client.appendBatch(List<ThriftFlumeEvent> events) |
void |
ThriftSourceProtocol.AsyncIface.appendBatch(List<ThriftFlumeEvent> events,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
ThriftSourceProtocol.AsyncClient.appendBatch(List<ThriftFlumeEvent> events,
org.apache.thrift.async.AsyncMethodCallback resultHandler) |
void |
ThriftSourceProtocol.Client.send_appendBatch(List<ThriftFlumeEvent> events) |
ThriftSourceProtocol.appendBatch_args |
ThriftSourceProtocol.appendBatch_args.setEvents(List<ThriftFlumeEvent> events) |
Constructor and Description |
---|
append_args(ThriftFlumeEvent event) |
append_call(ThriftFlumeEvent event,
org.apache.thrift.async.AsyncMethodCallback resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) |
ThriftFlumeEvent(ThriftFlumeEvent other)
Performs a deep copy on other.
|
Constructor and Description |
---|
appendBatch_args(List<ThriftFlumeEvent> events) |
appendBatch_call(List<ThriftFlumeEvent> events,
org.apache.thrift.async.AsyncMethodCallback resultHandler,
org.apache.thrift.async.TAsyncClient client,
org.apache.thrift.protocol.TProtocolFactory protocolFactory,
org.apache.thrift.transport.TNonblockingTransport transport) |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.