Searches a given byte array for a match of a sub-array of bytes. Returns the offset to the byte that matches, or -1 if no match was found.

called when the file is uploaded. @param srcFile - jar file to be uploaded @param targetFile - destination file @param totalBytes - total number o

Called when the tuple is emitted and auto commit is disabled. If kafka auto commit is enabled, the kafka consumer will periodically (depending on the

Called when the maximum number of retries have been reached. @param msgId The id of the tuple in the spout.

Called when kafka partitions are rebalanced. @param partitions The list of partitions that are now assigned to the consumer (may include partitions p

called whenever a chunk of bytes is uploaded. @param srcFile - jar file to be uploaded @param targetFile - destination file @param bytesUplo

Called when the Kafka spout sets a record for retry. @param msgId The id of the tuple in the spout.

called before file is uploaded. @param srcFile - jar file to be uploaded @param targetFile - destination file @param totalBytes - total number of

Process a single tick tuple of input. Tick tuple doesn't need to be acked. It provides default "DO NOTHING" implementation for convenient. Override th

Handle expired tuple events which can be removing from cache or store.

Returns map of stream id to component id to grouper.

Override the SlowExecutorPattern for given components. @param topoSpecific what we are going to use to override. @return a copy of this with the neede

Override the SlowExecutorPattern with a new one. @param slp the new pattern or null if you don't want it to change @return a copy of this with the adj

Parse the execution result.

Parses remote repository parameter and build {@link RemoteRepository} object. @param repository string representation of remote repository parameter