Apache Helix
Package Index
|
Class Index
org.apache.helix
org.apache.helix.agent
org.apache.helix.alerts
org.apache.helix.api
org.apache.helix.api.accessor
org.apache.helix.api.config
org.apache.helix.api.id
org.apache.helix.controller
org.apache.helix.controller.context
org.apache.helix.controller.pipeline
org.apache.helix.controller.rebalancer
org.apache.helix.controller.rebalancer.config
org.apache.helix.controller.rebalancer.util
org.apache.helix.controller.restlet
org.apache.helix.controller.serializer
org.apache.helix.controller.stages
org.apache.helix.controller.strategy
org.apache.helix.examples
org.apache.helix.filestore
org.apache.helix.healthcheck
org.apache.helix.lock
org.apache.helix.lock.zk
org.apache.helix.lockmanager
org.apache.helix.manager.zk
org.apache.helix.manager.zk.serializer
org.apache.helix.messaging
org.apache.helix.messaging.handling
org.apache.helix.model
org.apache.helix.model.builder
org.apache.helix.model.util
org.apache.helix.monitoring
org.apache.helix.monitoring.mbeans
org.apache.helix.participant
org.apache.helix.participant.statemachine
org.apache.helix.recipes.rabbitmq
org.apache.helix.servicediscovery
org.apache.helix.spectator
org.apache.helix.store
org.apache.helix.store.zk
org.apache.helix.taskexecution
org.apache.helix.tools
org.apache.helix.userdefinedrebalancer
org.apache.helix.util
org.apache.helix.webapp
org.apache.helix.webapp.resources
Interfaces
TaskFactory
TaskResultStore
Classes
AnalyticsTaskFactory
CountTask
Dag
Dag.Node
FilterTask
JoinTask
RedisTaskResultStore
ReportTask
Task
TaskCluster
TaskExecutionDemo
TaskStateModel
TaskStateModelFactory
Worker
Package Index
|
Class Index
Summary:
Inherited Fields
|
Ctors
|
Protected Methods
|
Inherited Methods
|
[Expand All]
public class
CountTask
extends
Task
java.lang.Object
↳
org.apache.helix.taskexecution.Task
↳
org.apache.helix.taskexecution.CountTask
Summary
[Expand]
Inherited Fields
From class
org.apache.helix.taskexecution.Task
protected final
String
id
protected final
Set
<
String
>
parentIds
protected final
TaskResultStore
resultStore
Public Constructors
CountTask
(
String
id,
Set
<
String
> parentIds,
HelixManager
helixManager,
TaskResultStore
resultStore,
String
eventSource,
String
groupByCol)
Protected Methods
void
executeImpl
(
String
resourceName, int numPartitions, int partitionNum)
[Expand]
Inherited Methods
From class
org.apache.helix.taskexecution.Task
final void
execute
(
String
resourceName, int numPartitions, int partitionNum)
abstract void
executeImpl
(
String
resourceName, int numPartitions, int partitionNum)
void
onExternalViewChange
(
List
<
ExternalView
> externalViewList,
NotificationContext
changeContext)
Invoked when external view changes
From class
java.lang.Object
Object
clone
()
boolean
equals
(
Object
arg0)
void
finalize
()
final
Class
<?>
getClass
()
int
hashCode
()
final void
notify
()
final void
notifyAll
()
String
toString
()
final void
wait
()
final void
wait
(long arg0, int arg1)
final void
wait
(long arg0)
From interface
org.apache.helix.ExternalViewChangeListener
abstract void
onExternalViewChange
(
List
<
ExternalView
> externalViewList,
NotificationContext
changeContext)
Invoked when external view changes
Public Constructors
public
CountTask
(
String
id,
Set
<
String
> parentIds,
HelixManager
helixManager,
TaskResultStore
resultStore,
String
eventSource,
String
groupByCol)
Protected Methods
protected void
executeImpl
(
String
resourceName, int numPartitions, int partitionNum)
Throws
Exception