blob: 52d14fb86f87a1184fa7144129ec719d5be4c7b9 [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="../io/gearpump/cluster/scheduler/Relaxation$.html" class="extype" name="io.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="../io/gearpump/streaming/task/Subscription$.html" class="extype" name="io.gearpump.streaming.task.Subscription">Subscription</a> </div>
</div><div class="entry">
<div class="name">OffsetManager</div>
<div class="occurrences"><a href="../io/gearpump/streaming/transaction/api/package.html" class="extype" name="io.gearpump.streaming.transaction.api">api</a> </div>
</div><div class="entry">
<div class="name">OffsetStorage</div>
<div class="occurrences"><a href="../io/gearpump/streaming/transaction/api/package.html" class="extype" name="io.gearpump.streaming.transaction.api">api</a> </div>
</div><div class="entry">
<div class="name">OffsetStorageFactory</div>
<div class="occurrences"><a href="../io/gearpump/streaming/transaction/api/package.html" class="extype" name="io.gearpump.streaming.transaction.api">api</a> </div>
</div><div class="entry">
<div class="name">OffsetTimeStampResolver</div>
<div class="occurrences"><a href="../io/gearpump/streaming/transaction/api/package.html" class="extype" name="io.gearpump.streaming.transaction.api">api</a> </div>
</div><div class="entry">
<div class="name">Op</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/op/package.html" class="extype" name="io.gearpump.streaming.dsl.op">op</a> </div>
</div><div class="entry">
<div class="name">OpChain</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/op/package.html" class="extype" name="io.gearpump.streaming.dsl.op">op</a> </div>
</div><div class="entry">
<div class="name">OpEdge</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/op/package.html" class="extype" name="io.gearpump.streaming.dsl.op">op</a> </div>
</div><div class="entry">
<div class="name">OpTranslator</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/plan/package.html" class="extype" name="io.gearpump.streaming.dsl.plan">plan</a> </div>
</div><div class="entry">
<div class="name">Overflow</div>
<div class="occurrences"><a href="../io/gearpump/streaming/transaction/api/OffsetStorage$.html" class="extype" name="io.gearpump.streaming.transaction.api.OffsetStorage">OffsetStorage</a> </div>
</div><div class="entry">
<div class="name">of</div>
<div class="occurrences"><a href="../io/gearpump/streaming/task/Subscriber$.html" class="extype" name="io.gearpump.streaming.task.Subscriber">Subscriber</a> </div>
</div><div class="entry">
<div class="name">offset</div>
<div class="occurrences"><a href="../io/gearpump/streaming/kafka/lib/consumer/KafkaMessage.html" class="extype" name="io.gearpump.streaming.kafka.lib.consumer.KafkaMessage">KafkaMessage</a> </div>
</div><div class="entry">
<div class="name">oldProcessorId</div>
<div class="occurrences"><a href="../io/gearpump/streaming/appmaster/DagManager$$ReplaceProcessor.html" class="extype" name="io.gearpump.streaming.appmaster.DagManager.ReplaceProcessor">ReplaceProcessor</a> </div>
</div><div class="entry">
<div class="name">onNext</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$GroupByTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.GroupByTask">GroupByTask</a> <a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$SinkTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.SinkTask">SinkTask</a> <a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$SourceTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.SourceTask">SourceTask</a> <a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$TransformTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.TransformTask">TransformTask</a> <a href="../io/gearpump/streaming/javaapi/Task.html" class="extype" name="io.gearpump.streaming.javaapi.Task">Task</a> <a href="../io/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="io.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../io/gearpump/streaming/source/DataSourceTask.html" class="extype" name="io.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../io/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="io.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../io/gearpump/streaming/task/Task.html" class="extype" name="io.gearpump.streaming.task.Task">Task</a> <a href="../io/gearpump/streaming/task/TaskActor.html" class="extype" name="io.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../io/gearpump/streaming/task/TaskInterface.html" class="extype" name="io.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../io/gearpump/streaming/task/TaskWrapper.html" class="extype" name="io.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onStart</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$GroupByTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.GroupByTask">GroupByTask</a> <a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$SinkTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.SinkTask">SinkTask</a> <a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$SourceTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.SourceTask">SourceTask</a> <a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$TransformTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.TransformTask">TransformTask</a> <a href="../io/gearpump/streaming/javaapi/Task.html" class="extype" name="io.gearpump.streaming.javaapi.Task">Task</a> <a href="../io/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="io.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../io/gearpump/streaming/source/DataSourceTask.html" class="extype" name="io.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../io/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="io.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../io/gearpump/streaming/task/Task.html" class="extype" name="io.gearpump.streaming.task.Task">Task</a> <a href="../io/gearpump/streaming/task/TaskActor.html" class="extype" name="io.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../io/gearpump/streaming/task/TaskInterface.html" class="extype" name="io.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../io/gearpump/streaming/task/TaskWrapper.html" class="extype" name="io.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onStop</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$SinkTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.SinkTask">SinkTask</a> <a href="../io/gearpump/streaming/dsl/plan/OpTranslator$$SourceTask.html" class="extype" name="io.gearpump.streaming.dsl.plan.OpTranslator.SourceTask">SourceTask</a> <a href="../io/gearpump/streaming/javaapi/Task.html" class="extype" name="io.gearpump.streaming.javaapi.Task">Task</a> <a href="../io/gearpump/streaming/sink/DataSinkTask.html" class="extype" name="io.gearpump.streaming.sink.DataSinkTask">DataSinkTask</a> <a href="../io/gearpump/streaming/source/DataSourceTask.html" class="extype" name="io.gearpump.streaming.source.DataSourceTask">DataSourceTask</a> <a href="../io/gearpump/streaming/state/api/PersistentTask.html" class="extype" name="io.gearpump.streaming.state.api.PersistentTask">PersistentTask</a> <a href="../io/gearpump/streaming/task/Task.html" class="extype" name="io.gearpump.streaming.task.Task">Task</a> <a href="../io/gearpump/streaming/task/TaskActor.html" class="extype" name="io.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../io/gearpump/streaming/task/TaskInterface.html" class="extype" name="io.gearpump.streaming.task.TaskInterface">TaskInterface</a> <a href="../io/gearpump/streaming/task/TaskWrapper.html" class="extype" name="io.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">onUnManagedMessage</div>
<div class="occurrences"><a href="../io/gearpump/streaming/task/TaskActor.html" class="extype" name="io.gearpump.streaming.task.TaskActor">TaskActor</a> </div>
</div><div class="entry">
<div class="name">op</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/package.html" class="extype" name="io.gearpump.streaming.dsl">dsl</a> </div>
</div><div class="entry">
<div class="name">open</div>
<div class="occurrences"><a href="../io/gearpump/external/hbase/HBaseSink.html" class="extype" name="io.gearpump.external.hbase.HBaseSink">HBaseSink</a> <a href="../io/gearpump/streaming/dsl/CollectionDataSource.html" class="extype" name="io.gearpump.streaming.dsl.CollectionDataSource">CollectionDataSource</a> <a href="../io/gearpump/streaming/kafka/KafkaSink.html" class="extype" name="io.gearpump.streaming.kafka.KafkaSink">KafkaSink</a> <a href="../io/gearpump/streaming/kafka/KafkaSource.html" class="extype" name="io.gearpump.streaming.kafka.KafkaSource">KafkaSource</a> <a href="../io/gearpump/streaming/sink/DataSink.html" class="extype" name="io.gearpump.streaming.sink.DataSink">DataSink</a> <a href="../io/gearpump/streaming/source/DataSource.html" class="extype" name="io.gearpump.streaming.source.DataSource">DataSource</a> </div>
</div><div class="entry">
<div class="name">ops</div>
<div class="occurrences"><a href="../io/gearpump/streaming/dsl/op/OpChain.html" class="extype" name="io.gearpump.streaming.dsl.op.OpChain">OpChain</a> </div>
</div><div class="entry">
<div class="name">options</div>
<div class="occurrences"><a href="../io/gearpump/cluster/main/AppSubmitter$.html" class="extype" name="io.gearpump.cluster.main.AppSubmitter">AppSubmitter</a> <a href="../io/gearpump/cluster/main/ArgumentsParser.html" class="extype" name="io.gearpump.cluster.main.ArgumentsParser">ArgumentsParser</a> <a href="../io/gearpump/cluster/main/ArgumentsParser$$Syntax.html" class="extype" name="io.gearpump.cluster.main.ArgumentsParser.Syntax">Syntax</a> <a href="../io/gearpump/cluster/main/Info$.html" class="extype" name="io.gearpump.cluster.main.Info">Info</a> <a href="../io/gearpump/cluster/main/Kill$.html" class="extype" name="io.gearpump.cluster.main.Kill">Kill</a> <a href="../io/gearpump/cluster/main/Local$.html" class="extype" name="io.gearpump.cluster.main.Local">Local</a> <a href="../io/gearpump/cluster/main/Master$.html" class="extype" name="io.gearpump.cluster.main.Master">Master</a> <a href="../io/gearpump/cluster/main/Replay$.html" class="extype" name="io.gearpump.cluster.main.Replay">Replay</a> <a href="../io/gearpump/streaming/dsl/example/WordCount$.html" class="extype" name="io.gearpump.streaming.dsl.example.WordCount">WordCount</a> </div>
</div><div class="entry">
<div class="name">originFileName</div>
<div class="occurrences"><a href="../io/gearpump/util/FileDirective$$FileInfo.html" class="extype" name="io.gearpump.util.FileDirective.FileInfo">FileInfo</a> </div>
</div><div class="entry">
<div class="name">out</div>
<div class="occurrences"><a href="../io/gearpump/util/ProcessLogRedirector.html" class="extype" name="io.gearpump.util.ProcessLogRedirector">ProcessLogRedirector</a> </div>
</div><div class="entry">
<div class="name">outDegreeOf</div>
<div class="occurrences"><a href="../io/gearpump/util/Graph.html" class="extype" name="io.gearpump.util.Graph">Graph</a> </div>
</div><div class="entry">
<div class="name">outgoingEdgesOf</div>
<div class="occurrences"><a href="../io/gearpump/util/Graph.html" class="extype" name="io.gearpump.util.Graph">Graph</a> </div>
</div><div class="entry">
<div class="name">output</div>
<div class="occurrences"><a href="../io/gearpump/streaming/task/TaskActor.html" class="extype" name="io.gearpump.streaming.task.TaskActor">TaskActor</a> <a href="../io/gearpump/streaming/task/TaskContext.html" class="extype" name="io.gearpump.streaming.task.TaskContext">TaskContext</a> <a href="../io/gearpump/streaming/task/TaskWrapper.html" class="extype" name="io.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div><div class="entry">
<div class="name">outputUnManaged</div>
<div class="occurrences"><a href="../io/gearpump/streaming/task/TaskWrapper.html" class="extype" name="io.gearpump.streaming.task.TaskWrapper">TaskWrapper</a> </div>
</div></body>
</html>