|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.flume.source.AbstractSource org.apache.flume.source.NetcatSource
public class NetcatSource
A netcat-like source that listens on a given port and turns each line of text into an event.
This source, primarily built for testing and exceedingly simple systems, acts like nc -k -l [host] [port]. In other words, it opens a specified port and listens for data. The expectation is that the supplied data is newline separated text. Each line of text is turned into a Flume event and sent via the connected channel.
Most testing has been done by using the nc client but other, similarly implemented, clients should work just fine.
Configuration options
Parameter | Description | Unit / Type | Default |
---|---|---|---|
bind | 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
Nested Class Summary | |
---|---|
static class |
NetcatSource.AcceptHandler
|
static class |
NetcatSource.NetcatSocketHandler
|
Constructor Summary | |
---|---|
NetcatSource()
|
Method Summary | |
---|---|
void |
configure(Context context)
|
void |
start()
Starts a service or component. |
void |
stop()
Stops a service or component. |
Methods inherited from class org.apache.flume.source.AbstractSource |
---|
getChannelProcessor, getLifecycleState, getName, setChannelProcessor, setName |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.flume.Source |
---|
getChannelProcessor, setChannelProcessor |
Methods inherited from interface org.apache.flume.lifecycle.LifecycleAware |
---|
getLifecycleState |
Methods inherited from interface org.apache.flume.NamedComponent |
---|
getName, setName |
Constructor Detail |
---|
public NetcatSource()
Method Detail |
---|
public void configure(Context context)
configure
in interface Configurable
public void start()
LifecycleAware
Starts a service or component.
Implementations should determine the result of any start logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
start
in interface LifecycleAware
start
in class AbstractSource
public void stop()
LifecycleAware
Stops a service or component.
Implementations should determine the result of any stop logic and effect
the return value of LifecycleAware.getLifecycleState()
accordingly.
stop
in interface LifecycleAware
stop
in class AbstractSource
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |