Serialized Form

Package com.cloudera.flume.handlers.thrift

Class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Deprecated.

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Deprecated.

Throws:

IOException

Serialized Fields

timestamp

long timestamp

Deprecated.

priority

Priority priority

Deprecated.

See Also:

Priority

body

ByteBuffer body

Deprecated.

nanos

long nanos

Deprecated.

host

String host

Deprecated.

fields

Map<K,V> fields

Deprecated.

__isset_bit_vector

BitSet __isset_bit_vector

Deprecated.

Class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

evt

ThriftFlumeEvent evt

Class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Package org.apache.flume

Class org.apache.flume.ChannelException extends RuntimeException implements Serializable

serialVersionUID: 1L

Class org.apache.flume.EventDeliveryException extends Exception implements Serializable

serialVersionUID: 1102327497549834945L

Class org.apache.flume.FlumeException extends RuntimeException implements Serializable

serialVersionUID: 1L

Package org.apache.flume.channel.file

Class org.apache.flume.channel.file.LogFileRetryableIOException extends IOException implements Serializable

serialVersionUID: -2747112999806160431L

Package org.apache.flume.channel.file.proto

Class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

logFileID_

int logFileID_

count_

int count_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

version_

int version_

writeOrderID_

long writeOrderID_

queueSize_

int queueSize_

queueHead_

int queueHead_

activeLogs_

List<E> activeLogs_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.Commit extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

type_

int type_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

headers_

List<E> headers_

body_

com.google.protobuf.ByteString body_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

key_

Object key_

value_

Object value_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

cipherProvider_

Object cipherProvider_

keyAlias_

Object keyAlias_

parameters_

com.google.protobuf.ByteString parameters_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

version_

int version_

logFileID_

int logFileID_

checkpointPosition_

long checkpointPosition_

checkpointWriteOrderID_

long checkpointWriteOrderID_

encryption_

ProtosFactory.LogFileEncryption encryption_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.Put extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

event_

ProtosFactory.FlumeEvent event_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.Rollback extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.Take extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

fileID_

int fileID_

offset_

int offset_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader extends com.google.protobuf.GeneratedMessage implements Serializable

serialVersionUID: 0L

Serialization Methods

writeReplace

protected Object writeReplace()
                       throws ObjectStreamException

Throws:

ObjectStreamException

Serialized Fields

bitField0_

int bitField0_

type_

int type_

transactionID_

long transactionID_

writeOrderID_

long writeOrderID_

memoizedIsInitialized

byte memoizedIsInitialized

memoizedSerializedSize

int memoizedSerializedSize

Package org.apache.flume.channel.jdbc

Class org.apache.flume.channel.jdbc.JdbcChannelException extends ChannelException implements Serializable

serialVersionUID: -5566109526732929679L

Package org.apache.flume.conf

Class org.apache.flume.conf.ConfigurationException extends FlumeException implements Serializable

serialVersionUID: 1L

Package org.apache.flume.lifecycle

Class org.apache.flume.lifecycle.LifecycleException extends Exception implements Serializable

serialVersionUID: 4689000562519155240L

Package org.apache.flume.source.http

Class org.apache.flume.source.http.HTTPBadRequestException extends FlumeException implements Serializable

serialVersionUID: -3540764742069390951L

Package org.apache.flume.source.scribe

Class org.apache.flume.source.scribe.LogEntry extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

category

String category

message

ByteBuffer message

Class org.apache.flume.source.scribe.Scribe.Log_args extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

messages

List<E> messages

Class org.apache.flume.source.scribe.Scribe.Log_result extends Object implements Serializable

Serialization Methods

readObject

private void readObject(ObjectInputStream in)
                 throws IOException,
                        ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeObject

private void writeObject(ObjectOutputStream out)
                  throws IOException

Throws:

IOException

Serialized Fields

success

ResultCode success

See Also:

ResultCode