Package | Description |
---|---|
org.thales.punch.libraries.storm.bolt.factory | |
org.thales.punch.libraries.storm.bolt.impl |
Modifier and Type | Method and Description |
---|---|
AbstractFileOutput |
FileOutputFactory.createBolt(org.thales.punch.platform.api.IPlatform platform,
org.thales.punch.libraries.storm.api.NodeSettings boltConfig,
org.thales.punch.libraries.storm.api.ITopologySettings topoConfig) |
Modifier and Type | Class and Description |
---|---|
class |
AtLeastOnceFileOutput
The "At least once" version of the FileBolt.
In case of a topology failure/restart, duplicated Tuples will be found. |
class |
OneByOneFileOutput
The "Exactly once" version of the FileBolt.
A special variation of the FileBolt that creates a dedicated file batch object for each Tuple. |
Copyright © 2022. All rights reserved.