Index

A

• activate command / Activate
• Adium
  • URL / The XMPP server
• Aggregator
  • about / Aggregator
• aggregators, Trident
  • about / Introducing Trident aggregators – Combiners and Reducers
  • CombinerAggregator / CombinerAggregator
  • ReducerAggregator / ReducerAggregator
  • Aggregator / Aggregator
• all grouping / Understanding stream groupings
• Amazon
  • URL, for account signing up / Setting up an AWS account
• Amazon EC2
  • about / Introducing Amazon Elastic Compute Cloud (EC2)
• Amazon Web Services (AWS) / Executing the batch analysis
• AMI
  • about / Launching an EC2 instance manually
• anatomy, Storm cluster / Introducing the anatomy of a Storm cluster
• Apache jclouds
  • URL / Introducing Apache Whirr
• Apache Kafka
  • about / Apache Kafka
  • URL / Apache Kafka
• Apache Whirr
  • about / Introducing Apache Whirr
  • URL / Introducing Apache Whirr
  • installing / Installing Whirr
  • Storm cluster, configuring with / Configuring a Storm cluster with Whirr
• append() method / Sending log messages to Kafka
• application architecture
  • components / Architecture
• ApplicationMaster / Examining YARN
• application monitoring
  • about / Use case
• architecture, Twitter client application
  • Twitter client / The Twitter client
  • Kafka spout / Kafka spout
  • titan-distributed graph database / A titan-distributed graph database
• architecture implementation
  • about / Implementing the architecture
  • data model / The data model
  • recursive topology, examining / Examining the recursive topology
  • queue interaction / The queue interaction
  • functions / Functions and filters
  • filters / Functions and filters
• Artificial Intelligence (AI) system
  • use case, designing / Designing for our use case
• AWS account
  • setting up / Setting up an AWS account
• AWS Management Console
  • about / The AWS Management Console
  • SSH key pair, creating / Creating an SSH key pair

B

• base operating system
  • installing / Installing the base operating system
• BaseRichSpout class / Implementing the sentence spout
• batch analysis
  • performing, with Pig infrastructure / Performing a batch analysis with the Pig infrastructure
• BatchCoordinator class / Introducing Trident spouts
• BatchCoordinator function / Introducing Trident spouts
• batches
  • about / Introducing Trident spouts
• batch processing mechanism
  • about / Batch processing / historical analysis
• Blueprints API
  • about / Accessing the graph – the TinkerPop stack
  • used, for manipulating graph / Manipulating the graph with the Blueprints API
• BoardSpout function / Implementing the recursion
• bolts
  • about / Bolts
  • functionalities / Bolts
• Broker node / Integrating a non-transactional system
• buildTopology() method / The final topology

C

• CAP theorem
  • about / A titan-distributed graph database, Motivating a Lambda architecture
  • consistency / A titan-distributed graph database
  • availability / A titan-distributed graph database
  • partition tolerance / A titan-distributed graph database
• Cassandra
  • installing / Installing Cassandra
  • about / Implementing the architecture
• Cassandra backend
  • Titan, starting with / Starting Titan with the Cassandra backend
• Cassandra storage backend
  • Titan, setting up for / Setting up Titan to use the Cassandra storage backend
• classes, Puppet / Puppet classes and modules
• classpath command / Classpath
• clojars.org
  • URL / Kafka spout
• Clojure / Java and Clojure
• cluster configuration
  • automating / Automating the cluster configuration
• cluster configuration, Whirr Storm / Cluster configuration
• CombinerAggregator
  • about / CombinerAggregator
• complex event processing (CEP) / Streams
• components, application architecture
  • source application / The source application
  • Logback Kafka appender / The logback Kafka appender
  • Apache Kafka / Apache Kafka
  • Kafka spout / Kafka spout
  • XMPP server / The XMPP server
• components, TinkerPop stack
  • blueprints / Accessing the graph – the TinkerPop stack
  • pipes / Accessing the graph – the TinkerPop stack
  • Gremlin / Accessing the graph – the TinkerPop stack
  • frames / Accessing the graph – the TinkerPop stack
  • Furnace project / Accessing the graph – the TinkerPop stack
  • Rextser / Accessing the graph – the TinkerPop stack
• components, topology in Storm cluster
  • nodes (machines) / Introducing parallelism in Storm
  • workers (JVMs) / Introducing parallelism in Storm
  • executors (threads) / Introducing parallelism in Storm
  • tasks (bolt/spout instances) / Introducing parallelism in Storm
• components, Trident state implementation
  • StateFactory interface / Implementing GraphState
  • State interface / Implementing GraphState
  • StateUpdater interface / Implementing GraphState
• Compute node / Integrating a non-transactional system, The Druid setup
• Compute nodes / Integrating a non-transactional system
• configuration, HDFS
  • NameNode, starting / Configuring the NameNode
  • DataNode, configuring / Configuring the DataNode
• configuration, OAuth
  • about / The OAuth configuration
  • TwitterStreamConsumer class / The TwitterStreamConsumer class
  • TwitterStatusListener class / The TwitterStatusListener class
• configuration, YARN
  • about / Configuring YARN
  • ResourceManager, configuring / Configuring the ResourceManager
• containers / Examining YARN
• create, read, update and delete (CRUD) / Examining HDFS
• Curator
  • about / Implementing the partition status in ZooKeeper
  • URL, for info / Implementing the partition status in ZooKeeper

D

• daemon commands, Storm
  • storm nimbus / Nimbus
  • storm supervisor / Supervisor
  • storm ui / UI
  • storm drpc / DRPC
• DataNode
  • configuring / Configuring the DataNode
• deactivate command / Deactivate
• debug commands, Storm
  • repl / REPL
  • classpath / Classpath
  • localconfvalue / Localconfvalue
• declareOutputFields() method / Implementing the sentence spout, Implementing the split sentence bolt
• Deep Storage mechanism / Integrating a non-transactional system
• DiagnosisEventSpout function / Introducing Trident topologies, Introducing Trident spouts
• directed acyclic graphs (DAG) / Accessing the graph – the TinkerPop stack
• direct grouping / Understanding stream groupings
• distributed locking mechanism / Distributed locking
• domain specific language (DSL) / Accessing the graph – the TinkerPop stack
• DRPC
  • about / Examining the design challenges, Distributed Remote Procedure Call (DRPC)
  • remote-deployment / Remote deployment
• DRPC server
  • working with / Working with Storm's DRPC server
• DRPC topology
  • about / Distributed Remote Procedure Call (DRPC)
  • code / Distributed Remote Procedure Call (DRPC)
• Druid / Integrating a non-transactional system
  • URL, for info / Integrating a non-transactional system
  • Storm, integrating with / Integrating a non-transactional system
  • setting up / The Druid setup
• Druid MapReduce job
  • internals, examining / HadoopDruidIndexer
• DruidState / DruidState

E

• EC2 instance
  • launching, manually / Launching an EC2 instance manually
  • logging in to / Logging in to the EC2 instance
• elements, Storm topology
  • streams / Streams
  • spouts / Spouts
  • bolts / Bolts
• emitBatch() method / Introducing Trident spouts
• emitDirect() method / Understanding stream groupings
• Emitter function / Introducing Trident spouts
• environments
  • managing, with Puppet Hiera / Managing environments with Puppet Hiera
• events
  • about / Streams
• exponentially weighted moving average / Calculating a moving average

F

• fields grouping / Understanding stream groupings
• filter / The filter
• filters, Trident
  • about / Introducing Trident filters
• Firehose / The state design
• firewall rules, Whirr Storm
  • customizing / Customizing firewall rules
• FIX format / Use case
• FIX messages / Use case
• FIX Spout / The topology
• forceStartOffsetTime() method / The final topology
• frames / Accessing the graph – the TinkerPop stack
• function fields
  • about / Introducing Trident operations – filters and functions
• functions, Trident
  • about / Introducing Trident functions
• Furnace / Accessing the graph – the TinkerPop stack

G

• game tree
  • enumerating / Enumerating the game tree
• GenerateBoards function / Immutable tuple field values
• getAverage() method / Adding a sliding window
• getAverageIn()method / Adding a sliding window
• getAverageRatePer() method / Adding a sliding window
• global grouping / Understanding stream groupings
• Global Positioning System (GPS)
  • about / Examining our use case
• graph
  • about / A brief introduction to graph databases
  • accessing / Accessing the graph – the TinkerPop stack
  • manipulating, with Blueprints API / Manipulating the graph with the Blueprints API
  • manipulating, with Gremlin shell / Manipulating the graph with the Gremlin shell
  • querying, with Gremlin / Querying the graph with Gremlin
• graph databases
  • about / A brief introduction to graph databases
• graph data model
  • about / Graph data model
• GraphFactory
  • implementing / Implementing GraphFactory
• GraphFactory interface
  • about / GraphFactory
• GraphOfTheGodsFactory class / Titan installation
• GraphState
  • implementing / Implementing GraphState
  • GraphFactory interface / GraphFactory
  • GraphTupleProcessor interface / GraphTupleProcessor
  • Factory interface / GraphStateFactory
• GraphState class / GraphState
• GraphStateFactory interface / GraphStateFactory
• GraphTupleProcessor
  • implementing / Implementing GraphTupleProcessor
• GraphTupleProcessor interface
  • about / GraphTupleProcessor
• GraphUpdater class / GraphUpdater
• Gremlin / Accessing the graph – the TinkerPop stack
  • used, for querying graph / Querying the graph with Gremlin
• Gremlin Reference
  • URL / Querying the graph with Gremlin
• Gremlin shell
  • used, for manipulating graph / Manipulating the graph with the Gremlin shell
• Gremlin Wiki
  • URL / Querying the graph with Gremlin
• groupBy() method / Aggregator
• guaranteed processing
  • about / Guaranteed processing
  • reliability, in spouts / Reliability in spouts
  • reliability, in bolts / Reliability in bolts
  • reliability, in word count / Reliable word count

H

• Hadoop
  • about / Introducing elements of a Storm topology – streams, spouts, and bolts, Hadoop
  • MapReduce overview / An overview of MapReduce
  • Druid, setting up / The Druid setup
• Hadoop Distributed Filesystem (HDFS)
  • about / Batch processing / historical analysis
• HadoopDruidIndexer function
  • about / HadoopDruidIndexer
• Hadoop infrastructure
  • configuring / The Hadoop infrastructure
• HDFS
  • about / Establishing the architecture
  • examining / Examining HDFS
  • configuring / Configuring HDFS
• Hiera
  • about / Introducing Hiera
• Historical nodes / The Druid setup

I

• ICD-9-CM
  • URL, for codes / Examining our use case
  • codes / Introducing Trident spouts
• immutable tuple field values / Immutable tuple field values
• install-storm.sh script / Storm
• installation, Apache Whirr / Installing Whirr
• installation, base operating system / Installing the base operating system
• installation, Cassandra / Installing Cassandra
• installation, Java / Installing Java
• installation, Kafka / Installing Kafka
• installation, OpenFire / Installing OpenFire
• installation, Storm
  • on Linux / Installing Storm on Linux
  / Storm installation
• installation, Titan / Titan installation
• installation, Vagrant / Installing Vagrant
• installation, ZooKeeper / ZooKeeper installation
• instance type
  • about / Launching an EC2 instance manually
• instant message (IM)
  • about / Kafka spout
• intrusion detection
  • about / Use case

J

• jar command / Jar
• Java / Java and Clojure
  • installing / Installing Java
• JSON project function
  • about / The JSON project function
• JSONProjectFunction class / The JSONProjectFunction class

K

• Kafka
  • installing / Installing Kafka
  • URL, for downloading / Installing Kafka
  • log messages, sending to / Sending log messages to Kafka
• Kafka spout
  • about / Kafka spout, Kafka spout, Kafka spout
• kill command / Kill
• Kryo
  • URL / Titan installation

L

• Lambda architecture
  • motivating / Motivating a Lambda architecture
  • realizing / Realizing a Lambda architecture
• Limbo / The state design
• Linux
  • Storm, installing on / Installing Storm on Linux
• local/shuffle grouping / Understanding stream groupings
• localconfvalue command / Localconfvalue
• log analysis topology
  • about / Introducing the log analysis topology
  • Kafka spout / Kafka spout
  • JSON project function / The JSON project function
  • moving average, calculating / Calculating a moving average
  • sliding window, adding / Adding a sliding window
  • moving average function, implementing / Implementing the moving average function
  • filtering, on thresholds / Filtering on thresholds
  • notifications, sending with XMPP protocol / Sending notifications with XMPP
  • completing / The final topology
  • running / Running the log analysis topology
• Logback Appender extension
  • about / Kafka spout
• logback framework
  • about / Use case
• logback Kafka appender
  • about / The logback Kafka appender
• log messages
  • sending, to Kafka / Sending log messages to Kafka

M

• management commands, Storm
  • jar / Jar
  • kill / Kill
  • deactivate / Deactivate
  • activate / Activate
  • rebalance / Rebalance
  • remoteconfvalue / Remoteconfvalue
• mandatory settings, Storm cluster
  • storm.zookeeper.servers / Mandatory settings
  • nimbus.host / Mandatory settings
  • supervisor.slots.ports / Mandatory settings
  • storm.local.dir / Mandatory settings
• manifests, Puppet / Puppet manifests
• map function / An overview of MapReduce
• MapReduce
  • about / An overview of MapReduce
• mark() method / Adding a sliding window
• Master node / Integrating a non-transactional system, The Druid setup
• Metcalfe's law
  • URL / Use case
• Minimax algorithm
  • about / Designing for our use case
  • goal / Designing for our use case
• modules, Puppet / Puppet classes and modules
• move() method / Designing for our use case
• moving average
  • calculating / Calculating a moving average
• moving average function
  • implementing / Implementing the moving average function
• multimachine clusters
  • configuring, with Vagrant / Configuring multimachine clusters with Vagrant
• MySQL / Integrating a non-transactional system

N

• n-grams
  • URL, for info / TweetSplitterFunction
• NameNode
  • configuring / Configuring the NameNode
• Natural Language Processing (NLP) / Examining our use case
  • analytics, examining / Examining the analytics
• Negamax algorithm
  • about / Designing for our use case
• nextTuple() method / Implementing the sentence spout
• nimbus.childopts setting / Optional settings
• nimbus.host setting / Mandatory settings
• nimbus daemon / Introducing the anatomy of a Storm cluster
  • overview / Understanding the nimbus daemon
• nimbus node / Customizing firewall rules
• NodeManager
  • configuring / Configuring the NodeManager
• NodeManagers / Examining YARN
• non-transactional spouts / Introducing Trident spouts
• non-Transactional state / Integrating a non-transactional system
• non-transactional system
  • integrating / Integrating a non-transactional system
• none grouping / Understanding stream groupings
• notifications
  • sending, with XMPP / Sending notifications with XMPP

O

• OAuth
  • configuring / The OAuth configuration
• online advertising
  • about / Use case
• opaque spouts / Introducing Trident spouts
• Opaque state / The Opaque state
• Opaque Transactional state / Integrating a non-transactional system
• OpenFire
  • about / Installing OpenFire
  • installing / Installing OpenFire
• OpenFire XMPP server
  • URL / The XMPP server
• operations, Trident
  • about / Introducing Trident operations – filters and functions
  • filters / Introducing Trident filters
  • functions / Introducing Trident functions
• optional settings, Storm cluster / Optional settings
• OutbreakDetectionTopology class
  • about / Executing the topology
• OutbreakTrendState object / The Opaque state

P

• parallelism
  • in Storm / Introducing parallelism in Storm
• Parallels Desktop
  • URL, for downloading / Installing Storm on Linux
• partitionPersist() method / Introducing the Trident state
• partition status
  • implementing, in ZooKeeper / Implementing the partition status in ZooKeeper
• PersistenceFunction / PersistenceFunction
• Pidgin
  • URL / The XMPP server
• Pig
  • about / Examining the use case
• Pig infrastructure
  • batch analysis, performing with / Performing a batch analysis with the Pig infrastructure
• Pipes / Accessing the graph – the TinkerPop stack
• Puppet
  • about / A rapid introduction to Puppet
  • URL / A rapid introduction to Puppet
  • manifests / Puppet manifests
  • classes / Puppet classes and modules
  • modules / Puppet classes and modules
  • templates / Puppet templates
• Puppet Hiera
  • used, for managing environments / Managing environments with Puppet Hiera
• Python / Python

Q

• queue interaction / The queue interaction

R

• read-before-write, Scoring Topology
  • distributed locking / Distributed locking
  • retry when stale approach / Retry when stale
• read-before-write paradigm / Read-before-write
  • addressing / Addressing read-before-write
• real-time aggregate analytics
  • examining / Examining the analytics
• real-time analysis
  • performing, with Storm-YARN infrastructure / Performing a real-time analysis with the Storm-YARN infrastructure
• Real-time nodes / Integrating a non-transactional system
• real-time trend analysis
  • use case / Use case
• rebalance command / Rebalance
• recursion implementation
  • return values, accessing for function / Accessing the function's return values
  • immutable tuple field values / Immutable tuple field values
  • upfront field declaration / Upfront field declaration
  • tuple acknowledgement, in recursion / Tuple acknowledgement in recursion
  • output to multiple streams / Output to multiple streams
  • read-before-write paradigm / Read-before-write
• Recursion Topology
  • about / Solving the challenges
• recursive topology
  • implementing / Examining the recursive topology
• reduce function / An overview of MapReduce
• ReducerAggregator
  • about / ReducerAggregator
• reliability, in bolts / Reliability in bolts
• reliability, in spouts / Reliability in spouts
• reliability, in word count / Reliable word count
• remote-deployment, DRPC / Remote deployment
• remoteconfvalue command / Remoteconfvalue
• Repeat Transactional state / The Repeat Transactional state, Integrating a non-transactional system
• repl command / REPL
• report bolt
  • about / Introducing the report bolt
  • implementing / Implementing the report bolt
• REpresentational State Transfer (REST) / Use case
• ResourceManager / Examining YARN
  • configuring / Configuring the ResourceManager
• retry when stale approach / Retry when stale
• Rextser / Accessing the graph – the TinkerPop stack

S

• sample application
  • about / Introducing the sample application
  • log messages, sending to Kafka / Sending log messages to Kafka
• sbt (Scala Build Tool)
  • about / Installing Kafka
  • URL / Installing Kafka
• Scoring Function
  • about / Solving the challenges
• Scoring Queue
  • about / Solving the challenges
• Scoring Topology
  • about / Solving the challenges
  • examining / Examining the Scoring Topology
  • read-before-write, addressing / Addressing read-before-write
  • executing / Executing the topology
  • game tree, enumerating / Enumerating the game tree
• sentence spout
  • implementing / Implementing the sentence spout
• SentenceSpout class
  • about / Sentence spout
  • split sentence bolt / Introducing the split sentence bolt
  • word count bolt / Introducing the word count bolt
  • report bolt / Introducing the report bolt
• setNumWorkers() method / Adding workers to a topology
• shuffle grouping / Understanding stream groupings
• SLF4J
  • URL / Introducing the sample application
• sliding window
  • about / Adding a sliding window
• social media use case
  • about / Use case
• software installation, Twitter client application
  • Titan / Titan installation
• split sentence bolt
  • about / Introducing the split sentence bolt
  • implementing / Implementing the split sentence bolt
• spout / The spout
• spouts
  • about / Spouts
  • potential data sources / Spouts
• spouts, Trident
  • about / Introducing Trident spouts
  • non-transactional / Introducing Trident spouts
  • transactional / Introducing Trident spouts
  • opaque / Introducing Trident spouts
  • interface / Introducing Trident spouts
  • BatchCoordinator class / Introducing Trident spouts
  • Emitter function / Introducing Trident spouts
• SQL2Gremlin
  • URL / Querying the graph with Gremlin
• SSH key pair
  • creating / Creating an SSH key pair
• Start of Header (SOH) / Use case
• state, Trident
  • about / Introducing the Trident state
  • Repeat Transactional state / The Repeat Transactional state
  • Opaque state / The Opaque state
• StateFactory interface / Implementing GraphState
• State interface / Implementing GraphState
• stateQuery() method / Introducing the Trident state
• states, Zookeeper
  • inProgress / The state design
  • Limbo / The state design
  • Completed / The state design
• StateUpdater interface / Implementing GraphState
• Storm
  • stream groupings / Understanding stream groupings
  • technology stack / Introducing the Storm technology stack
  • installing, on Linux / Installing Storm on Linux
  • installing / Storm installation
  • configuring / Configuring Storm
  • daemon commands / The daemon commands
  • management commands / The management commands
  • local debug/development commands / Local debug/development commands
  • integrating, with Druid / Integrating a non-transactional system
  • about / Storm
• Storm, and Druid integration
  • architecture, implementing / Implementing the architecture
  • implementation, examining / Executing the implementation
• Storm, on Hadoop for advertising analysis
  • use case, examining / Examining the use case
  • architecture, establishing / Establishing the architecture
  • infrastructure, configuring / Configuring the infrastructure, Configuring HDFS, Configuring the NameNode, Configuring the DataNode, Configuring YARN, Configuring the ResourceManager, Configuring the NodeManager
  • deploying / Deploying the analytics, Deploying the topology
  • performing / Performing the analytics
  • batch analysis, executing / Executing the batch analysis
  • real-time analysis, executing / Executing real-time analysis
  • executing / Executing the topology
• Storm-YARN infrastructure
  • real-time analysis, performing with / Performing a real-time analysis with the Storm-YARN infrastructure
• Storm-YARN project
  • URL / Examining YARN
• storm.local.dir setting / Mandatory settings
• storm.zookeeper.servers setting / Mandatory settings
• Storm architecture
  • establishing / Establishing the architecture
  • design challenges, examining / Examining the design challenges
  • recursion, implementing / Implementing the recursion
  • challenges, solving / Solving the challenges
• Storm cluster
  • anatomy / Introducing the anatomy of a Storm cluster
  • mandatory settings / Mandatory settings
  • optional settings / Optional settings
  • topologies, submitting to / Submitting topologies to a Storm cluster
  • configuring, with Apache Whirr / Configuring a Storm cluster with Whirr
  • launching / Launching the cluster, Launching the Storm cluster
• Storm daemons
  • running / Running the Storm daemons
• storm drpc command / DRPC
• Storm executable
  • about / The Storm executable
  • setting up, on workstation / Setting up the Storm executable on a workstation
• StormFirehose object
  • implementing / Implementing the StormFirehose object
• storm nimbus command / Nimbus
• Storm provisioning scripts
  • creating / Creating Storm-provisioning scripts
  • ZooKeeper / ZooKeeper
  • Storm / Storm
  • supervisord service / Supervisord
• storm supervisor command / Supervisor
• Storm UI
  • about / Introducing the Storm UI
• storm ui command / UI
• Storm Vagrantfile / The Storm Vagrantfile
• stream groupings, Storm
  • about / Understanding stream groupings
  • shuffle grouping / Understanding stream groupings
  • fields grouping / Understanding stream groupings
  • all grouping / Understanding stream groupings
  • global grouping / Understanding stream groupings
  • none grouping / Understanding stream groupings
  • direct grouping / Understanding stream groupings
  • local/shuffle grouping / Understanding stream groupings
• Streaming Quotient Filter (SQF) / Executing real-time analysis
• submitTopology() method / Adding workers to a topology
• supervisor.childopts setting / Optional settings
• supervisor.slots.ports setting / Mandatory settings
• supervisor daemon / Introducing the anatomy of a Storm cluster
  • working with / Working with the supervisor daemon
• supervisord service
  • about / Supervisord
  • Storm Vagrantfile / The Storm Vagrantfile
• supervisor node / Customizing firewall rules
• supply chain management
  • about / Use case

T

• technology stack, Storm
  • about / Introducing the Storm technology stack
  • Java / Java and Clojure
  • Clojure / Java and Clojure
  • Python / Python
• templates, Puppet / Puppet templates
• tic-tac-toe game
  • about / Designing for our use case
  • sample tree / Designing for our use case
• TinkerPop
  • about / Accessing the graph – the TinkerPop stack
• TinkerPop stack
  • components / Accessing the graph – the TinkerPop stack
• Titan
  • about / A titan-distributed graph database
  • installing / Titan installation
  • setting up, for Cassandra storage backend / Setting up Titan to use the Cassandra storage backend
  • starting, with Cassandra backend / Starting Titan with the Cassandra backend
• titan-distributed graph database / A titan-distributed graph database
• topologies
  • submitting, to Storm cluster / Submitting topologies to a Storm cluster
• topologies, Trident
  • about / Introducing Trident topologies
  • code / Introducing Trident topologies
  • executing / Executing the topology
• topology
  • about / Introducing elements of a Storm topology – streams, spouts, and bolts
• topology, financial analytics
  • about / The topology
  • code / The topology
  • spout / The spout
  • filter / The filter
  • state design / The state design
• topology.enable.message.timeouts setting / Optional settings
• topology.max.spout.pending setting / Optional settings
• topology.message.timeout.secs setting / Optional settings
• transactional spouts / Introducing Trident spouts
• Trident aggregators
  • about / Introducing Trident aggregators – Combiners and Reducers
  • CombinerAggregator / CombinerAggregator
  • ReducerAggregator / ReducerAggregator
  • Aggregator / Aggregator
• Trident filters
  • about / Introducing Trident filters
• Trident functions
  • about / Introducing Trident functions
• Trident operations
  • about / Introducing Trident operations – filters and functions
  • filters / Introducing Trident filters
  • functions / Introducing Trident functions
• TridentSpout function / Introducing Trident spouts
• Trident spouts
  • about / Introducing Trident spouts
  • non-transactional / Introducing Trident spouts
  • transactional / Introducing Trident spouts
  • opaque / Introducing Trident spouts
  • interface / Introducing Trident spouts
  • BatchCoordinator class / Introducing Trident spouts
  • Emitter function / Introducing Trident spouts
• Trident state
  • about / Introducing the Trident state
• Trident topologies
  • about / Introducing Trident topologies
  • code / Introducing Trident topologies
  • executing / Executing the topology
• tuple
  • about / Streams
• TweetEmitter / TwitterSpout/TweetEmitter
• TweetSplitterFunction / TweetSplitterFunction
• Twitter4J Client
  • setting up / Setting up the Twitter4J client
• Twitter4J java library
  • URL / The Twitter client
• Twitter client / The Twitter client
• Twitter client application
  • architecture / Architecture
  • software installation / Software installation
• Twitter graph topology
  • about / Twitter graph topology
  • JSONProjectFunction class / The JSONProjectFunction class
• TwitterGraphTopology class / Putting it all together – the TwitterGraphTopology class, The TwitterGraphTopology class
• TwitterSpout / TwitterSpout/TweetEmitter
• TwitterStatusListener class / The TwitterStatusListener class
• Twitter stream
  • connecting to / Connecting to the Twitter stream
• TwitterStreamConsumer class / The TwitterStreamConsumer class

U

• ui.childopts setting / Optional settings
• ui.port setting / Optional settings
• upfront field declaration / Upfront field declaration
• use case
  • designing, for artificial intelligence / Designing for our use case
  • examining / Examining our use case
  • designing / Designing the topology for our use case
• use case, real-time trend analysis / Use case
• use case, Trident topologies
  • examining / Examining our use case
• use case design
  • implementing / Implementing the design

V

• Vagrant
  • about / Introducing Vagrant
  • URL / Introducing Vagrant
  • installing / Installing Vagrant
  • virtual machine, launching / Launching your first virtual machine
  • shared filesystem / The Vagrantfile and shared filesystem
  • multimachine clusters, configuring with / Configuring multimachine clusters with Vagrant
• vagrant-hostmanager plugin / The Storm Vagrantfile
• Vagrantfile / The Vagrantfile and shared filesystem
• vagrant init command / The Vagrantfile and shared filesystem
• Vagrant provisioning / Vagrant provisioning
• VirtualBox
  • URL, for downloading / Installing Storm on Linux
  • URL / Introducing Vagrant
• virtual machine, Vagrant
  • launching / Launching your first virtual machine
• VMWare
  • URL, for downloading / Installing Storm on Linux
  • URL / Introducing Vagrant

W

• whirr.cluster-name property / Configuring a Storm cluster with Whirr
• whirr.image-id property / Configuring a Storm cluster with Whirr
• whirr.instance-template property / Configuring a Storm cluster with Whirr
• whirr destroy-cluster command / Launching the cluster
• Whirr Storm
  • about / Introducing Whirr Storm
  • URL / Introducing Whirr Storm
  • setting up / Setting up Whirr Storm
  • cluster configuration / Cluster configuration
  • configuration, customizing / Customizing Storm's configuration
  • firewall rules, customizing / Customizing firewall rules
• word count bolt
  • about / Introducing the word count bolt
  • implementing / Implementing the word count bolt
• word count topology
  • implementing / Implementing the word count topology, Implementing the word count topology
  • development environment, setting up / Setting up a development environment
  • sentence spout, implementing / Implementing the sentence spout
  • split sentence bolt, implementing / Implementing the split sentence bolt
  • word count bolt, implementing / Implementing the word count bolt
  • report bolt, implementing / Implementing the report bolt
• word count topology data flow
  • about / Introducing the word count topology data flow
  • Sentence spout / Sentence spout
• WordCountTopology parallelism
  • about / WordCountTopology parallelism
  • workers, adding to topology / Adding workers to a topology
  • executors, configuring / Configuring executors and tasks
  • tasks, configuring / Configuring executors and tasks
• WordFrequencyFunction / WordFrequencyFunction
• worker.childopts setting / Optional settings
• Work Queue
  • about / Solving the challenges
• Work Spout
  • about / Solving the challenges
• workstation
  • Storm executable, setting up on / Setting up the Storm executable on a workstation

X

• XMPP
  • URL / The XMPP server
  • about / The XMPP server
  • used, for sending notifications / Sending notifications with XMPP
• XMPP protocol
  • about / Sending notifications with XMPP

Y

• YARN
  • about / Establishing the architecture
  • examining / Examining YARN
  • configuring / Configuring YARN

Z

• Zookeeper / Integrating a non-transactional system
• ZooKeeper / Distributed locking
  • about / Introducing Apache ZooKeeper, ZooKeeper
  • installing / ZooKeeper installation
  • partition status, implementing / Implementing the partition status in ZooKeeper