This constructor should be called by the subclass' default constructor with the desired value @param commitOffsetPeriodMs commit offset period to be u

Creates a new KafkaSpoutConfig using a Builder. @param builder The Builder to construct the KafkaSpoutConfig from

The time stamp of the next retry is scheduled according to the exponential backoff formula (geometric progression): nextRetry = failCount == 1 ? curre

Builds a metadata object. @param firstOffset The first offset for the batch @param lastOffset The last offset for the batch

Creates a new coordinator based on the given spout config. @param kafkaSpoutConfig The spout config to use

Create a new Kafka spout emitter. @param kafkaSpoutConfig The kafka spout config @param topologyContext The topology context

Creates a new opaque transactional Trident Kafka spout.

Creates a new non-opaque transactional Trident Kafka spout.

Create a KerberosSaslNettyClient for authentication with servers.

Constructor. @param numBuckets the number of buckets to divide the time periods into.

Creates a {@link LeaderListenerCallback}. @param conf config @param zk zookeeper CuratorFramework client @param blobStore BlobStore @param leaderElec

Create a new load. @param hasMetrics have metrics been reported yet? @param boltLoad the load as reported by the bolt 0.0 no load 1.0 fully

Create a new LoadCompConf with the given values. @param id the id of the component. @param parallelism tha parallelism of the component. @param stream

Create a simple load spout with just a set rate per second on the default stream. @param ratePerSecond the rate to send messages at.

Create a default LocalCluster. @throws Exception on any error

Creates a LocalDRPC with a default metrics registry.

Constructor. @param keyname the key of the blob to download. @param uncompress should the blob be uncompressed or not. @param needsCallback if the blo

Create a new LocallyCachedBlob. @param blobDescription a description of the blob this represents. Typically it should at least be the blob key, but

Create a new LocallyCachedBlob. @param topologyId the ID of the topology. @param type the type of the blob. @param owner the name of the user that own

Constuctor. @param stormConf configuration map for Storm cluster @param workerLogs {@link WorkerLogs} instance @param directoryCleaner {