blob: eaef7033e1c0c7e698a736525ee1566c08ad6a4f [file] [log] [blame]
<!DOCTYPE html >
<html>
<head>
<title></title>
<meta name="description" content="" />
<meta name="keywords" content="" />
<meta http-equiv="content-type" content="text/html; charset=UTF-8" />
<link href="../lib/ref-index.css" media="screen" type="text/css" rel="stylesheet" />
<script type="text/javascript" src="../lib/jquery.js"></script>
</head>
<body><div class="entry">
<div class="name">ONEWORKER</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/scheduler/Relaxation$.html" class="extype" name="org.apache.gearpump.cluster.scheduler.Relaxation">Relaxation</a> </div>
</div><div class="entry">
<div class="name">ONE_ACKREQUEST_EVERY_MESSAGE_COUNT</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/Subscription$.html" class="extype" name="org.apache.gearpump.streaming.task.Subscription">Subscription</a> </div>
</div><div class="entry">
<div class="name">OPTION_CONFIG</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/main/Gear$.html" class="extype" name="org.apache.gearpump.cluster.main.Gear">Gear</a> </div>
</div><div class="entry">
<div class="name">Op</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan">plan</a> </div>
</div><div class="entry">
<div class="name">OpChainException</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan">plan</a> </div>
</div><div class="entry">
<div class="name">OpEdge</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/plan/package.html" class="extype" name="org.apache.gearpump.streaming.dsl.plan">plan</a> </div>
</div><div class="entry">
<div class="name">Options</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/metrics/TaskFilterAggregator$.html" class="extype" name="org.apache.gearpump.streaming.metrics.TaskFilterAggregator">TaskFilterAggregator</a> </div>
</div><div class="entry">
<div class="name">OutputFormatter</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/hadoop/lib/format/package.html" class="extype" name="org.apache.gearpump.streaming.hadoop.lib.format">format</a> </div>
</div><div class="entry">
<div class="name">of</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/Subscriber$.html" class="extype" name="org.apache.gearpump.streaming.task.Subscriber">Subscriber</a> </div>
</div><div class="entry">
<div class="name">ofEpochMilli</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/Window$.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.Window">Window</a> </div>
</div><div class="entry">
<div class="name">offset</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/kafka/lib/source/consumer/KafkaMessage.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib.source.consumer.KafkaMessage">KafkaMessage</a> </div>
</div><div class="entry">
<div class="name">oldProcessorId</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/appmaster/DagManager$$ReplaceProcessor.html" class="extype" name="org.apache.gearpump.streaming.appmaster.DagManager.ReplaceProcessor">ReplaceProcessor</a> </div>
</div><div class="entry">
<div class="name">onAppMasterActivated</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" class="extype" name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo">ApplicationRuntimeInfo</a> </div>
</div><div class="entry">
<div class="name">onAppMasterRegistered</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" class="extype" name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo">ApplicationRuntimeInfo</a> </div>
</div><div class="entry">
<div class="name">onFinalStatus</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" class="extype" name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo">ApplicationRuntimeInfo</a> </div>
</div><div class="entry">
<div class="name">onNext</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/CountTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.CountTriggerTask">CountTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.EventTimeTriggerTask">EventTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask">ProcessingTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$$Transform.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask.Transform">Transform</a> <a href="../org/apache/gearpump/streaming/javaapi/Task.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onRestartTasks</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/executor/Executor.html" class="extype" name="org.apache.gearpump.streaming.executor.Executor">Executor</a> </div>
</div><div class="entry">
<div class="name">onStart</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/ProcessingTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.ProcessingTimeTriggerTask">ProcessingTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$$Transform.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask.Transform">Transform</a> <a href="../org/apache/gearpump/streaming/javaapi/Task.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onStop</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$$Transform.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask.Transform">Transform</a> <a href="../org/apache/gearpump/streaming/javaapi/Task.html" class="extype" name="org.apache.gearpump.streaming.javaapi.Task">Task</a> <a href="../org/apache/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onTrigger</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/window/impl/ReduceFnRunner.html" class="extype" name="org.apache.gearpump.streaming.dsl.window.impl.ReduceFnRunner">ReduceFnRunner</a> </div>
</div><div class="entry">
<div class="name">onUnManagedMessage</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> </div>
</div><div class="entry">
<div class="name">onWatermarkProgress</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/dsl/task/EventTimeTriggerTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.EventTimeTriggerTask">EventTimeTriggerTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask">TransformTask</a> <a href="../org/apache/gearpump/streaming/dsl/task/TransformTask$$Transform.html" class="extype" name="org.apache.gearpump.streaming.dsl.task.TransformTask.Transform">Transform</a> <a href="../org/apache/gearpump/streaming/source/DataSourceTask.html" class="extype" name="org.apache.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../org/apache/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="org.apache.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../org/apache/gearpump/streaming/task/Task.html" class="extype" name="org.apache.gearpump.streaming.task.Task">Task</a> <a href="../org/apache/gearpump/streaming/task/TaskInterface.html" class="extype" name="org.apache.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">open</div>
<div class="occurrences"><a href="../org/apache/gearpump/external/hbase/HBaseSink.html" class="extype" name="org.apache.gearpump.external.hbase.HBaseSink">HBaseSink</a> <a href="../org/apache/gearpump/streaming/dsl/scalaapi/CollectionDataSource.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.CollectionDataSource">CollectionDataSource</a> <a href="../org/apache/gearpump/streaming/dsl/scalaapi/LoggerSink.html" class="extype" name="org.apache.gearpump.streaming.dsl.scalaapi.LoggerSink">LoggerSink</a> <a href="../org/apache/gearpump/streaming/hadoop/SequenceFileSink.html" class="extype" name="org.apache.gearpump.streaming.hadoop.SequenceFileSink">SequenceFileSink</a> <a href="../org/apache/gearpump/streaming/kafka/lib/sink/AbstractKafkaSink.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib.sink.AbstractKafkaSink">AbstractKafkaSink</a> <a href="../org/apache/gearpump/streaming/kafka/lib/source/AbstractKafkaSource.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib.source.AbstractKafkaSource">AbstractKafkaSource</a> <a href="../org/apache/gearpump/streaming/sink/DataSink.html" class="extype" name="org.apache.gearpump.streaming.sink.DataSink">DataSink</a> <a href="../org/apache/gearpump/streaming/source/DataSource.html" class="extype" name="org.apache.gearpump.streaming.source.DataSource">DataSource</a> </div>
</div><div class="entry">
<div class="name">optConsumer</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/kafka/lib/store/KafkaStore.html" class="extype" name="org.apache.gearpump.streaming.kafka.lib.store.KafkaStore">KafkaStore</a> </div>
</div><div class="entry">
<div class="name">options</div>
<div class="occurrences"><a href="../org/apache/gearpump/cluster/ClientToMaster$$QueryHistoryMetrics.html" class="extype" name="org.apache.gearpump.cluster.ClientToMaster.QueryHistoryMetrics">QueryHistoryMetrics</a> <a href="../org/apache/gearpump/cluster/main/AppSubmitter$.html" class="extype" name="org.apache.gearpump.cluster.main.AppSubmitter">AppSubmitter</a> <a href="../org/apache/gearpump/cluster/main/ArgumentsParser.html" class="extype" name="org.apache.gearpump.cluster.main.ArgumentsParser">ArgumentsParser</a> <a href="../org/apache/gearpump/cluster/main/ArgumentsParser$$Syntax.html" class="extype" name="org.apache.gearpump.cluster.main.ArgumentsParser.Syntax">Syntax</a> <a href="../org/apache/gearpump/cluster/main/Info$.html" class="extype" name="org.apache.gearpump.cluster.main.Info">Info</a> <a href="../org/apache/gearpump/cluster/main/Kill$.html" class="extype" name="org.apache.gearpump.cluster.main.Kill">Kill</a> <a href="../org/apache/gearpump/cluster/main/Local$.html" class="extype" name="org.apache.gearpump.cluster.main.Local">Local</a> <a href="../org/apache/gearpump/cluster/main/MainRunner$.html" class="extype" name="org.apache.gearpump.cluster.main.MainRunner">MainRunner</a> <a href="../org/apache/gearpump/cluster/main/Master$.html" class="extype" name="org.apache.gearpump.cluster.main.Master">Master</a> <a href="../org/apache/gearpump/cluster/main/Replay$.html" class="extype" name="org.apache.gearpump.cluster.main.Replay">Replay</a> </div>
</div><div class="entry">
<div class="name">org</div>
<div class="occurrences"><a href="../package.html" class="extype" name="_root_">root</a> </div>
</div><div class="entry">
<div class="name">originFileName</div>
<div class="occurrences"><a href="../org/apache/gearpump/jarstore/FileDirective$$FileInfo.html" class="extype" name="org.apache.gearpump.jarstore.FileDirective.FileInfo">FileInfo</a> </div>
</div><div class="entry">
<div class="name">out</div>
<div class="occurrences"><a href="../org/apache/gearpump/util/ProcessLogRedirector.html" class="extype" name="org.apache.gearpump.util.ProcessLogRedirector">ProcessLogRedirector</a> </div>
</div><div class="entry">
<div class="name">outDegreeOf</div>
<div class="occurrences"><a href="../org/apache/gearpump/util/Graph.html" class="extype" name="org.apache.gearpump.util.Graph">Graph</a> </div>
</div><div class="entry">
<div class="name">outgoingEdgesOf</div>
<div class="occurrences"><a href="../org/apache/gearpump/util/Graph.html" class="extype" name="org.apache.gearpump.util.Graph">Graph</a> </div>
</div><div class="entry">
<div class="name">output</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/TaskActor.html" class="extype" name="org.apache.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../org/apache/gearpump/streaming/task/TaskContext.html" class="extype" name="org.apache.gearpump.streaming.task.TaskContext">TaskContext</a> <a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> <a href="../org/apache/gearpump/util/ConsoleOutput.html" class="extype" name="org.apache.gearpump.util.ConsoleOutput">ConsoleOutput</a> <a href="../org/apache/gearpump/util/ProcessLogRedirector.html" class="extype" name="org.apache.gearpump.util.ProcessLogRedirector">ProcessLogRedirector</a> </div>
</div><div class="entry">
<div class="name">outputUnManaged</div>
<div class="occurrences"><a href="../org/apache/gearpump/streaming/task/TaskWrapper.html" class="extype" name="org.apache.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div></body>
</html>