Package | Description |
---|---|
org.apache.flume.serialization | |
org.apache.flume.sink.hdfs |
Modifier and Type | Interface and Description |
---|---|
interface |
EventSerDe
A class that is able to both serialize and deserialize events.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractAvroEventSerializer<T>
This is a helper class provided to make it straightforward to serialize
Flume events into Avro data.
|
class |
BodyTextEventSerializer
This class simply writes the body of the event to the output stream
and appends a newline after each event.
|
class |
FlumeEventAvroEventSerializer |
class |
HeaderAndBodyTextEventSerializer
This class simply writes the body of the event to the output stream
and appends a newline after each event.
|
Modifier and Type | Method and Description |
---|---|
EventSerializer |
FlumeEventAvroEventSerializer.Builder.build(Context context,
OutputStream out) |
EventSerializer |
HeaderAndBodyTextEventSerializer.Builder.build(Context context,
OutputStream out) |
EventSerializer |
EventSerializer.Builder.build(Context context,
OutputStream out) |
EventSerializer |
BodyTextEventSerializer.Builder.build(Context context,
OutputStream out) |
static EventSerializer |
EventSerializerFactory.getInstance(String serializerType,
Context context,
OutputStream out) |
Modifier and Type | Class and Description |
---|---|
class |
AvroEventSerializer
This class serializes Flume events into Avro data files.
|
Modifier and Type | Method and Description |
---|---|
EventSerializer |
AvroEventSerializer.Builder.build(Context context,
OutputStream out) |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.