Index

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

A

acker tasks
acking tuples
  defined
  explicit
  implicit
aggregation, Trident
Amazon Web Services.
    See AWS.
Apache Hadoop
Apache Samza
Apache Spark
at-least-once processing, 2^nd
at-most-once processing
AWS (Amazon Web Services), 2^nd

B

BaseBasicBolt class, 2^nd
baseline, performance
BaseRichBolt class, 2^nd
BaseRichSpout class
BasicOutputCollector class
brokers, defined

C

chained streams
Cluster Summary section, Storm UI
CombinatorAggregator
commit feed listener spout
complex streams
Component Summary section, Storm UI
concurrency
ConcurrentModificationException
Config class, 2^nd
CountMetric
CPU contention

D

DAG (directed acyclic graph)
data loss
data points
data streams
  analyzing requirements of
  bottlenecks inherent within
declareOutputFields method
defaults.yaml file
dependencies
deserialization
directed acyclic graph.
    See DAG.
disk I/O contention
distributed commit log
DRPCExecutionException

E

edges, topology
email counter bolt
email extractor bolt
emit frequencies of tick tuples
emit method
Errors section, Storm UI
exactly once processing
execute method, 2^nd, 3^rd
executors
  for commit feed listener spout
  for email counter bolt
  for email extractor bolt
  incoming queue
  increasing parallelism
  outgoing transfer queue
  transferring tuples between, 2^nd
Executors section, Storm UI
explicit anchoring, acking, and failing
external services

F

FailedException, 2^nd
fail-fast design
fault tolerance
fields grouping, 2^nd
filters, Trident
functions, Trident

G

GC (garbage collection)
global grouping, 2^nd
Google Geocoder Java API
grouping, Trident

H

I

IBasicBolt interface
iftop command
implicit anchoring, acking, and failing
Input Stats section, Storm UI
internal queue overflow
internal Storm buffer overflow
  adjusting production-to-consumption ratio
  buffer sizes and performance
  increasing size of buffer for all topologies
  increasing size of buffer for given topology
  max spout pending
IRichBolt interface

J

java.library.path property
joins, Trident
JVM (Java Virtual Machine)

K

Kafka
  overview
  partitions in
  performance
  storage model
  Trident and
Kryo serialization

L

LMAX Disruptor
local cluster mode
local transfer
LocalCluster class
LocalTopologyRunner class

M

main thread
max spout pending, 2^nd
MemoryMapState.Factory
merges, Trident
metrics, performance
  CountMetric
  creating custom MultiSuccessRateMetric
  creating custom SuccessRateMetric
  setting up metrics consumer
micro-batch processing within stream
MultiSuccessRateMetric

N

netstat command
Netty
network I/O contention
nextTuple method
Nimbus
  fault tolerance for
  launching under supervision
Nimbus Configuration section, Storm UI
nimbus.host property, 2^nd
nodes

O

offsets, defined
OOM (out-of-memory) errors
optimization
OS (operating system), 2^nd
Output Stats section, Storm UI
OutputCollector class

P

parallelism hints
ParseException
partitions
  breaking into components at points of repartition
  in Kafka
  simplest functional components vs. lowest number of repartitions
  Trident
    for parallelism
    in streams
prepare method
principle of single responsibility
production-to-consumption ratio
projections

R

RabbitMQ, 2^nd, 3^rd
rebalance command
ReducerAggregator
remote Storm cluster
RemoteTopologyRunner class
repartitioning, 2^nd, 3^rd
retriable errors
routing

S

sar command, 2^nd, 3^rd
send thread
serialization, 2^nd
service-level agreement.
    See SLA.
shuffle grouping, 2^nd
single point of failure
single responsibility principle
SLA (service-level agreement), 2^nd
slots
socket I/O contention
Spark Streaming
splits, Trident
SpoutOutputCollector class
state updater operation
storm command
storm.local.dir property
storm.yaml
storm.zookeeper.port property
storm.zookeeper.servers property
StormTopology class
stream processing
submitTopology method
SuccessRateMetric
supervision, running process under, 2^nd
Supervisor Summary section, Storm UI
supervisor.slots.ports property, 2^nd

T

tasks, 2^nd
TCP_WAIT
thread safety
tick tuples
topics, defined
TOPOLOGY_MESSAGE_TIMEOUT_SECS setting
TopologyBuilder class
transfer functions
tuning.
    See performance.
tuple trees

U

ui.port property

V

variety
velocity
veracity
volume

W

worker.childopts property, 2^nd