A B C D E F G H I J K L M N O P Q R S T U V W

A

abort() - Method in class org.thales.punch.libraries.storm.util.FileRecord

abruptClose() - Method in class org.thales.punch.libraries.storm.bolt.impl.AsyncKafkaProducer

AbstractArchiveBuffer - Class in org.thales.punch.libraries.storm.bolt.file.buffer

AbstractArchiveBuffer(int, int, List<ArchiveDevice>) - Constructor for class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

AbstractFileInput - Class in org.thales.punch.libraries.storm.spout

The file spout feeds messages into Storm from one or several files.

AbstractFileInput(NodeSettings, Logger) - Constructor for class org.thales.punch.libraries.storm.spout.AbstractFileInput

Ctor.

AbstractFileInput.Item - Class in org.thales.punch.libraries.storm.spout

Whenever something is read, it is enqueued so that stom can come pick it in nextTuple().

AbstractFileOutput - Class in org.thales.punch.libraries.storm.bolt

The file bolt writes the incoming tuples into archives.

AbstractFileOutput(NodeSettings, List<ArchiveDevice>, IFileNameSupplier, ArchiveFormatSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

Ctor.

AbstractJDBCOutput - Class in org.thales.punch.libraries.storm.bolt

AbstractJDBCBolt provides common JDBC configuration (host, username, port, etc...).

AbstractJDBCOutput(NodeSettings, String) - Constructor for class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

AbstractKafkaNode - Class in org.thales.punch.libraries.storm.spout

Common kafka input node base class with standard kafka properties definition.

AbstractKafkaNode(NodeSettings, String, Logger) - Constructor for class org.thales.punch.libraries.storm.spout.AbstractKafkaNode

Create a new Kafka spout

AbstractKafkaOutput - Class in org.thales.punch.libraries.storm.bolt

The KafkaBolt writes the content of storm tuples to Kafka topics.

AbstractKafkaOutput(NodeSettings, Properties) - Constructor for class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

The properties must only contain string.

AbstractKafkaOutput.Topic - Class in org.thales.punch.libraries.storm.bolt

Gather any information related to a topic.

AbstractSocketInput<T> - Class in org.thales.punch.libraries.storm.spout

Base class for socket servers spouts : http, lumberjack relp and plain syslog.

AbstractSocketInput(NodeSettings, Logger) - Constructor for class org.thales.punch.libraries.storm.spout.AbstractSocketInput

A Spout constructor is in charge of setting the fields that will be required later on when the spout will be effectively started and run somewhere in the cluster.

ack(Object) - Method in interface org.thales.punch.libraries.storm.core.topology.light.LightAcker

Ack a (spout) tuple.

ack(Tuple) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

This method is thread safe.

ack(Object) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpout

ack() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

Only after all anchors have acked will the tuple be acked to the originating spout.

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.AbstractSocketInput

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.AzureBlobStorageSpout

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.ExtractionInput

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.GeneratorInput

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.HttpInput

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.KafkaInput

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.SFTPSpout

commit will be done only if all emitted data have been ack If at least one emitted file is not ack, this topology will fail

ack(Object) - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

ackAll() - Method in class org.thales.punch.libraries.storm.bolt.OmniSciOutput

ackDocument(ElasticDocument) - Method in class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

ackFail - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

action - Variable in class org.thales.punch.libraries.storm.bolt.elasticsearch.FailureHandler

activate() - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

addBolt(LightBoltRunner) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

Register a bolt as part of this topology.

addBoltDispatcher(String, LightBoltDispatcher) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

addListeningAddress(ISettingsMap, LinkedBlockingQueue<INettyTuple<Map<String, String>>>) - Method in class org.thales.punch.libraries.storm.spout.impl.LumberjackServer

addListeningAddress(ISettingsMap, ISyslogReceiver<T>) - Method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

Add a listening address to this server.

addLogFileTailerListener(LogFileTailerListener) - Method in class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

add a listener

addPunchletsBlock(List<String>, List<String>, int, String) - Method in class org.thales.punch.libraries.storm.util.PunchletConfig

addRuntimeData(Object, int, Object) - Method in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

addSpout(String, ISpout) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

Add a spout to the topology.

addSubscriber(LightBoltDispatcher, String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

A bolt dispatcher comes in to subscribe to tuples from a given stream

addSubscription(TopologyGraphNode) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyGraphNode

addTupleToQuery(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

Add a tuple to INSERT query.

allGrouping(String, String) - Method in interface org.thales.punch.libraries.storm.core.topology.IBoltDeclarer

allGrouping(String, String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltDeclarer

allGrouping(String, String) - Method in class org.thales.punch.libraries.storm.core.topology.StormBoltDeclarer

archiveFormatSettings - Variable in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

The archive format settings.

ArchiveReaderNode - Class in org.thales.punch.libraries.storm.bolt

Node to read archive from provided metadata

ArchiveReaderNode(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.ArchiveReaderNode

Ctor

ArchiveReaderNodeFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build Archive Reader.

ArchiveReaderNodeFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.ArchiveReaderNodeFactory

Default constructor.

archiveTuple(Tuple, long, Iterable<String>) - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Marshal this tuple into the archive(s).

ArchiveUtils - Class in org.thales.punch.libraries.storm.util

AsyncKafkaProducer - Class in org.thales.punch.libraries.storm.bolt.impl

When writing to Kafka using the asynchronous API, in case of write error it is best to close the producer and reinit a new one.

AsyncKafkaProducer(Producer<byte[], byte[]>) - Constructor for class org.thales.punch.libraries.storm.bolt.impl.AsyncKafkaProducer

AtLeastOnceFileOutput - Class in org.thales.punch.libraries.storm.bolt.impl

The "At least once" version of the FileBolt.
In case of a topology failure/restart, duplicated Tuples will be found.

AtLeastOnceFileOutput(NodeSettings, List<ArchiveDevice>, IFileNameSupplier, ArchiveFormatSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.impl.AtLeastOnceFileOutput

Ctor

AvroParquetArchiveBuffer - Class in org.thales.punch.libraries.storm.bolt.file.buffer

The AvroParquetArchiveBuffer writes its content into S3 cluster or Filesystem.

AvroParquetArchiveBuffer(int, int, List<ArchiveDevice>, IRecordWriterBuilder<Map<String, Object>>, boolean) - Constructor for class org.thales.punch.libraries.storm.bolt.file.buffer.AvroParquetArchiveBuffer

AzureBlobStorageSpout - Class in org.thales.punch.libraries.storm.spout

The AzureBlobStorageSpout enable you to pull data from a given container located in an Azure Blob Storage.

AzureBlobStorageSpout(NodeSettings, boolean) - Constructor for class org.thales.punch.libraries.storm.spout.AzureBlobStorageSpout

Constructor.

AzureBlobStorageSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Factory for the azure blob storage spout

AzureBlobStorageSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.AzureBlobStorageSpoutFactory

Ctor

B

BatchArchiver - Class in org.thales.punch.libraries.storm.bolt.file

An BatchArchiver is in charge of writing the incoming data to one or several destination.

BatchArchiver(BatchMetadata, ArchiveFormatSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Ctor.

BatchMap<T> - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

BatchMap(long, long) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMap

BatchMapKey - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

Unique ids for a batch are simply built by concatenating the batch number (monotonically increasing counter set up by the Kafka Spout) with the source partition number.

BatchMapKey(long, long) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMapKey

bind(String, Class<T>) - Static method in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomBoltFactory

Jackson mapper

bind(String, Class<T>) - Static method in class org.thales.punch.libraries.storm.spout.factory.WrapperCustomSpoutFactory

Jackson mapper

boltFactories - Variable in class org.thales.punch.libraries.storm.core.topology.SimpleTopologyRegistry

The registered bolt factories by type.

boltFactoryFor(String) - Method in class org.thales.punch.libraries.storm.core.topology.SimpleTopologyRegistry

boltProducer - Variable in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

The Kafka producer used to send the message/records

build() - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.ReporterBuilder

buildName(ITopologySettings) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyFactory

bulkSize - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

byteProducer - Variable in class org.thales.punch.libraries.storm.bolt.impl.AsyncKafkaProducer

the underlying kafka producer

C

cancel(LastEventOperator) - Static method in class org.thales.punch.libraries.storm.util.WatchDog

Stop verifying a watchdog lastEventOperator.

CephGzipArchiveBuffer - Class in org.thales.punch.libraries.storm.bolt.file.buffer

The CephGzipArchiveBuffer writes its content into a Ceph cluster.

CephGzipArchiveBuffer(int, int, List<ArchiveDevice>, IRecordEncoder<Map<String, Object>>, IRecordEncoder.RecordFormat) - Constructor for class org.thales.punch.libraries.storm.bolt.file.buffer.CephGzipArchiveBuffer

charset - Variable in class org.thales.punch.libraries.storm.spout.AbstractSocketInput

check() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

Check if this tuple has been emitted at least once.

CHECKPOINT_APPLICATION_RUNTIME_ID - Static variable in class org.thales.punch.libraries.storm.spout.SFTPSpout

CHECKPOINT_ES_INDEX_PREFIX - Static variable in class org.thales.punch.libraries.storm.spout.SFTPSpout

CHECKPOINT_ES_NODES - Static variable in class org.thales.punch.libraries.storm.spout.SFTPSpout

CHECKPOINT_SETTINGS - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

checkStormStreamWiring(ISettingsMap, StormSettings) - Static method in class org.thales.punch.libraries.storm.bolt.factory.SyslogBoltFactory

This function checks that the storm streams declared in the storm settings of a bolt are inline with the ones contained in the destination settings.

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomOutput

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.FilterNode

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.impl.JdbcHandle

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.LumberjackOutput

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.ModuleNode

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.OmniSciOutput

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.PunchNode

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.RetentionNode

cleanup() - Method in class org.thales.punch.libraries.storm.bolt.SplitNode

CLEANUP - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

ClickHouseBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

ClickHouseBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.ClickHouseBoltFactory

ClickHouseOutput - Class in org.thales.punch.libraries.storm.bolt

This bolt will enable you to insert data into a ClickHouse database.

ClickHouseOutput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.ClickHouseOutput

close(List<String>) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AvroParquetArchiveBuffer

close(List<String>) - Method in interface org.thales.punch.libraries.storm.bolt.file.buffer.IArchiveBuffer

Close this archive buffer.

close(List<String>) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

close(List<String>) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.StreamingGzipArchiveBuffer

close() - Method in class org.thales.punch.libraries.storm.bolt.impl.KafkaOutputBoltPartitioner

close() - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

close() - Method in class org.thales.punch.libraries.storm.spout.ExtractionInput

close() - Method in class org.thales.punch.libraries.storm.spout.HttpInput

Close callback, notified by Storm runtime at topology deactivation.

close() - Method in class org.thales.punch.libraries.storm.spout.impl.HttpServer

close() - Method in class org.thales.punch.libraries.storm.spout.impl.LumberjackServer

close() - Method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

Close the server

close() - Method in class org.thales.punch.libraries.storm.spout.impl.UdpSyslogServer

Close the server

close() - Method in class org.thales.punch.libraries.storm.spout.LumberjackInput

Close callback, notified by Storm runtime at topology deactivation.

close() - Method in class org.thales.punch.libraries.storm.spout.RelpInput

close() - Method in class org.thales.punch.libraries.storm.spout.SFTPSpout

close() - Method in class org.thales.punch.libraries.storm.spout.SmtpInput

Close callback, notified by Storm runtime at topology deactivation.

close() - Method in class org.thales.punch.libraries.storm.spout.SyslogInput

Close callback, notified by Storm runtime at topology deactivation.

close() - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

closeRequested() - Method in class org.thales.punch.libraries.storm.bolt.impl.AsyncKafkaProducer

COLUMN_NAME_WRAPPER_CHAR_SETTING - Static variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

column_name_wrapper_char: This optional setting provides a DB-specific character that will be used around column names to allow for special characters in column names, like @

COLUMN_NAMES_SETTING - Static variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

Settings

COLUMN_TYPE_CAST - Static variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

COLUMN_TYPE_FUNCTION - Static variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

columnNames - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

columnNameWrapper - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

columnsNamesSeparator - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

componentId - Variable in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

compress(String) - Static method in class org.thales.punch.libraries.storm.impl.CompressionHelper

CompressionHelper - Class in org.thales.punch.libraries.storm.impl

This class provides methods to compress/decompress hasn maps.

CompressionHelper() - Constructor for class org.thales.punch.libraries.storm.impl.CompressionHelper

compressResources(Map<String, Object>) - Static method in class org.thales.punch.libraries.storm.impl.CompressionHelper

Compress all the String resources.

compute(Tuple, List<Operation>) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.Record

Run the sequence of operations on an incoming tuple.

configure(Map<String, ?>) - Method in class org.thales.punch.libraries.storm.bolt.impl.KafkaOutputBoltPartitioner

ConstantAdditionalValue - Class in org.thales.punch.libraries.storm.bolt.elasticsearch

A constant key value IAdditionalValue.

ConstantAdditionalValue(Object, String) - Constructor for class org.thales.punch.libraries.storm.bolt.elasticsearch.ConstantAdditionalValue

Ctor.

CONSUMER_MODE - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

CONSUMER_MODE_DEFAULT - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

contains(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

convert(Tuple) - Method in interface org.thales.punch.libraries.storm.bolt.impl.IInputTupleConverter

convert(StreamDeclaration, T) - Method in interface org.thales.punch.libraries.storm.bolt.impl.IOutputTupleConverter

convert(Tuple) - Method in class org.thales.punch.libraries.storm.converter.InputTupleConverterImpl

Transformation between Storm Tuple to Punch Tuple

convert(StreamDeclaration, Tuple) - Method in class org.thales.punch.libraries.storm.converter.OutputTupleConverterImpl

Transformation between Punch Tuple from module to Object List

CONVERT_BOOLEAN_TO_INT_SETTING - Static variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

convert_boolean_to_int: if true, then the boolean value will be converted to 0 or 1 integer value at insert

convertBooleanToInt - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

CountFieldOperation - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

CountFieldOperation(String, String) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.CountFieldOperation

CountFieldValueOperation - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

CountFieldValueOperation(String, String, long, String) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.CountFieldValueOperation

CountOperation - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

CountOperation(String) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.CountOperation

createArchiver(BatchMetadata) - Method in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

Create correct BatchArchiver from metadata

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.ArchiveReaderNodeFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.ClickHouseBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.DistinctLogCounterBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.ElasticSearchOutputFactory

Create en ElasticSearch bolt.

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.FileOutputFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.FileTransferBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.FilterBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.HttpBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.KafkaBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.LumberjackBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.OmniSciBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.PostgresqlBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.PunchBoltDispatcherFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.PunchBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.RawPacketBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.RetentionBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.RythmerBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.SplitBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.SyslogBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.SyslogUdpBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.TestBoltFactory

createBolt(IPlatform, NodeSettings, ITopologySettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomBoltFactory

createComponentSettings(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.bolt.factory.KafkaBoltFactory

Creates settings needed by the Kafka producer.

createConfig(ITopologySettings) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyFactory

Creates a Storm topology configuration from an PunchPlatform configuration.

createEmbeddedTopology(ITopologySettings, List<String>) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyFactory

createLocalTopology(ITopologySettings, List<String>) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyFactory

createRemoteTopology(ITopologySettings, String, List<String>) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyFactory

createRoot - Variable in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.AzureBlobStorageSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.ExtractionInputFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.FileSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.GeneratorSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.HttpSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.KafkaSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.LumberjackSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.NSGAzureBlobStorageSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.SnmpSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.SyslogSpoutFactory

createSpout(NodeSettings, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.spout.factory.WrapperCustomSpoutFactory

createTopology(ITopologyBuilder, ITopologySettings, IPunchPlatformProperties) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyFactory

Build a Storm or embedded topology from an PunchPlatform configuration.

D

database - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

DATE_PATTERN - Static variable in class org.thales.punch.libraries.storm.core.topology.TopologyFactory

The pattern appended to the topology name.

DateAdditionalValue - Class in org.thales.punch.libraries.storm.bolt.elasticsearch

A small utility builder class to efficiently generate a json line containing the current time as a correctly formatted string.

DateAdditionalValue(String, String, String) - Constructor for class org.thales.punch.libraries.storm.bolt.elasticsearch.DateAdditionalValue

deactivate() - Method in class org.thales.punch.libraries.storm.spout.HttpInput

deactivate() - Method in class org.thales.punch.libraries.storm.spout.LumberjackInput

deactivate() - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

declare(Fields) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightOutputDeclarer

declare(boolean, Fields) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightOutputDeclarer

declareOutputFields(OutputFieldsDeclarer) - Method in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

declareOutputFields(OutputFieldsDeclarer) - Method in class org.thales.punch.libraries.storm.bolt.LumberjackOutput

declareOutputFields(OutputFieldsDeclarer) - Method in class org.thales.punch.libraries.storm.bolt.ModuleNode

This bolt does not add any new field to the stream.

declareOutputFields(OutputFieldsDeclarer) - Method in class org.thales.punch.libraries.storm.bolt.SplitNode

This bolt does not add any new field to the stream.

declareOutputFields(OutputFieldsDeclarer) - Method in class org.thales.punch.libraries.storm.bolt.SyslogOutput

declareOutputFields(OutputFieldsDeclarer) - Method in class org.thales.punch.libraries.storm.bolt.SyslogUdpOutput

declareOutputFields(OutputFieldsDeclarer) - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

declareStream(String, Fields) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

Make this component publish some fields over a stream

declareStream(String, Fields) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightOutputDeclarer

declareStream(String, boolean, Fields) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightOutputDeclarer

decompress(byte[]) - Static method in class org.thales.punch.libraries.storm.impl.CompressionHelper

decPendingCount() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpoutOutputCollector

DEFAULT_HOST - Static variable in class org.thales.punch.libraries.storm.spout.ExtractionInput

DEFAULT_MODE - Static variable in class org.thales.punch.libraries.storm.spout.factory.ExtractionInputFactory

DEFAULT_PORT - Static variable in class org.thales.punch.libraries.storm.spout.ExtractionInput

deserialize(EthernetPacket) - Method in enum org.thales.punch.libraries.storm.bolt.rawpacket.EthernetPacketDeserializers

deserialize(EthernetPacket) - Method in interface org.thales.punch.libraries.storm.bolt.rawpacket.IEthernetPacketDeserializer

deserialize(byte[]) - Method in class org.thales.punch.libraries.storm.spout.impl.StringKafkaSpoutScheme

deserialize(ByteBuffer) - Method in class org.thales.punch.libraries.storm.spout.impl.StringKafkaSpoutScheme

deserializeString(byte[]) - Static method in class org.thales.punch.libraries.storm.spout.impl.StringKafkaSpoutScheme

destinations - Variable in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

DirWatcher - Class in org.thales.punch.libraries.storm.util

DirWatcher is a TimerTask class that periodically watch changes on a defined directory.

DirWatcher(String, String) - Constructor for class org.thales.punch.libraries.storm.util.DirWatcher

Constructor of the class.

DirWatcher(String, String, FileTime) - Constructor for class org.thales.punch.libraries.storm.util.DirWatcher

Constructor of the class.

DistinctLogCounterBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build a the distinct log counter bolt

DistinctLogCounterBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.DistinctLogCounterBoltFactory

Default constructor.

DistinctLogCounterNode - Class in org.thales.punch.libraries.storm.bolt

Count the distinct log, differentiated with their sequence identifier

DistinctLogCounterNode(NodeSettings, ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.bolt.DistinctLogCounterNode

Create a new SplitBolt

DOWNLOAD_ADD_SUFFIX - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

DOWNLOAD_IGNORE_SUFFIX - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

DOWNLOAD_PATH - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

drainNextLogs() - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput

E

EArchiverType - Enum in org.thales.punch.libraries.storm.bolt.file

Defines the supported archiver implementation.

ElasticBulkRequest - Class in org.thales.punch.libraries.storm.bolt.elasticsearch

This class only takes care of executing a single bulk request for the regular input document.

ElasticBulkRequest(ElasticsearchOutput, RestHighLevelClient, BulkRequest, ElasticDocument[], int) - Constructor for class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticBulkRequest

ElasticDocument - Class in org.thales.punch.libraries.storm.bolt.elasticsearch

A transient data structure to hold a document in the pipe to be sent to elasticsearch

ElasticDocument(Tuple, String, String, String, String) - Constructor for class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

ElasticDocumentBuilder - Class in org.thales.punch.libraries.storm.bolt.elasticsearch

A utility class to build the final json document from the fields received in a storm tuple.

ElasticDocumentBuilder(ISettingsMap) - Constructor for class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocumentBuilder

ElasticErrorBulkRequest - Class in org.thales.punch.libraries.storm.bolt.elasticsearch

This class only takes care of executing a single bulk request to reindex error documents.

ElasticErrorBulkRequest(ElasticsearchOutput, RestHighLevelClient, BulkRequest, List<ElasticDocument>) - Constructor for class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticErrorBulkRequest

ElasticRequestRunnable - Class in org.thales.punch.libraries.storm.spout.es.wrapper.plugins

ElasticRequestRunnable(LinkedBlockingQueue<String>, ElasticClientWrapper, ConcurrentMap<String, Object>) - Constructor for class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.ElasticRequestRunnable

ElasticsearchOutput - Class in org.thales.punch.libraries.storm.bolt

The Elasticsearch output node sends tuples to Elasticsearch.

ElasticsearchOutput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

Constructor

ElasticSearchOutputFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Setup an elasticsearch bolt.

ElasticSearchOutputFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.ElasticSearchOutputFactory

Default constructor.

emit(String, Collection<Tuple>, List<Object>) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

Emit a new tuple, anchored by another one.

emit(String, List<Object>, LightTuple) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltRunner

Emit a tuple from a bolt.

emit(String, List<Object>, Object) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpout

Emit a spout tuple.

emit(String, List<Object>, Object) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpoutOutputCollector

emitDirect(int, String, Collection<Tuple>, List<Object>) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

emitDirect(int, String, List<Object>, Object) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpoutOutputCollector

emitNextLine(String, Map<String, String>) - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput

equals(Object) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMapKey

equals(Object) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.RecordKey

equals(Object) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

errorStream - Variable in class org.thales.punch.libraries.storm.spout.AbstractKafkaNode

The error stream is used to forward error documents

EthernetPacketDeserializers - Enum in org.thales.punch.libraries.storm.bolt.rawpacket

execute(Timer.Context, Counter, Every) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticBulkRequest

execute(Timer.Context, Counter, Every) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticErrorBulkRequest

exit(Exception) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

Exit archiving.

exit(Exception) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.StreamingGzipArchiveBuffer

exitOnFailure - Variable in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

Make the process exit if the writing to Kafka fails

expirationTimeout - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

ExtractionInput - Class in org.thales.punch.libraries.storm.spout

Light topology elastic input node designed for extraction

ExtractionInput(NodeSettings, List<ISettingsMap>, List<ISettingsMap>, ISettingsMap, ISettingsMap, String) - Constructor for class org.thales.punch.libraries.storm.spout.ExtractionInput

ExtractionInputFactory - Class in org.thales.punch.libraries.storm.spout.factory

ExtractionInputFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.ExtractionInputFactory

F

factory(ISettingsMap) - Static method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.Operation

fail(Object) - Method in interface org.thales.punch.libraries.storm.core.topology.light.LightAcker

Fail a (spout) tuple.

fail(Tuple) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

This method is thread safe.

fail(Object) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpout

fail() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

Once a tuple is failed, subsequent fail or acks are discarded.

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.AbstractSocketInput

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.AzureBlobStorageSpout

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.ExtractionInput

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.GeneratorInput

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.HttpInput

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.KafkaInput

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.LumberjackInput

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.SFTPSpout

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.SyslogInput

fail(Object) - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

failAll() - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

failDocument(ElasticDocument) - Method in class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

failed - Variable in class org.thales.punch.libraries.storm.spout.AbstractFileInput

Ths queue holds failed tuples, the failed lines of data that must be reemitted.

failStop - Variable in class org.thales.punch.libraries.storm.spout.AbstractKafkaNode

True to make the spout exit in case it receives a failed tuple

FailureHandler - Class in org.thales.punch.libraries.storm.bolt.elasticsearch

FailureHandler(String, String) - Constructor for class org.thales.punch.libraries.storm.bolt.elasticsearch.FailureHandler

FailureHandler.FailureAction - Enum in org.thales.punch.libraries.storm.bolt.elasticsearch

fatalException(Exception) - Static method in class org.thales.punch.libraries.storm.util.ArchiveUtils

Log a fatal exception and exit.

FieldAdditionalValue - Class in org.thales.punch.libraries.storm.bolt.elasticsearch

A key value IAdditionalValue that takes its value from a storm tuple.

FieldAdditionalValue(String, String) - Constructor for class org.thales.punch.libraries.storm.bolt.elasticsearch.FieldAdditionalValue

fieldIndex(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

fieldName - Variable in class org.thales.punch.libraries.storm.spout.impl.StringKafkaSpoutScheme

fieldsGrouping(String, String, Fields) - Method in interface org.thales.punch.libraries.storm.core.topology.IBoltDeclarer

fieldsGrouping(String, String, Fields) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltDeclarer

fieldsGrouping(String, String, Fields) - Method in class org.thales.punch.libraries.storm.core.topology.StormBoltDeclarer

FILE_COMPLETE_MARKER - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

filename - Variable in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

fileNameSupplier - Variable in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

This supplier is in charge of providing us with the identifier of each batch.

FileOutputFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build correct FileBolt.

FileOutputFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.FileOutputFactory

Default constructor.

FileRecord - Class in org.thales.punch.libraries.storm.util

This class holds a file and keeps track of what has been read so far.

FileRecord(File) - Constructor for class org.thales.punch.libraries.storm.util.FileRecord

Creates a new FileRecord

FileSpout - Class in org.thales.punch.libraries.storm.spout.impl

The original implementation of the File Spout.

FileSpout(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.spout.impl.FileSpout

FileSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Create regular and watcher file spouts.

FileSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.FileSpoutFactory

Default constructor.

FileSpoutWatcher - Class in org.thales.punch.libraries.storm.spout.impl

The "Watcher" implementation of the File Spout.

FileSpoutWatcher(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.spout.impl.FileSpoutWatcher

Ctor.

FileTransferBolt - Class in org.thales.punch.libraries.storm.bolt

This node enable you to transfer file located on your filesystem to somewhere else: S3, Hadoop, FileSystem (based on supported sink point of avro-parquet lib)

FileTransferBolt(NodeSettings, String, String, ISettingsMap) - Constructor for class org.thales.punch.libraries.storm.bolt.FileTransferBolt

FileTransferBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

FileTransferBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.FileTransferBoltFactory

FilterBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

FilterBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.FilterBoltFactory

FilterNode - Class in org.thales.punch.libraries.storm.bolt

The Filter bolt provides useful, simple, yet efficient filtering capabilities with low cpu usage.

FilterNode(NodeSettings, ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.bolt.FilterNode

Create a new Filter

fire(long, Logger) - Static method in class org.thales.punch.libraries.storm.util.WatchDog

Return a punch LastEventOperator register into a singleton watchdog.

fireNewLogFileLine(String, Map<String, String>) - Method in class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

flush(BatchArchiver) - Method in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

Flush this batch, i.e.

flush() - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Flush your archive.

flush() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

flush() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpoutOutputCollector

formatColumnForAutoCast(Object) - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

formatColumnForAutoCast(Object) - Method in class org.thales.punch.libraries.storm.bolt.PostgresqlOutput

formatColumnForFunction(Object) - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

forwardOrFailDocument(ElasticDocument, String) - Method in class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

G

GeneratorInput - Class in org.thales.punch.libraries.storm.spout

The generator publishes fake data in configurable streams.

GeneratorInput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.spout.GeneratorInput

Create a new Generator spout

GeneratorSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Generator Spout factory

GeneratorSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.GeneratorSpoutFactory

Default constructor.

get(String) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMap

get() - Method in class org.thales.punch.libraries.storm.bolt.file.ObjectStorageFileNameSupplier

getAdditionalValue(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ConstantAdditionalValue

This method returns a ready to use ",\"key\": value" string

getAdditionalValue(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.DateAdditionalValue

This method returns a ready to be inserted timestamp json line.

getAdditionalValue(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.FieldAdditionalValue

This method returns a ready to be inserted value

getAdditionalValue(Tuple) - Method in interface org.thales.punch.libraries.storm.bolt.elasticsearch.IAdditionalValue

This method returns a ready to use "\"key\":value" string

getAnchor() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getAnchoredTuple() - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Getter for anchored tuple

getAttachement() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

The attachement is an arbitrary object attached to that tuple.

getBatchMetadata() - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

An BatchArchiver is handling a single batch.

getBatchOutputPath() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

Return full batch path from metadata.

getBinary(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getBinaryByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getBloomFilterFields() - Method in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

Getter for bloom fields.

getBoltDispatcherById(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getBoltTuple(String, String, List<Object>, Fields, LightTuple) - Static method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

Build a new bolt tuple.

getBoolean(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getBooleanByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getByte(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getByteArray() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.GzipArchiveBuffer

getByteArray() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

Get final byte array

getByteByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getBytes(Long) - Method in class org.thales.punch.libraries.storm.util.FileRecord

Reads the file

getClonedBoltInstance() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltDispatcher

This method reserialize a fresh new tuple instance from the original bolt.

getCodec(ISettingsMap) - Method in class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

Build specific codec from config

getCodec(ISettingsMap) - Static method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

Build specific codec from the caller configuration.

getComponentById(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getComponentConfiguration() - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

getComponentConfiguration() - Method in class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

getComponentConfiguration() - Method in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomOutput

getComponentConfiguration() - Method in class org.thales.punch.libraries.storm.bolt.impl.AtLeastOnceFileOutput

getComponentConfiguration() - Method in class org.thales.punch.libraries.storm.bolt.OmniSciOutput

getComponentConfiguration() - Method in class org.thales.punch.libraries.storm.bolt.PunchNode

We request from storm a regular callback.

getComponentConfiguration() - Method in class org.thales.punch.libraries.storm.bolt.RetentionNode

getComponentConfiguration() - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

getComponentId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltDispatcher

getComponentId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

getComponentNode(String) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyGraph

getComponentTasks(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LigthTopologyContext

getContext() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getCreatedTime() - Method in class org.thales.punch.libraries.storm.util.FileRecord

getDefaultColumnNameWrapperChar() - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

getDefaultColumnNameWrapperChar() - Method in class org.thales.punch.libraries.storm.bolt.ClickHouseOutput

getDefaultConvertBooleanToInt() - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

getDefaultConvertBooleanToInt() - Method in class org.thales.punch.libraries.storm.bolt.ClickHouseOutput

getDeserializer(String) - Static method in enum org.thales.punch.libraries.storm.bolt.rawpacket.EthernetPacketDeserializers

getDigest() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AvroParquetArchiveBuffer

getDigest() - Method in interface org.thales.punch.libraries.storm.bolt.file.buffer.IArchiveBuffer

Return the digest of written bytes

getDigest() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

getDigest() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.StreamingGzipArchiveBuffer

getDocumentIdField() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocumentBuilder

getDocumentType() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocumentBuilder

Type mapping are deprecated since ES7, but we still need compatibility with older clusters.

getDocumentValue(Tuple, String) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocumentBuilder

getDouble(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getDoubleByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getEarliest() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMap

getElapsedTime() - Method in class org.thales.punch.libraries.storm.util.LoadControlItem

getEmitterNodeId() - Method in class org.thales.punch.libraries.storm.core.topology.StreamSubscription

getErrorDocument(String, String, String) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

getExecutors() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltDispatcher

getExpirationCause() - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Getter for expiration cause

getFields() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getFile() - Method in class org.thales.punch.libraries.storm.util.FileRecord

getFileAttributes() - Method in class org.thales.punch.libraries.storm.util.FileRecord

getFloat(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getFloatByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getGroks() - Method in class org.thales.punch.libraries.storm.util.PunchletConfig

getHashId() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.Key

getId() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

getId(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocumentBuilder

getId() - Method in class org.thales.punch.libraries.storm.core.topology.TopologyGraphNode

getIndex() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

getIndex(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocumentBuilder

Return the target index depending on the input configuration

getInputQueue() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltDispatcher

getInstance() - Static method in class org.thales.punch.libraries.storm.util.WhiteBoard

The getInstance method is in charge of returning the singleton static instance of the whiteboard object.

getInstanceId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getInteger(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getIntegerByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getJdbcClient() - Method in class org.thales.punch.libraries.storm.bolt.impl.JdbcHandle

getJsonResources() - Method in class org.thales.punch.libraries.storm.util.PunchletConfig

getKey() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ConstantAdditionalValue

getKey() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.DateAdditionalValue

getKey() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.FieldAdditionalValue

getKey() - Method in interface org.thales.punch.libraries.storm.bolt.elasticsearch.IAdditionalValue

getLastModTime() - Method in class org.thales.punch.libraries.storm.util.FileRecord

getLastRead() - Method in class org.thales.punch.libraries.storm.util.FileRecord

getLatest() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMap

getLightOutputCollector() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltRunner

getLightSpoutOutputCollector() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpout

getLine() - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput.Item

getListFiles(File) - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput

This method constructs a list of files to process from different format, in subfolders or compressed.

getLong(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getLongByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getLongField(ITuple, String, Long) - Static method in class org.thales.punch.libraries.storm.util.ArchiveUtils

getMandatoryIntegerField(ITuple, String) - Static method in class org.thales.punch.libraries.storm.util.ArchiveUtils

Fast fail if a mandatory integer field is missing.

getMandatoryLongField(ITuple, String) - Static method in class org.thales.punch.libraries.storm.util.ArchiveUtils

Fast fail if a mandatory long field is missing.

getMaxSpoutPending() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getMessageId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getMessageId() - Method in class org.thales.punch.libraries.storm.util.LoadControlItem

getMessageTimeoutSec() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getName() - Method in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput.Topic

getName() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.Operation

getOutputFields() - Method in class org.thales.punch.libraries.storm.spout.impl.StringKafkaSpoutScheme

getPayload() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

getPendingCount() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpoutOutputCollector

getProperties() - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput.Item

getPublishedStreamConfig(NodeSettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.KafkaBoltFactory

getPublishedStreamConfig(NodeSettings) - Method in class org.thales.punch.libraries.storm.bolt.factory.LumberjackBoltFactory

getPublishedStreamConfig(NodeSettings) - Method in class org.thales.punch.libraries.storm.spout.factory.GeneratorSpoutFactory

getPublishedStreamConfig(NodeSettings) - Method in class org.thales.punch.libraries.storm.spout.factory.KafkaSpoutFactory

getPublishedStreams() - Method in class org.thales.punch.libraries.storm.core.topology.TopologyGraphNode

getPunchletBlocks() - Method in class org.thales.punch.libraries.storm.util.PunchletConfig

getPunchletConfig(ISettingsMap, String, String, ITopologySettings) - Static method in class org.thales.punch.libraries.storm.bolt.factory.PunchBoltFactory

Load all the required resource and punchlet files and return a ready to use PunchletConfig.

getPunchletConfig(ISettingsMap, String, String, ITopologySettings, String, Path) - Static method in class org.thales.punch.libraries.storm.bolt.factory.PunchBoltFactory

This method looks for punchlets in a local configuration directory.

getPunchletConfig(ISettingsMap, ITopologySettings, String) - Static method in class org.thales.punch.libraries.storm.bolt.factory.PunchBoltFactory

getQueue() - Method in class org.thales.punch.libraries.storm.spout.impl.HttpServer

getRefCount() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getRuntimeData(Object, int) - Method in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

getShort(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getShortByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getSiddhiRules() - Method in class org.thales.punch.libraries.storm.util.PunchletConfig

getSize() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AvroParquetArchiveBuffer

getSize() - Method in interface org.thales.punch.libraries.storm.bolt.file.buffer.IArchiveBuffer

Return the size, compressed if compression enabled, of written bytes

getSize() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

getSize() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.StreamingGzipArchiveBuffer

getSize() - Method in class org.thales.punch.libraries.storm.util.FileRecord

getSizeLeft() - Method in class org.thales.punch.libraries.storm.util.FileRecord

getSocketHostAddress(InetSocketAddress) - Method in class org.thales.punch.libraries.storm.spout.AbstractSocketInput

getSourceComponent() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getSourceGlobalStreamId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getSourceStreamId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getSourceTask() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getSpout() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpout

getSpoutById(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getSpoutTuple(String, String, List<Object>, Fields, Object) - Static method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

Build a new spout tuple.

getStormId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getStormId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LigthTopologyContext

getStormTopology() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getStormTopologyPluginsJarPaths() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

getStreamId() - Method in class org.thales.punch.libraries.storm.core.topology.StreamSubscription

getString(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getStringByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getStringResources() - Method in class org.thales.punch.libraries.storm.util.PunchletConfig

getSubscriptions() - Method in class org.thales.punch.libraries.storm.core.topology.TopologyGraphNode

getTargetTopic(String) - Method in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

getThisComponentId() - Method in class org.thales.punch.libraries.storm.core.topology.light.LigthTopologyContext

getThisTaskIndex() - Method in class org.thales.punch.libraries.storm.core.topology.light.LigthTopologyContext

getThisWorkerPort() - Method in class org.thales.punch.libraries.storm.core.topology.light.LigthTopologyContext

getThisWorkerTasks() - Method in class org.thales.punch.libraries.storm.core.topology.light.LigthTopologyContext

getTickTuple() - Static method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getTimestampFromTuple(ITuple) - Method in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

Extracts a timestamp from the received tuple.

getTmpName() - Method in class org.thales.punch.libraries.storm.util.FileRecord

getTopology() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopologyBuilder

getTopology() - Method in class org.thales.punch.libraries.storm.core.topology.StormTopologyBuilder

getTopologyContext() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

The associated topology context is actually per component, as it provides per component informations such as the component identifier.

getTuple() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

getTupleId(Object, boolean) - Method in class org.thales.punch.libraries.storm.spout.AbstractKafkaNode

Every tuple is acked or failed, even when working with batches.

getType() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

getType() - Method in class org.thales.punch.libraries.storm.spout.impl.HttpServer

getType() - Method in class org.thales.punch.libraries.storm.spout.impl.LumberjackServer

getType() - Method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

getType() - Method in class org.thales.punch.libraries.storm.spout.impl.UdpSyslogServer

getType() - Method in class org.thales.punch.libraries.storm.spout.RelpInput

getUncompressedSize() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AvroParquetArchiveBuffer

getUncompressedSize() - Method in interface org.thales.punch.libraries.storm.bolt.file.buffer.IArchiveBuffer

Return the size, uncompressed if compression enabled, of written bytes

getUncompressedSize() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

getUncompressedSize() - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.StreamingGzipArchiveBuffer

getUuid() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getValue() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.Timestamp

getValue(int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getValueByField(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

getValues() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

GzipArchiveBuffer - Class in org.thales.punch.libraries.storm.bolt.file.buffer

The Gzip archiver creates a RAM byte array with gzip compressed batch content before writing to file (no streaming).

GzipArchiveBuffer(int, int, List<ArchiveDevice>, IRecordEncoder<Map<String, Object>>, IRecordEncoder.RecordFormat, boolean) - Constructor for class org.thales.punch.libraries.storm.bolt.file.buffer.GzipArchiveBuffer

Ctor

H

handleDeviceFailure(String, String, Exception, int) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

When device fails to open, write or close, the device is considered down.

hasExpired(long, long) - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Check if this batch has expired, given an expiration timeout.

hashCode() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMapKey

hashCode() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.RecordKey

hashCode() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

hikariConfigMaps - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

hosts - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

HttpBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build a HttpNode from NodeSettings, ITopologySettings.

HttpBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.HttpBoltFactory

HttpInput - Class in org.thales.punch.libraries.storm.spout

The Http spout receives http requests and forwards them as tuple.

HttpInput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.spout.HttpInput

A Spout constructor is in charge of setting the fields that will be required later on when the spout will be effectively started and run somewhere in the cluster.

HttpNode - Class in org.thales.punch.libraries.storm.bolt

Send http request for each tuple.

HttpNode(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.HttpNode

HttpServer - Class in org.thales.punch.libraries.storm.spout.impl

This http server puts all the received event lines in a queue, ready to be consumed by a storm spout.

HttpServer(ISettingsMap, int, IMetricContext) - Constructor for class org.thales.punch.libraries.storm.spout.impl.HttpServer

HttpSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Build a SyslogInput from NodeSettings.

HttpSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.HttpSpoutFactory

Default constructor.

I

IAdditionalValue - Interface in org.thales.punch.libraries.storm.bolt.elasticsearch

The elasticsearch bolt needs to add additional key values at the end of the json document to insert.

IArchiveBuffer - Interface in org.thales.punch.libraries.storm.bolt.file.buffer

This interface defines the contract for marshaling incoming data (i.e.

IBoltDeclarer - Interface in org.thales.punch.libraries.storm.core.topology

The bolt declarer interface.

IEthernetPacketDeserializer - Interface in org.thales.punch.libraries.storm.bolt.rawpacket

IFileNameSupplier - Interface in org.thales.punch.libraries.storm.bolt.file

Each batch receives a unique file name (or object name).

IInputTupleConverter<T> - Interface in org.thales.punch.libraries.storm.bolt.impl

Input Tuple Converter interface.

inc() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

initMetadata(long) - Method in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

Common metadata initialization

inputQueue - Variable in class org.thales.punch.libraries.storm.spout.AbstractFileInput

Internal FileSpout queue to put read items before doing the actual processing.

inputQueues - Static variable in class org.thales.punch.libraries.storm.spout.AbstractFileInput

Keep track of internal queues based on the Storm component ID.

InputTupleConverterImpl - Class in org.thales.punch.libraries.storm.converter

Implementation of InputTupleConverter.

InputTupleConverterImpl() - Constructor for class org.thales.punch.libraries.storm.converter.InputTupleConverterImpl

IOutputTupleConverter<T> - Interface in org.thales.punch.libraries.storm.bolt.impl

Output Tuple Converter interface.

isAborted() - Method in class org.thales.punch.libraries.storm.util.FileRecord

isCompleted() - Method in class org.thales.punch.libraries.storm.util.FileRecord

isEnabled() - Method in class org.thales.punch.libraries.storm.bolt.impl.JdbcHandle

isEnabledMessageTimeout() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

isNullIdsAreErrors() - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocumentBuilder

isRunning - Variable in class org.thales.punch.libraries.storm.bolt.RythmerNode

use to verify if the consummer is aldreay running

isSpoutTuple() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

This method is thread-safe.

isStarted() - Method in class org.thales.punch.libraries.storm.util.FileRecord

ISubscription - Interface in org.thales.punch.libraries.storm.util

ISyslogReceiver<T> - Interface in org.thales.punch.libraries.storm.spout.impl

ISyslogServer - Interface in org.thales.punch.libraries.storm.spout.impl

Item(String, Map<String, String>) - Constructor for class org.thales.punch.libraries.storm.spout.AbstractFileInput.Item

ITopologyBuilder - Interface in org.thales.punch.libraries.storm.core.topology

IWhiteBoard - Interface in org.thales.punch.libraries.storm.util

J

JdbcHandle - Class in org.thales.punch.libraries.storm.bolt.impl

JdbcHandle(Map<String, Object>, int) - Constructor for class org.thales.punch.libraries.storm.bolt.impl.JdbcHandle

Create a JDBC handle.

jdbcHandleIterator - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

JsonKafkaOutput - Class in org.thales.punch.libraries.storm.bolt.impl

JsonKafkaOutput(NodeSettings, Properties) - Constructor for class org.thales.punch.libraries.storm.bolt.impl.JsonKafkaOutput

JsonToNDJson - Class in org.thales.punch.libraries.storm.spout.es.wrapper.plugins

JsonToNDJson(List<ISettingsMap>, List<ISettingsMap>) - Constructor for class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.JsonToNDJson

JsonToNDJson.Mode - Enum in org.thales.punch.libraries.storm.spout.es.wrapper.plugins

K

KafkaBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build a Storm topology.

KafkaBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.KafkaBoltFactory

Default constructor.

KafkaHeaderReader - Class in org.thales.punch.libraries.storm.util

This static class allows to decode kafka headers according to storm configuration 'headers_fields' The resulting HeaderDeclaration object is used to cast the header value according to its type, encoding or byte ordering

KafkaInput - Class in org.thales.punch.libraries.storm.spout

The KafkaInput node reads records from a topic and forwards them into a punchline.

KafkaInput(NodeSettings, String) - Constructor for class org.thales.punch.libraries.storm.spout.KafkaInput

Create a new Kafka node

KafkaOutputBoltPartitioner - Class in org.thales.punch.libraries.storm.bolt.impl

The partitioner is in charge of telling the kafka producer to which partition the next message should go to.

KafkaOutputBoltPartitioner() - Constructor for class org.thales.punch.libraries.storm.bolt.impl.KafkaOutputBoltPartitioner

KafkaSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Build a KafkaInput from NodeSettings, ITopologySettings.

KafkaSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.KafkaSpoutFactory

Default constructor.

Key - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

Key(Tuple, List<String>) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.Key

L

lastCommittedWriter() - Method in class org.thales.punch.libraries.storm.spout.AzureBlobStorageSpout

will be use to write last_committed on success

lastUpdateTimestamp - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

LightAcker - Interface in org.thales.punch.libraries.storm.core.topology.light

LightBoltDeclarer - Class in org.thales.punch.libraries.storm.core.topology.light

The LightBoltDeclarer is in charge of wiring the topology graph.

LightBoltDeclarer(LightTopology, String, IRichBolt, int) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightBoltDeclarer

Ctor.

LightBoltDispatcher - Class in org.thales.punch.libraries.storm.core.topology.light

To each bolt is associated one LightBoltDispatcher.

LightBoltDispatcher(LightTopology, TopologyContext, String, IRichBolt, int) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightBoltDispatcher

LightBoltOutputCollector - Class in org.thales.punch.libraries.storm.core.topology.light

LightBoltOutputCollector(LightBoltRunner) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

LightBoltRunner - Class in org.thales.punch.libraries.storm.core.topology.light

A LightBoltRunner is in charge of running one instance of a bolt.

LightBoltRunner(LightTopology, TopologyContext, LightBoltDispatcher, IRichBolt) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightBoltRunner

LightComponent - Class in org.thales.punch.libraries.storm.core.topology.light

A (bolt or spout) component.

LightComponent(LightTopology, String, TopologyContext) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightComponent

LightOutputDeclarer - Class in org.thales.punch.libraries.storm.core.topology.light

LightOutputDeclarer(LightTopology, String) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightOutputDeclarer

LightOutputDeclarer(LightComponent) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightOutputDeclarer

LightSpout - Class in org.thales.punch.libraries.storm.core.topology.light

LightSpout(LightTopology, String, ISpout, TopologyContext) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightSpout

LightSpoutOutputCollector - Class in org.thales.punch.libraries.storm.core.topology.light

This class is the output collector used by the light storm engine.

LightSpoutOutputCollector(LightSpout) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightSpoutOutputCollector

LightTopology - Class in org.thales.punch.libraries.storm.core.topology.light

LightTopology(ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightTopology

LightTopologyBuilder - Class in org.thales.punch.libraries.storm.core.topology.light

Builder class for light topologies.

LightTopologyBuilder(ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LightTopologyBuilder

LightTuple - Class in org.thales.punch.libraries.storm.core.topology.light

These are the (storm compatible) tuples given to bolts.

LigthTopologyContext - Class in org.thales.punch.libraries.storm.core.topology.light

The ligthweigth topology context implementation.

LigthTopologyContext(String, String, int) - Constructor for class org.thales.punch.libraries.storm.core.topology.light.LigthTopologyContext

LoadControlItem<T> - Class in org.thales.punch.libraries.storm.util

This class helps you keep track of the time it takes to acknowledge or fail a tuple.

LoadControlItem(T) - Constructor for class org.thales.punch.libraries.storm.util.LoadControlItem

Create a new LoadControlItem.

localOrShuffleGrouping(String, String) - Method in interface org.thales.punch.libraries.storm.core.topology.IBoltDeclarer

localOrShuffleGrouping(String, String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltDeclarer

localOrShuffleGrouping(String, String) - Method in class org.thales.punch.libraries.storm.core.topology.StormBoltDeclarer

LogFileTailer - Class in org.thales.punch.libraries.storm.spout.impl

A log file tailer is designed to monitor a log file and send notifications when new lines are added to the log file.

LogFileTailer(ISettingsMap, Logger, File, long, boolean) - Constructor for class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

Creates a new log file tailer

LogFileTailerListener - Interface in org.thales.punch.libraries.storm.spout.impl

Provides listener notification methods when a tailed log file is updated

logStartFailure(String) - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

logStartProcessing() - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

logStartSuccess() - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

logStatistics(ISettingsMap) - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

logStopFailure(String) - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

logStopProcessing() - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

logStopSuccess() - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

LruCache<K,V> - Class in org.thales.punch.libraries.storm.spout.impl

LruCache(int) - Constructor for class org.thales.punch.libraries.storm.spout.impl.LruCache

LumberjackBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Setup a Syslog bolt.

LumberjackBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.LumberjackBoltFactory

LumberjackInput - Class in org.thales.punch.libraries.storm.spout

The Lumberjack spout receives and decodes lumberjack frames, emitted in turn as tuples.

LumberjackInput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.spout.LumberjackInput

A Spout constructor is in charge of setting the fields that will be required later on when the spout will be effectively started and run somewhere in the cluster.

LumberjackInputRecordType - Enum in org.thales.punch.libraries.storm.spout.impl

The possible type of lumberjack records we receive.

LumberjackKafkaOutput - Class in org.thales.punch.libraries.storm.bolt.impl

LumberjackKafkaOutput(NodeSettings, Properties) - Constructor for class org.thales.punch.libraries.storm.bolt.impl.LumberjackKafkaOutput

The properties must only contain string.

LumberjackOutput - Class in org.thales.punch.libraries.storm.bolt

The PunchPlatformBolt forwards messages to a next hop PunchPlatformSpout.

LumberjackOutput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.LumberjackOutput

Constructor.

LumberjackServer - Class in org.thales.punch.libraries.storm.spout.impl

This lumberjack server puts all the received log lines in a queue, ready to be consumed by a storm spout.

LumberjackServer(ISettingsMap, LinkedBlockingQueue<INettyTuple<Map<String, String>>>, int, IMetricContext) - Constructor for class org.thales.punch.libraries.storm.spout.impl.LumberjackServer

Ctor.

LumberjackSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Build a SyslogInput from NodeSettings.

LumberjackSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.LumberjackSpoutFactory

Default constructor.

M

maxTopologyMessageTimeout() - Method in class org.thales.punch.libraries.storm.core.topology.light.LigthTopologyContext

maxWrites - Variable in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

messagesProducingRate - Variable in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput.Topic

minWrites - Variable in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

ModuleNode<T,V> - Class in org.thales.punch.libraries.storm.bolt

A simple module bolt.

ModuleNode(NodeSettings, Serializable, ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.bolt.ModuleNode

mustCallNextTuple() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpout

N

newLogFileLine(String, Map<String, String>) - Method in interface org.thales.punch.libraries.storm.spout.impl.LogFileTailerListener

A new line has been added to the tailed log file

nextTuple() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpout

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput

Callback to feed the topology with tuples.

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.AbstractKafkaNode

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.AzureBlobStorageSpout

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.ExtractionInput

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.GeneratorInput

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.HttpInput

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.KafkaInput

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.LumberjackInput

Callback to feed the topology with tuples.

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.RelpInput

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.SFTPSpout

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.SmtpInput

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.SyslogInput

Callback to feed the topology with tuples.

nextTuple() - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

NSGAzureBlobStorageSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

NSGAzureBlobStorageSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.NSGAzureBlobStorageSpoutFactory

NULL_VALUE - Static variable in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.JsonToNDJson

O

ObjectStorageFileNameSupplier - Class in org.thales.punch.libraries.storm.bolt.file

A filename supplier for archiving.

ObjectStorageFileNameSupplier(String, String, int) - Constructor for class org.thales.punch.libraries.storm.bolt.file.ObjectStorageFileNameSupplier

Ctor

OmniSciBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

OmniSciBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.OmniSciBoltFactory

OmniSciOutput - Class in org.thales.punch.libraries.storm.bolt

This bolt will enable you to insert data into a MapD (OmniSci) database.

OmniSciOutput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.OmniSciOutput

onActive(ChannelHandlerContext) - Method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

onChange(File, String) - Method in class org.thales.punch.libraries.storm.impl.Watcher

onChange(File, String) - Method in class org.thales.punch.libraries.storm.util.DirWatcher

OneByOneFileOutput - Class in org.thales.punch.libraries.storm.bolt.impl

The "Exactly once" version of the FileBolt.
A special variation of the FileBolt that creates a dedicated file batch object for each Tuple.

OneByOneFileOutput(NodeSettings, List<ArchiveDevice>, IFileNameSupplier, ArchiveFormatSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.impl.OneByOneFileOutput

Ctor.

onInactive(ChannelHandlerContext) - Method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

onReceive(ChannelHandlerContext, INettyTuple<Map<String, Object>>) - Method in class org.thales.punch.libraries.storm.spout.impl.HttpServer

onReceive(NettyTupleImpl<T>) - Method in interface org.thales.punch.libraries.storm.spout.impl.ISyslogReceiver

onReceive(ChannelHandlerContext, INettyTuple<Map<String, String>>) - Method in class org.thales.punch.libraries.storm.spout.impl.LumberjackServer

onReceive(ChannelHandlerContext, INettyTuple<T>) - Method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

onReceive(ChannelHandlerContext, INettyTuple<T>) - Method in class org.thales.punch.libraries.storm.spout.impl.UdpSyslogServer

onReceive(IPartition, ConsumerRecord<byte[], byte[]>) - Method in class org.thales.punch.libraries.storm.spout.KafkaInput

onReceive(ChannelHandlerContext, INettyTuple<RELPFrame>) - Method in class org.thales.punch.libraries.storm.spout.RelpInput

onReceive(NettyTupleImpl<T>) - Method in class org.thales.punch.libraries.storm.spout.SyslogInput

onReceive(Object) - Method in interface org.thales.punch.libraries.storm.util.ISubscription

onReceiveTuple() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.AbstractKafkaNode

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.AbstractSocketInput

Setup this spout before it starts receiving data and emitting tuples into the topology.

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.AzureBlobStorageSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.ExtractionInput

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.GeneratorInput

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.HttpInput

Setup this spout before it starts receiving data and emitting tuples into the topology.

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.impl.FileSpout

Setup this spout before it starts receiving data and emitting tuples into the topology.

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.impl.FileSpoutWatcher

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.KafkaInput

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.LumberjackInput

Setup this spout before it starts receiving data and emitting tuples into the topology.

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.RelpInput

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.SFTPSpout

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.SmtpInput

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.SyslogInput

Setup this spout before it starts receiving data and emitting tuples into the topology.

open(Map, TopologyContext, SpoutOutputCollector) - Method in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

Operation - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

Operation(String) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.Operation

orderedRead - Variable in class org.thales.punch.libraries.storm.spout.AbstractFileInput

If set to true, every files will be proceed one by one in a single thread starting with the oldest files first.

org.thales.punch.libraries.storm.bolt - package org.thales.punch.libraries.storm.bolt

Punchplatform bolts package.

org.thales.punch.libraries.storm.bolt.aggregator.impl - package org.thales.punch.libraries.storm.bolt.aggregator.impl

org.thales.punch.libraries.storm.bolt.elasticsearch - package org.thales.punch.libraries.storm.bolt.elasticsearch

org.thales.punch.libraries.storm.bolt.factory - package org.thales.punch.libraries.storm.bolt.factory

org.thales.punch.libraries.storm.bolt.file - package org.thales.punch.libraries.storm.bolt.file

org.thales.punch.libraries.storm.bolt.file.buffer - package org.thales.punch.libraries.storm.bolt.file.buffer

org.thales.punch.libraries.storm.bolt.impl - package org.thales.punch.libraries.storm.bolt.impl

org.thales.punch.libraries.storm.bolt.rawpacket - package org.thales.punch.libraries.storm.bolt.rawpacket

org.thales.punch.libraries.storm.converter - package org.thales.punch.libraries.storm.converter

org.thales.punch.libraries.storm.core.topology - package org.thales.punch.libraries.storm.core.topology

org.thales.punch.libraries.storm.core.topology.light - package org.thales.punch.libraries.storm.core.topology.light

org.thales.punch.libraries.storm.impl - package org.thales.punch.libraries.storm.impl

org.thales.punch.libraries.storm.spout - package org.thales.punch.libraries.storm.spout

Punchplatform spouts package.

org.thales.punch.libraries.storm.spout.es.wrapper.plugins - package org.thales.punch.libraries.storm.spout.es.wrapper.plugins

org.thales.punch.libraries.storm.spout.factory - package org.thales.punch.libraries.storm.spout.factory

org.thales.punch.libraries.storm.spout.impl - package org.thales.punch.libraries.storm.spout.impl

org.thales.punch.libraries.storm.util - package org.thales.punch.libraries.storm.util

outgoingBytesRate - Variable in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput.Topic

outputStream - Variable in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

OutputTupleConverterImpl - Class in org.thales.punch.libraries.storm.converter

Implementation of OutputTupleConverter.

OutputTupleConverterImpl() - Constructor for class org.thales.punch.libraries.storm.converter.OutputTupleConverterImpl

P

partition(Object, int) - Method in class org.thales.punch.libraries.storm.bolt.impl.KafkaOutputBoltPartitioner

partition(String, Object, byte[], Object, byte[], Cluster) - Method in class org.thales.punch.libraries.storm.bolt.impl.KafkaOutputBoltPartitioner

password - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

path - Variable in class org.thales.punch.libraries.storm.spout.AbstractFileInput

The file or folder path to consume.

pathRegexPattern - Variable in class org.thales.punch.libraries.storm.spout.AbstractFileInput

The regualar expression pattern that any file must match to be proceed.

PlainArchiveBuffer - Class in org.thales.punch.libraries.storm.bolt.file.buffer

The plain archiver simply creates a RAM byte array with the batch content.

PlainArchiveBuffer(int, int, List<ArchiveDevice>, IRecordEncoder<Map<String, Object>>, IRecordEncoder.RecordFormat, boolean) - Constructor for class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

Ctor

pool - Variable in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

poolName - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

poolSize - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

PostgresqlBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

PostgresqlBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.PostgresqlBoltFactory

PostgresqlOutput - Class in org.thales.punch.libraries.storm.bolt

This bolt will enable you to insert data into a Postgresql database.

PostgresqlOutput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.PostgresqlOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

Prepare this bolt.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.ArchiveReaderNode

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.ClickHouseOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.DistinctLogCounterNode

Prepare this bolt.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomOutput

prepare(Supplier<IArchiveBuffer>, IMetricContext) - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Prepare this instance.

prepare(BatchMetadata) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AbstractArchiveBuffer

prepare(BatchMetadata) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AvroParquetArchiveBuffer

prepare(BatchMetadata) - Method in interface org.thales.punch.libraries.storm.bolt.file.buffer.IArchiveBuffer

Before using the archive buffer call this.

prepare(BatchMetadata) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.StreamingGzipArchiveBuffer

prepare(BatchMetadata) - Method in interface org.thales.punch.libraries.storm.bolt.file.IFileNameSupplier

Prepare this supplier before you use it to get a new batch identifier.

prepare(BatchMetadata) - Method in class org.thales.punch.libraries.storm.bolt.file.ObjectStorageFileNameSupplier

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.FileTransferBolt

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.FilterNode

Prepare this bolt.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.HttpNode

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.impl.AtLeastOnceFileOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.impl.JsonKafkaOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.impl.LumberjackKafkaOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.impl.OneByOneFileOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.LumberjackOutput

Setup this spout before starting emitting Tuples into the topology.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.ModuleNode

Prepare this bolt.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.OmniSciOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.PostgresqlOutput

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.PunchDispatcherNode

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.PunchNode

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.RawPacketNode

Prepare this bolt.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.RetentionNode

Prepare this bolt.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.RythmerNode

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.SplitNode

Prepare this bolt.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.SyslogOutput

Setup this spout before starting emitting Tuples into the topology.

prepare(Map, TopologyContext, OutputCollector) - Method in class org.thales.punch.libraries.storm.bolt.SyslogUdpOutput

Setup this spout before starting emitting Tuples into the topology.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.ArchiveReaderNode

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.DistinctLogCounterNode

The execute method is called by storm whenever some new tuples traverse the topology.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomOutput

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.FileTransferBolt

File that will be transfer are read line by line.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.FilterNode

The execute method is called by storm whenever some new tuples traverse the topology.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.HttpNode

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.impl.AtLeastOnceFileOutput

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.impl.JsonKafkaOutput

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.impl.LumberjackKafkaOutput

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.impl.OneByOneFileOutput

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.LumberjackOutput

Storm gives us tuple one by one.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.ModuleNode

The execute method is called by storm whenever some new tuples traverse the topology.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.OmniSciOutput

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.PunchDispatcherNode

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.PunchNode

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.RawPacketNode

The execute method is called by storm whenever some new tuples traverse the topology.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.RetentionNode

The execute method is called by storm whenever some new tuples traverse the topology.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.RythmerNode

Before sending the tuple to the consumer, the time difference between the previous message is calculated.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.SplitNode

The execute method is called by storm whenever some new tuples traverse the topology.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.SyslogOutput

The Syslog bolt expects a single field, and forwards that field to the destination.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.SyslogUdpOutput

The Syslog bolt expects a single field, and forwards that field to the destination.

process(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.TestNode

The execute method is called by storm whenever some new tuples traverse the topology.

process(Object, ConsumerRecord<byte[], byte[]>, KafkaBatchAttachement) - Method in class org.thales.punch.libraries.storm.spout.AbstractKafkaNode

Process a received record.

processAlreadyExisting - Variable in class org.thales.punch.libraries.storm.spout.AbstractFileInput

If true, the watcher will start by process any already existing file is the path.

producerProperties - Variable in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

The Kafka producer properties

publish(String, Object) - Method in interface org.thales.punch.libraries.storm.util.IWhiteBoard

publish(String, Object) - Method in class org.thales.punch.libraries.storm.util.WhiteBoard

The publish method is called by the producer when it receives data to call back the consumer.

publishersOfType(String) - Method in class org.thales.punch.libraries.storm.core.topology.TopologyGraphNode

publishStream(String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

PunchBoltDispatcherFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build a punch dispatcher bolt.

PunchBoltDispatcherFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.PunchBoltDispatcherFactory

Default constructor.

PunchBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Punch Node factory class.

PunchBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.PunchBoltFactory

Default constructor.

PunchDispatcherNode - Class in org.thales.punch.libraries.storm.bolt

The PunchDispatcherNode simply dispatches incoming tuples to different punchlet(s), based on one of the received fields.

PunchDispatcherNode(NodeSettings, Map<String, PunchNode>) - Constructor for class org.thales.punch.libraries.storm.bolt.PunchDispatcherNode

Ctor

PunchletConfig - Class in org.thales.punch.libraries.storm.util

PunchletConfig(String, Map<String, String>, Map<String, String>, Map<String, String>) - Constructor for class org.thales.punch.libraries.storm.util.PunchletConfig

PunchNode - Class in org.thales.punch.libraries.storm.bolt

The punch bolt executes punchlet(s) on the fly.

PunchNode(NodeSettings, PunchletConfig) - Constructor for class org.thales.punch.libraries.storm.bolt.PunchNode

Constructor.

put(String, T) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMap

put(Map<String, Object>) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.AvroParquetArchiveBuffer

put(Map<String, Object>) - Method in interface org.thales.punch.libraries.storm.bolt.file.buffer.IArchiveBuffer

Add a single item in the archive buffer.

put(Map<String, Object>) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

put(Map<String, Object>) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.StreamingGzipArchiveBuffer

putBytes(byte[]) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.GzipArchiveBuffer

putBytes(byte[]) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

Write bytes to correct buffer

Q

queryQueueTime - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

queueSize - Variable in class org.thales.punch.libraries.storm.spout.AbstractFileInput

The maximum amount of input lines we accept to accumulate in our server queues.

R

RawPacketBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build a Test Bolt.

RawPacketBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.RawPacketBoltFactory

Default constructor.

RawPacketNode - Class in org.thales.punch.libraries.storm.bolt

RawPacketNode(NodeSettings, ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.bolt.RawPacketNode

Create a new SplitBolt

readFile() - Method in class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

Use this method to read a file in a synchronous way.

readOneFile(File) - Method in class org.thales.punch.libraries.storm.spout.AbstractFileInput

Read a file using with a single or multi thread manner.

readValue(Header, HeaderDeclaration) - Static method in class org.thales.punch.libraries.storm.util.KafkaHeaderReader

Return a header value according to its configured declaration For accepted value type and encodings, check @HeaderDeclaration class

reconnectionTimeout - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

Record - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

A Record keeps track of the various counter associated to the keys identifying one aggregation.

Record(Tuple, List<Operation>, List<String>) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.Record

Create a new aggregation record.

RecordKey - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

RecordKey(long, long) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.RecordKey

registerBoltFactory(String, Class<? extends IBoltFactory>) - Method in class org.thales.punch.libraries.storm.core.topology.SimpleTopologyRegistry

Adds a bolt factory to the registry.

registerNextTupleCallback(INextTupleCallback) - Method in class org.thales.punch.libraries.storm.spout.HttpInput

registerNextTupleCallback(INextTupleCallback) - Method in class org.thales.punch.libraries.storm.spout.impl.HttpServer

Register the callback to receive the data.

registerNextTupleCallback(INextTupleCallback) - Method in class org.thales.punch.libraries.storm.spout.impl.LumberjackServer

registerNextTupleCallback(INextTupleCallback) - Method in class org.thales.punch.libraries.storm.spout.LumberjackInput

registerNextTupleCallback(INextTupleCallback) - Method in class org.thales.punch.libraries.storm.spout.SyslogInput

registerSpoutFactory(String, Class<? extends ISpoutFactory>) - Method in class org.thales.punch.libraries.storm.core.topology.SimpleTopologyRegistry

Adds a spout factory to the registry.

reindex(List<ElasticDocument>) - Method in class org.thales.punch.libraries.storm.bolt.ElasticsearchOutput

RelpInput - Class in org.thales.punch.libraries.storm.spout

The Relp listening spout.

RelpInput(NodeSettings, ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.spout.RelpInput

Create a new Relp spout

removeEldestEntry(Map.Entry<K, V>) - Method in class org.thales.punch.libraries.storm.spout.impl.LruCache

removeLogFileTailerListener(LogFileTailerListener) - Method in class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

remove a listener

Reporter - Class in org.thales.punch.libraries.storm.spout.es.wrapper.plugins

Reporter(ISettingsMap, ReporterGroup) - Constructor for class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.Reporter

ReporterBuilder - Class in org.thales.punch.libraries.storm.spout.es.wrapper.plugins

ReporterBuilder(ISettingsMap, ISettingsMap) - Constructor for class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.ReporterBuilder

reportError(Throwable) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

reportError(Throwable) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpoutOutputCollector

requestClose() - Method in class org.thales.punch.libraries.storm.bolt.impl.AsyncKafkaProducer

request the closing of this producer.

resetTimeout(Tuple) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltOutputCollector

resolve(String) - Method in class org.thales.punch.libraries.storm.bolt.factory.ResourcePathResolver

ResourcePathResolver - Class in org.thales.punch.libraries.storm.bolt.factory

IN a punch node resources are identified using various schemes:

ResourcePathResolver(String, String, Path) - Constructor for class org.thales.punch.libraries.storm.bolt.factory.ResourcePathResolver

RetentionBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

RetentionBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.RetentionBoltFactory

RetentionNode - Class in org.thales.punch.libraries.storm.bolt

Overview

RetentionNode(NodeSettings, ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.bolt.RetentionNode

Create a new retention bolt

run(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.CountFieldOperation

run(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.CountFieldValueOperation

run(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.CountOperation

run(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.Operation

run(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.SumOperation

run() - Method in class org.thales.punch.libraries.storm.bolt.impl.JdbcHandle

run() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltRunner

run() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopology

Running a light topology never returns.

run() - Method in class org.thales.punch.libraries.storm.impl.Watcher

run() - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.ElasticRequestRunnable

run() - Method in class org.thales.punch.libraries.storm.spout.impl.HttpServer

run() - Method in class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

run() - Method in class org.thales.punch.libraries.storm.spout.impl.LumberjackServer

run() - Method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

run() - Method in class org.thales.punch.libraries.storm.spout.impl.UdpSyslogServer

run() - Method in class org.thales.punch.libraries.storm.util.DirWatcher

Run the thread.

RythmerBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

RythmerBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.RythmerBoltFactory

RythmerNode - Class in org.thales.punch.libraries.storm.bolt

The rythmer bolt emits messages according to a provided timestamp.

RythmerNode(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.RythmerNode

S

S3ArchiveBuffer - Class in org.thales.punch.libraries.storm.bolt.file.buffer

The plain archiver simply creates a RAM byte array with the batch content.

S3ArchiveBuffer(int, int, List<ArchiveDevice>, IRecordEncoder<Map<String, Object>>, IRecordEncoder.RecordFormat) - Constructor for class org.thales.punch.libraries.storm.bolt.file.buffer.S3ArchiveBuffer

select(Fields) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

sendKafkaMessage(Tuple, AbstractKafkaOutput.Topic, byte[]) - Method in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

Call the Kafka producer to send the message

setAcker(LightAcker) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

Only a spout is interested to know when this tuple ack or fail.

setAnchoredTuple(Tuple) - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

In the exactly once mode, the first tuple of each batch is kept unacknowledged until the batch is flushed.

setBloomParameters(int, double) - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Use this to make your BatchArchiver instance compute bloom filters.

setBolt(String, IRichBolt, int) - Method in interface org.thales.punch.libraries.storm.core.topology.ITopologyBuilder

setBolt(String, IRichBolt, int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopologyBuilder

setBolt(String, IRichBolt, int) - Method in class org.thales.punch.libraries.storm.core.topology.StormTopologyBuilder

setBulkFailureHandler(FailureHandler) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticBulkRequest

setChannel(Object) - Method in interface org.thales.punch.libraries.storm.util.ISubscription

setClassName(String) - Method in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomBoltFactory

setClassName(String) - Method in class org.thales.punch.libraries.storm.spout.factory.WrapperCustomSpoutFactory

setConvertors(IInputTupleConverter<T>, IOutputTupleConverter<V>) - Method in class org.thales.punch.libraries.storm.bolt.ModuleNode

setError(String) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticDocument

setFailedDocumentReindexation(boolean) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticBulkRequest

setFailedDocumentReindexationForMappingExceptionsOnly(boolean) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticBulkRequest

setFailTupleWhenErrorNotIndexed(boolean) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticBulkRequest

setFailTupleWhenErrorNotIndexed(boolean) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticErrorBulkRequest

setSpout(String, ISpout, int) - Method in interface org.thales.punch.libraries.storm.core.topology.ITopologyBuilder

setSpout(String, ISpout, int) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTopologyBuilder

setSpout(String, ISpout, int) - Method in class org.thales.punch.libraries.storm.core.topology.StormTopologyBuilder

setTailling(boolean) - Method in class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

enable/disable file tailing

setTickFrequency(Integer) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltRunner

settings - Variable in class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput

these are the bolt settings as revamped by the factory

setUnavailabilityFailureHandler(FailureHandler) - Method in class org.thales.punch.libraries.storm.bolt.elasticsearch.ElasticBulkRequest

SFTP_SETTINGS - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

SFTPSpout - Class in org.thales.punch.libraries.storm.spout

SFTPSpout downloads files that matches a certain regex expression.

SFTPSpout(NodeSettings, ISettingsMap, boolean, String, String, String, ISettingsMap, String) - Constructor for class org.thales.punch.libraries.storm.spout.SFTPSpout

SFTPSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

SFTPSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

shuffleGrouping(String, String) - Method in interface org.thales.punch.libraries.storm.core.topology.IBoltDeclarer

shuffleGrouping(String, String) - Method in class org.thales.punch.libraries.storm.core.topology.light.LightBoltDeclarer

shuffleGrouping(String, String) - Method in class org.thales.punch.libraries.storm.core.topology.StormBoltDeclarer

SimpleTopologyRegistry - Class in org.thales.punch.libraries.storm.core.topology

A simple registry for various configuration artifacts.

SimpleTopologyRegistry() - Constructor for class org.thales.punch.libraries.storm.core.topology.SimpleTopologyRegistry

Default constructor.

size() - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

size() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

SmtpInput - Class in org.thales.punch.libraries.storm.spout

The SMTP listening spout.

SmtpInput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.spout.SmtpInput

SnmpInput - Class in org.thales.punch.libraries.storm.spout

The SNMP spout is able to receive SNMP Traps over UDP It decodes the SNMP Traps messages into a JSON format - cf.

SnmpInput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.spout.SnmpInput

SnmpSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Build a SnmpInput from NodeSettings.

SnmpSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.SnmpSpoutFactory

Default constructor.

SOURCE_TUPLE_FIELD_SETTING - Static variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

source_tuple_field: This optional setting provides the name of an input tuple field that is expected to contain a map-like object, providing all fields, instead of having many fields in the storm stream.

sourceTupleField - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

SplitBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build a Test Bolt.

SplitBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.SplitBoltFactory

SplitNode - Class in org.thales.punch.libraries.storm.bolt

A simple splitter bolt.

SplitNode(NodeSettings, ITopologySettings) - Constructor for class org.thales.punch.libraries.storm.bolt.SplitNode

Create a new SplitBolt

spoutFactories - Variable in class org.thales.punch.libraries.storm.core.topology.SimpleTopologyRegistry

The registered spout factories by type.

spoutFactoryFor(String) - Method in class org.thales.punch.libraries.storm.core.topology.SimpleTopologyRegistry

startAsync() - Method in class org.thales.punch.libraries.storm.bolt.impl.JdbcHandle

StormBoltDeclarer - Class in org.thales.punch.libraries.storm.core.topology

Default bolt declarer.

StormBoltDeclarer(BoltDeclarer) - Constructor for class org.thales.punch.libraries.storm.core.topology.StormBoltDeclarer

Ctor

StormTopologyBuilder - Class in org.thales.punch.libraries.storm.core.topology

StormTopologyBuilder() - Constructor for class org.thales.punch.libraries.storm.core.topology.StormTopologyBuilder

stream - Variable in class org.thales.punch.libraries.storm.bolt.elasticsearch.FailureHandler

streamDeclaration - Variable in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

StreamingGzipArchiveBuffer - Class in org.thales.punch.libraries.storm.bolt.file.buffer

A streaming gzip output file archiver.

StreamingGzipArchiveBuffer(int, int, List<ArchiveDevice>, IRecordEncoder<Map<String, Object>>, IRecordEncoder.RecordFormat, boolean) - Constructor for class org.thales.punch.libraries.storm.bolt.file.buffer.StreamingGzipArchiveBuffer

StreamSubscription - Class in org.thales.punch.libraries.storm.core.topology

StreamSubscription(String, String) - Constructor for class org.thales.punch.libraries.storm.core.topology.StreamSubscription

StringKafkaSpoutScheme - Class in org.thales.punch.libraries.storm.spout.impl

This is what is needed to get the message avalaible under the a given tuple field.

StringKafkaSpoutScheme(String) - Constructor for class org.thales.punch.libraries.storm.spout.impl.StringKafkaSpoutScheme

Associated a field to this scheme so that the spout will emit tuple with the value under that field name.

subscribe(String, ISubscription) - Method in interface org.thales.punch.libraries.storm.util.IWhiteBoard

subscribe(String, ISubscription) - Method in class org.thales.punch.libraries.storm.util.WhiteBoard

The subscribe method is called by the consumer when it receives data.

subscribersPerStreamId - Variable in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

Subscriptions - Class in org.thales.punch.libraries.storm.util

Subscriptions() - Constructor for class org.thales.punch.libraries.storm.util.Subscriptions

subscriptions - Variable in class org.thales.punch.libraries.storm.util.WhiteBoard

SumOperation - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

SumOperation(String, String) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.SumOperation

SyslogBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Setup a Syslog bolt.

SyslogBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.SyslogBoltFactory

SyslogInput<T> - Class in org.thales.punch.libraries.storm.spout

The Syslog input reads lines from tcp/udp and emits them as tuples.

SyslogInput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.spout.SyslogInput

A Spout constructor is in charge of setting the fields that will be required later on when the spout will be effectively started and run somewhere in the cluster.

SyslogInput(NodeSettings, Logger) - Constructor for class org.thales.punch.libraries.storm.spout.SyslogInput

Alternative constructor to use a Logger coming from the subclass

SyslogOutput - Class in org.thales.punch.libraries.storm.bolt

The Syslog bolt forwards messages to a next hop UDP server.

SyslogOutput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.SyslogOutput

Public constructor.

SyslogSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Build a SyslogInput from NodeSettings.

SyslogSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.SyslogSpoutFactory

Default constructor.

SyslogUdpBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Setup a Syslog UDP bolt.

SyslogUdpBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.SyslogUdpBoltFactory

SyslogUdpOutput - Class in org.thales.punch.libraries.storm.bolt

The Syslog udp bolt forwards messages to a next hop UDP server.

SyslogUdpOutput(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.SyslogUdpOutput

Public constructor.

T

table - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

TcpSyslogServer<T> - Class in org.thales.punch.libraries.storm.spout.impl

This syslog server puts all the received log lines in a queue, ready to be consumed by a storm spout.

TcpSyslogServer(ISettingsMap, IMetricContext, ISyslogReceiver<T>) - Constructor for class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

TestBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

Build a Test Bolt.

TestBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.TestBoltFactory

Default constructor.

TestNode - Class in org.thales.punch.libraries.storm.bolt

A simple test vbolt.

TestNode(NodeSettings) - Constructor for class org.thales.punch.libraries.storm.bolt.TestNode

Ctor

tick() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightSpout

tick() - Method in interface org.thales.punch.libraries.storm.spout.impl.ISyslogServer

tick() - Method in class org.thales.punch.libraries.storm.spout.impl.LogFileTailer

Flush buffer after timeout, tick is only implement for multiline codec

tick() - Method in class org.thales.punch.libraries.storm.spout.impl.TcpSyslogServer

Flush buffers after timeout, tick is only implemented for multiline codecs

Timestamp - Class in org.thales.punch.libraries.storm.bolt.aggregator.impl

Timestamp(Tuple, String) - Constructor for class org.thales.punch.libraries.storm.bolt.aggregator.impl.Timestamp

toInt(byte[], HeaderDeclaration) - Static method in class org.thales.punch.libraries.storm.util.KafkaHeaderReader

byte kafka header content to integer value according to byte ordering in header declaration

toLong(byte[], HeaderDeclaration) - Static method in class org.thales.punch.libraries.storm.util.KafkaHeaderReader

byte kafka header content to long value according to byte ordering in header declaration

toObjectList(List<String>, List<Operation>, String) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.Record

Topic(String) - Constructor for class org.thales.punch.libraries.storm.bolt.AbstractKafkaOutput.Topic

topologyContext - Variable in class org.thales.punch.libraries.storm.core.topology.light.LightComponent

TopologyFactory - Class in org.thales.punch.libraries.storm.core.topology

Build a Storm topology.

TopologyFactory(ITopologyRegistry, IPlatform, String) - Constructor for class org.thales.punch.libraries.storm.core.topology.TopologyFactory

Default constructor.

TopologyGraph - Class in org.thales.punch.libraries.storm.core.topology

TopologyGraph(List<NodeSettings>, List<NodeSettings>) - Constructor for class org.thales.punch.libraries.storm.core.topology.TopologyGraph

TopologyGraphNode - Class in org.thales.punch.libraries.storm.core.topology

This class makes it possible to build a graph from a topology configuration,

TopologyGraphNode(String, String, List<StreamDeclaration>) - Constructor for class org.thales.punch.libraries.storm.core.topology.TopologyGraphNode

toString() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMapKey

toString() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.Key

toString() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.RecordKey

toString() - Method in class org.thales.punch.libraries.storm.core.topology.light.LightTuple

toString() - Method in class org.thales.punch.libraries.storm.core.topology.TopologyGraph

toString() - Method in class org.thales.punch.libraries.storm.core.topology.TopologyGraphNode

toString() - Method in class org.thales.punch.libraries.storm.spout.impl.StringKafkaSpoutScheme

toString(byte[], HeaderDeclaration) - Static method in class org.thales.punch.libraries.storm.util.KafkaHeaderReader

byte kafka header content to string value according to value type in header declaration

transform(LinkedBlockingQueue<String>, String) - Method in class org.thales.punch.libraries.storm.spout.es.wrapper.plugins.JsonToNDJson

Receives ES query results, extract hits.hits for every result, format every tuple and return them as list.

tupleRtt - Variable in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

Time to process tuple metric

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.ArchiveReaderNodeFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.ClickHouseBoltFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.DistinctLogCounterBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.ElasticSearchOutputFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.FileOutputFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.FileTransferBoltFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.FilterBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.HttpBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.KafkaBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.LumberjackBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.OmniSciBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.PostgresqlBoltFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.PunchBoltDispatcherFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.PunchBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.RawPacketBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.RetentionBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.RythmerBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.SplitBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.SyslogBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.SyslogUdpBoltFactory

The key referencing the associated bolt.

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.TestBoltFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomBoltFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomOutput

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.AzureBlobStorageSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.ExtractionInputFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.FileSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.GeneratorSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.HttpSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.KafkaSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.LumberjackSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.NSGAzureBlobStorageSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.SFTPSpoutFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.SnmpSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.SyslogSpoutFactory

The key referencing the associated spout.

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.factory.WrapperCustomSpoutFactory

TYPE - Static variable in class org.thales.punch.libraries.storm.spout.WrapperCustomInput

U

UdpSyslogServer<T> - Class in org.thales.punch.libraries.storm.spout.impl

This syslog server puts all the received log lines in a queue, ready to be consumed by a storm spout.

UdpSyslogServer(ISettingsMap, IMetricContext, ISyslogReceiver<T>) - Constructor for class org.thales.punch.libraries.storm.spout.impl.UdpSyslogServer

uncompressResources(Map<String, Object>) - Static method in class org.thales.punch.libraries.storm.impl.CompressionHelper

Take a resource map, and if items are marked as compressed, uncompress them.

UNDERSCORE_ID - Static variable in class org.thales.punch.libraries.storm.spout.factory.ExtractionInputFactory

UNDERSCORE_SEARCH - Static variable in class org.thales.punch.libraries.storm.spout.ExtractionInput

unsubscribe(String) - Method in interface org.thales.punch.libraries.storm.util.IWhiteBoard

unsubscribe(String) - Method in class org.thales.punch.libraries.storm.util.WhiteBoard

The unsubscribe method is called by the producer when the subscription does not need to be maintained, its role is over.

update(File) - Method in class org.thales.punch.libraries.storm.util.FileRecord

Updates the current FileRecord to match the given file.

updateBloom(ITuple, Iterable<String>) - Method in class org.thales.punch.libraries.storm.bolt.file.BatchArchiver

Update the bloom filter with the new fields values

updateTimestamp(Long) - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMap

username - Variable in class org.thales.punch.libraries.storm.bolt.AbstractJDBCOutput

userStream - Variable in class org.thales.punch.libraries.storm.bolt.AbstractFileOutput

The user stream where to publish the batches metadata.

V

valueOf(String) - Static method in enum org.thales.punch.libraries.storm.bolt.elasticsearch.FailureHandler.FailureAction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.thales.punch.libraries.storm.bolt.file.EArchiverType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.thales.punch.libraries.storm.bolt.rawpacket.EthernetPacketDeserializers

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.thales.punch.libraries.storm.spout.es.wrapper.plugins.JsonToNDJson.Mode

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.thales.punch.libraries.storm.spout.impl.LumberjackInputRecordType

Returns the enum constant of this type with the specified name.

values() - Method in class org.thales.punch.libraries.storm.bolt.aggregator.impl.BatchMap

values() - Static method in enum org.thales.punch.libraries.storm.bolt.elasticsearch.FailureHandler.FailureAction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.thales.punch.libraries.storm.bolt.file.EArchiverType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.thales.punch.libraries.storm.bolt.rawpacket.EthernetPacketDeserializers

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.thales.punch.libraries.storm.spout.es.wrapper.plugins.JsonToNDJson.Mode

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.thales.punch.libraries.storm.spout.impl.LumberjackInputRecordType

Returns an array containing the constants of this enum type, in the order they are declared.

W

WatchDog - Class in org.thales.punch.libraries.storm.util

This class provides a simple and robust watchdog mechanism.

WatchDog() - Constructor for class org.thales.punch.libraries.storm.util.WatchDog

Watcher - Class in org.thales.punch.libraries.storm.impl

This watcher is designed to monitor creation events in a specific directory.

Watcher(String, boolean) - Constructor for class org.thales.punch.libraries.storm.impl.Watcher

Constructor

WhiteBoard - Class in org.thales.punch.libraries.storm.util

The WhiteBoard is in charge of maintain subscriptions used by consumer (HttpSpout) and producer (WhiteBoardBolt) to communicate.

withDefaultRoot(Path) - Method in class org.thales.punch.libraries.storm.bolt.factory.ResourcePathResolver

WrapperCustomBoltFactory - Class in org.thales.punch.libraries.storm.bolt.factory

WrapperCustomBoltFactory() - Constructor for class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomBoltFactory

WrapperCustomBoltFactory(String) - Constructor for class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomBoltFactory

WrapperCustomInput - Class in org.thales.punch.libraries.storm.spout

Wrapper input node to convert custom node with public API to legacy node with private API

WrapperCustomInput(NodeSettings, PunchInputNode) - Constructor for class org.thales.punch.libraries.storm.spout.WrapperCustomInput

WrapperCustomOutput - Class in org.thales.punch.libraries.storm.bolt.factory

Wrapper input node to convert custom node with public API to legacy node with private API

WrapperCustomOutput(NodeSettings, PunchProcessingNode) - Constructor for class org.thales.punch.libraries.storm.bolt.factory.WrapperCustomOutput

WrapperCustomSpoutFactory - Class in org.thales.punch.libraries.storm.spout.factory

Wrapper factory to convert custom node with public API to legacy node with private API

WrapperCustomSpoutFactory() - Constructor for class org.thales.punch.libraries.storm.spout.factory.WrapperCustomSpoutFactory

Used by DynamicTopologyRegistry

WrapperCustomSpoutFactory(String) - Constructor for class org.thales.punch.libraries.storm.spout.factory.WrapperCustomSpoutFactory

writeToDestination(ArchiveDevice, byte[]) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.CephGzipArchiveBuffer

writeToDestination(ArchiveDevice, byte[]) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.PlainArchiveBuffer

Write byte array to provided destination.

writeToDestination(ArchiveDevice, byte[]) - Method in class org.thales.punch.libraries.storm.bolt.file.buffer.S3ArchiveBuffer

A B C D E F G H I J K L M N O P Q R S T U V W