public class

FilterTask

extends Task
java.lang.Object
   ↳ org.apache.helix.taskexecution.Task
     ↳ org.apache.helix.taskexecution.FilterTask

Summary

Constants
String CLICKS
String FILTERED_CLICKS
String FILTERED_IMPRESSIONS
String IMPRESSIONS
[Expand]
Inherited Fields
From class org.apache.helix.taskexecution.Task
Public Constructors
FilterTask(String id, Set<String> parentIds, HelixManager helixManager, TaskResultStore resultStore, String dataSource)
Protected Methods
void executeImpl(String resourceName, int numPartitions, int partitionNum)
[Expand]
Inherited Methods
From class org.apache.helix.taskexecution.Task
From class java.lang.Object
From interface org.apache.helix.ExternalViewChangeListener

Constants

public static final String CLICKS

Constant Value: "clicks_demo"

public static final String FILTERED_CLICKS

Constant Value: "filtered_clicks_demo"

public static final String FILTERED_IMPRESSIONS

Constant Value: "filtered_impressions_demo"

public static final String IMPRESSIONS

Constant Value: "impressions_demo"

Public Constructors

public FilterTask (String id, Set<String> parentIds, HelixManager helixManager, TaskResultStore resultStore, String dataSource)

Protected Methods

protected void executeImpl (String resourceName, int numPartitions, int partitionNum)

Throws
Exception