org.apache.flume.source.avroLegacy
Class AvroLegacySource
java.lang.Object
org.apache.flume.source.AbstractSource
org.apache.flume.source.avroLegacy.AvroLegacySource
- All Implemented Interfaces:
- FlumeOGEventAvroServer, Configurable, EventDrivenSource, LifecycleAware, NamedComponent, Source
public class AvroLegacySource
- extends AbstractSource
- implements EventDrivenSource, Configurable, FlumeOGEventAvroServer
A Source
implementation that receives Avro events from Avro sink of
Flume OG
Configuration options
Parameter |
Description |
Unit / Type |
Default |
host |
The hostname or IP to which the source will bind. |
Hostname or IP / String |
none (required) |
port |
The port to which the source will bind and listen for events. |
TCP port / int |
none (required) |
Metrics
TODO
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HOST
public static final String HOST
- See Also:
- Constant Field Values
TIMESTAMP
public static final String TIMESTAMP
- See Also:
- Constant Field Values
PRIORITY
public static final String PRIORITY
- See Also:
- Constant Field Values
NANOS
public static final String NANOS
- See Also:
- Constant Field Values
OG_EVENT
public static final String OG_EVENT
- See Also:
- Constant Field Values
avroClient
protected FlumeOGEventAvroServer avroClient
AvroLegacySource
public AvroLegacySource()
start
public void start()
- Description copied from interface:
LifecycleAware
Starts a service or component.
Implementations should determine the result of any start logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
- Specified by:
start
in interface LifecycleAware
- Overrides:
start
in class AbstractSource
stop
public void stop()
- Description copied from interface:
LifecycleAware
Stops a service or component.
Implementations should determine the result of any stop logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
- Specified by:
stop
in interface LifecycleAware
- Overrides:
stop
in class AbstractSource
append
public Void append(AvroFlumeOGEvent evt)
throws org.apache.avro.AvroRemoteException
- Specified by:
append
in interface FlumeOGEventAvroServer
- Throws:
org.apache.avro.AvroRemoteException
configure
public void configure(Context context)
- Specified by:
configure
in interface Configurable
Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.