Package | Description |
---|---|
org.thales.punch.libraries.storm.spout |
Punchplatform spouts package.
|
org.thales.punch.libraries.storm.spout.factory | |
org.thales.punch.libraries.storm.spout.impl |
Class and Description |
---|
AbstractFileInput.Item
Whenever something is read, it is enqueued so that stom can come pick it in
nextTuple().
|
AbstractKafkaNode
Common kafka input node base class with standard kafka properties definition.
|
AbstractSocketInput
Base class for socket servers spouts : http, lumberjack relp and plain syslog.
|
SyslogInput
The Syslog input reads lines from tcp/udp and emits them as tuples.
|
Class and Description |
---|
GeneratorInput
The generator publishes fake data in configurable streams.
|
HttpInput
The Http spout receives http requests and forwards them as tuple.
|
LumberjackInput
The Lumberjack spout receives and decodes lumberjack frames, emitted in turn as tuples.
|
SnmpInput
The SNMP spout is able to receive SNMP Traps over UDP
It decodes the SNMP Traps messages into a JSON format - cf.
|
SyslogInput
The Syslog input reads lines from tcp/udp and emits them as tuples.
|
Class and Description |
---|
AbstractFileInput
The file spout feeds messages into Storm from one or several files.
|
Copyright © 2022. All rights reserved.