http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/package-list ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/package-list b/content/releases/latest/api/java/package-list index 08d18dc..110c4a4 100644 --- a/content/releases/latest/api/java/package-list +++ b/content/releases/latest/api/java/package-list @@ -16,11 +16,14 @@ org.apache.gearpump.security org.apache.gearpump.serializer org.apache.gearpump.streaming org.apache.gearpump.streaming.appmaster -org.apache.gearpump.streaming.dsl +org.apache.gearpump.streaming.dsl.api.functions org.apache.gearpump.streaming.dsl.javaapi +org.apache.gearpump.streaming.dsl.javaapi.functions org.apache.gearpump.streaming.dsl.partitioner org.apache.gearpump.streaming.dsl.plan org.apache.gearpump.streaming.dsl.plan.functions +org.apache.gearpump.streaming.dsl.scalaapi +org.apache.gearpump.streaming.dsl.scalaapi.functions org.apache.gearpump.streaming.dsl.task org.apache.gearpump.streaming.dsl.window.api org.apache.gearpump.streaming.dsl.window.impl @@ -30,7 +33,6 @@ org.apache.gearpump.streaming.hadoop.lib org.apache.gearpump.streaming.hadoop.lib.format org.apache.gearpump.streaming.hadoop.lib.rotation org.apache.gearpump.streaming.javaapi -org.apache.gearpump.streaming.javaapi.dsl.functions org.apache.gearpump.streaming.kafka org.apache.gearpump.streaming.kafka.dsl org.apache.gearpump.streaming.kafka.lib
http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/serialized-form.html ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/serialized-form.html b/content/releases/latest/api/java/serialized-form.html index 5f9cbd0..60fed1f 100644 --- a/content/releases/latest/api/java/serialized-form.html +++ b/content/releases/latest/api/java/serialized-form.html @@ -2,9 +2,9 @@ <!-- NewPage --> <html lang="en"> <head> -<!-- Generated by javadoc (1.8.0_25) on Mon Nov 28 22:41:21 PST 2016 --> +<!-- Generated by javadoc (1.8.0_121) on Tue Apr 25 03:06:41 SST 2017 --> <title>Serialized Form</title> -<meta name="date" content="2016-11-28"> +<meta name="date" content="2017-04-25"> <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> <script type="text/javascript" src="script.js"></script> </head> @@ -95,15 +95,6 @@ </li> </ul> </li> -<li class="blockList"> -<h3>Serialized Fields</h3> -<ul class="blockList"> -<li class="blockListLast"> -<h4>noTimeStamp</h4> -<pre>long noTimeStamp</pre> -</li> -</ul> -</li> </ul> </li> </ul> @@ -153,6 +144,62 @@ </li> </ul> </li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.ACTIVE:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.ACTIVE$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.ACTIVE$</a> extends <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.FAILED:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.FAILED$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.FAILED$</a> extends <a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster">ApplicationTerminalStatus</a> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.NONEXIST:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.NONEXIST$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.NONEXIST$</a> extends <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.PENDING:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.PENDING$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.PENDING$</a> extends <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.SUCCEEDED:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.SUCCEEDED$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.SUCCEEDED$</a> extends <a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster">ApplicationTerminalStatus</a> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus.TERMINATED:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ApplicationStatus.TERMINATED$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationStatus.TERMINATED$</a> extends <a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster">ApplicationTerminalStatus</a> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationStatus:D"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.cluster.ApplicationStatus$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ApplicationTerminalStatus"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ApplicationTerminalStatus.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ApplicationTerminalStatus</a> extends <a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a> implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterContext"> <!-- --> </a> @@ -161,7 +208,7 @@ <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterContext:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.cluster.AppMasterContext$ extends scala.runtime.AbstractFunction7<java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/scheduler/Resource.html" title="class in org.apache.gearpump.cluster.scheduler">Resource</a>,<a href="org/apache/gearpump/cluster/appmaster/WorkerInfo.html" title="class in org.apache.gearpump.cluster.appmaster">WorkerInfo</a>,scala.Option<<a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a>>,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/AppMasterRegisterData.html" title="interface in org.apache.gearpump.cluster">AppMasterRegisterData</a>,<a href="org/apache/gearpump/cluster/AppMasterContext.html" title="class in org.apache.gearpump.cluster">AppMasterContext</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.cluster.AppMasterContext$ extends scala.runtime.AbstractFunction6<java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/scheduler/Resource.html" title="class in org.apache.gearpump.cluster.scheduler">Resource</a>,<a href="org/apache/gearpump/cluster/appmaster/WorkerInfo.html" title="class in org.apache.gearpump.cluster.appmaster">WorkerInfo</a>,scala.Option<<a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a>>,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/AppMasterContext.html" title="class in org.apache.gearpump.cluster">AppMasterContext</a>> implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -174,20 +221,20 @@ </li> </ul> </li> -<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.ActivateAppMaster"> +<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.AppDataSaved:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.ActivateAppMaster</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.AppDataSaved$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.AppDataSaved$</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.ActivateAppMaster:D"> +<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.ActivateAppMaster$</a> extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/cluster/AppMasterToMaster.ActivateAppMaster.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.ActivateAppMaster</a>> implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.AppDataSaved:D"> +<li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.AppDataSaved$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.AppDataSaved$</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.ApplicationStatusChanged$</a> extends scala.runtime.AbstractFunction4<java.lang.Object,<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,java.lang.Object,java.lang.Throwable,<a href="org/apache/gearpump/cluster/AppMasterToMaster.ApplicationStatusChanged.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.ApplicationStatusChanged</a>> implements Serializable</h3> </li> <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary"> <!-- --> @@ -197,7 +244,7 @@ <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary$</a> extends scala.runtime.AbstractFunction8<java.lang.Object,java.lang.String,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.GeneralAppMasterSummary</a>> implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.GeneralAppMasterSummary$</a> extends scala.runtime.AbstractFunction8<java.lang.Object,java.lang.String,java.lang.String,java.lang.String,<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,java.lang.Object,java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/AppMasterToMaster.GeneralAppMasterSummary.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.GeneralAppMasterSummary</a>> implements Serializable</h3> </li> <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.GetAllWorkers:D"> <!-- --> @@ -267,7 +314,7 @@ <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.RegisterAppMaster:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.RegisterAppMaster$</a> extends scala.runtime.AbstractFunction2<akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/AppMasterRegisterData.html" title="interface in org.apache.gearpump.cluster">AppMasterRegisterData</a>,<a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.RegisterAppMaster</a>> implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.AppMasterToMaster.RegisterAppMaster$</a> extends scala.runtime.AbstractFunction3<java.lang.Object,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/WorkerInfo.html" title="class in org.apache.gearpump.cluster.appmaster">WorkerInfo</a>,<a href="org/apache/gearpump/cluster/AppMasterToMaster.RegisterAppMaster.html" title="class in org.apache.gearpump.cluster">AppMasterToMaster.RegisterAppMaster</a>> implements Serializable</h3> </li> <li class="blockList"><a name="org.apache.gearpump.cluster.AppMasterToMaster.RequestResource"> <!-- --> @@ -429,6 +476,16 @@ </a> <h3>Class <a href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.QueryWorkerConfig$</a> extends scala.runtime.AbstractFunction1<<a href="org/apache/gearpump/cluster/worker/WorkerId.html" title="class in org.apache.gearpump.cluster.worker">WorkerId</a>,<a href="org/apache/gearpump/cluster/ClientToMaster.QueryWorkerConfig.html" title="class in org.apache.gearpump.cluster">ClientToMaster.QueryWorkerConfig</a>> implements Serializable</h3> </li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ClientToMaster.RegisterAppResultListener"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.RegisterAppResultListener</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.ClientToMaster.RegisterAppResultListener:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.ClientToMaster.RegisterAppResultListener$</a> extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/cluster/ClientToMaster.RegisterAppResultListener.html" title="class in org.apache.gearpump.cluster">ClientToMaster.RegisterAppResultListener</a>> implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.gearpump.cluster.ClientToMaster.RemoveMaster"> <!-- --> </a> @@ -585,7 +642,7 @@ <li class="blockList"><a name="org.apache.gearpump.cluster.MasterToAppMaster.AppMasterData:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterData$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToAppMaster.AppMasterData$</a> extends scala.runtime.AbstractFunction9<java.lang.String,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterData.html" title="class in org.apache.gearpump.cluster">MasterToAppMaster.AppMasterData</a>> implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterData$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToAppMaster.AppMasterData$</a> extends scala.runtime.AbstractFunction9<<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,java.lang.String,<a href="org/apache/gearpump/cluster/MasterToAppMaster.AppMasterData.html" title="class in org.apache.gearpump.cluster">MasterToAppMaster.AppMasterData</a>> implements Serializable</h3> </li> <li class="blockList"><a name="org.apache.gearpump.cluster.MasterToAppMaster.AppMasterDataDetailRequest"> <!-- --> @@ -677,6 +734,26 @@ </a> <h3>Class <a href="org/apache/gearpump/cluster/MasterToAppMaster.WorkerList$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToAppMaster.WorkerList$</a> extends scala.runtime.AbstractFunction1<scala.collection.immutable.List<<a href="org/apache/gearpump/cluster/worker/WorkerId.html" title="class in org.apache.gearpump.cluster.worker">WorkerId</a>>,<a href="org/apache/gearpump/cluster/MasterToAppMaster.WorkerList.html" title="class in org.apache.gearpump.cluster">MasterToAppMaster.WorkerList</a>> implements Serializable</h3> </li> +<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.ApplicationFailed"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.ApplicationFailed</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.ApplicationFailed:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.ApplicationFailed$</a> extends scala.runtime.AbstractFunction2<java.lang.Object,java.lang.Throwable,<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationFailed.html" title="class in org.apache.gearpump.cluster">MasterToClient.ApplicationFailed</a>> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.ApplicationSucceeded"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.ApplicationSucceeded</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.ApplicationSucceeded:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded$.html" title="class in org.apache.gearpump.cluster">org.apache.gearpump.cluster.MasterToClient.ApplicationSucceeded$</a> extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/cluster/MasterToClient.ApplicationSucceeded.html" title="class in org.apache.gearpump.cluster">MasterToClient.ApplicationSucceeded</a>> implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.gearpump.cluster.MasterToClient.AppMasterConfig"> <!-- --> </a> @@ -903,15 +980,15 @@ <li class="blockList"> <h2 title="Package">Package org.apache.gearpump.cluster.appmaster</h2> <ul class="blockList"> -<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationState"> +<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationMetaData"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ApplicationState</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ApplicationMetaData</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationState:D"> +<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationMetaData:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.cluster.appmaster.ApplicationState$ extends scala.runtime.AbstractFunction7<java.lang.Object,java.lang.String,java.lang.Object,<a href="org/apache/gearpump/cluster/AppDescription.html" title="class in org.apache.gearpump.cluster">AppDescription</a>,scala.Option<<a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a>>,java.lang.String,java.lang.Object,<a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationState</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.cluster.appmaster.ApplicationMetaData$ extends scala.runtime.AbstractFunction5<java.lang.Object,java.lang.Object,<a href="org/apache/gearpump/cluster/AppDescription.html" title="class in org.apache.gearpump.cluster">AppDescription</a>,scala.Option<<a href="org/apache/gearpump/cluster/AppJar.html" title="class in org.apache.gearpump.cluster">AppJar</a>>,java.lang.String,<a href="org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationMetaData</a>> implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -924,30 +1001,15 @@ </li> </ul> </li> -<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment.StartAppMaster:D"> +<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.StartAppMaster$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment.StartAppMaster$</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv"> +<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a> extends java.lang.Object implements Serializable</h3> -</li> -<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv:D"> -<!-- --> -</a> -<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$</a> extends scala.runtime.AbstractFunction4<akka.testkit.TestProbe,akka.testkit.TestProbe,akka.testkit.TestProbe,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a>> implements Serializable</h3> -</li> -<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo"> -<!-- --> -</a> -<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo</a> extends java.lang.Object implements Serializable</h3> -</li> -<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo:D"> -<!-- --> -</a> -<h3>Class org.apache.gearpump.cluster.appmaster.AppMasterRuntimeInfo$ extends scala.runtime.AbstractFunction8<java.lang.Object,java.lang.String,akka.actor.ActorRef,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,com.typesafe.config.Config,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeInfo</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.cluster.appmaster.ApplicationRuntimeInfo$ extends scala.runtime.AbstractFunction10<java.lang.Object,java.lang.String,akka.actor.ActorRef,akka.actor.ActorRef,java.lang.String,java.lang.Object,java.lang.Object,java.lang.Object,com.typesafe.config.Config,<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,<a href="org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationRuntimeInfo</a>> implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -960,6 +1022,21 @@ </li> </ul> </li> +<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment.StartAppMaster:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironment.StartAppMaster$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironment.StartAppMaster$</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$.html" title="class in org.apache.gearpump.cluster.appmaster">org.apache.gearpump.cluster.appmaster.AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv$</a> extends scala.runtime.AbstractFunction4<akka.testkit.TestProbe,akka.testkit.TestProbe,akka.testkit.TestProbe,akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeEnvironmentSpec.TestAppMasterEnv</a>> implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.gearpump.cluster.appmaster.ExecutorSystem"> <!-- --> </a> @@ -1192,6 +1269,31 @@ </ul> </li> <li class="blockList"> +<h2 title="Package">Package org.apache.gearpump.cluster.client</h2> +<ul class="blockList"> +<li class="blockList"><a name="org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterRequest"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest.html" title="class in org.apache.gearpump.cluster.client">org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterRequest</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterRequest:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest$.html" title="class in org.apache.gearpump.cluster.client">org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterRequest$</a> extends scala.runtime.AbstractFunction1<java.lang.String,<a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterRequest.html" title="class in org.apache.gearpump.cluster.client">RunningApplicationSpec.MockAskAppMasterRequest</a>> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterResponse"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse.html" title="class in org.apache.gearpump.cluster.client">org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterResponse</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterResponse:D"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse$.html" title="class in org.apache.gearpump.cluster.client">org.apache.gearpump.cluster.client.RunningApplicationSpec.MockAskAppMasterResponse$</a> extends scala.runtime.AbstractFunction1<java.lang.String,<a href="org/apache/gearpump/cluster/client/RunningApplicationSpec.MockAskAppMasterResponse.html" title="class in org.apache.gearpump.cluster.client">RunningApplicationSpec.MockAskAppMasterResponse</a>> implements Serializable</h3> +</li> +</ul> +</li> +<li class="blockList"> <h2 title="Package">Package org.apache.gearpump.cluster.main</h2> <ul class="blockList"> <li class="blockList"><a name="org.apache.gearpump.cluster.main.ArgumentsParser.Syntax"> @@ -1225,6 +1327,11 @@ </li> </ul> </li> +<li class="blockList"><a name="org.apache.gearpump.cluster.main.MasterWatcher:D:Danonfun:D3:D:Danonfun:Dapply:D1"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.cluster.main.MasterWatcher$$anonfun$3$$anonfun$apply$1 extends java.lang.Object implements Serializable</h3> +</li> </ul> </li> <li class="blockList"> @@ -1238,7 +1345,7 @@ <li class="blockList"><a name="org.apache.gearpump.cluster.master.AppManager.MasterState:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/master/AppManager.MasterState$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.AppManager.MasterState$</a> extends scala.runtime.AbstractFunction4<java.lang.Object,scala.collection.immutable.Map<java.lang.Object,scala.Tuple2<akka.actor.ActorRef,<a href="org/apache/gearpump/cluster/appmaster/AppMasterRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">AppMasterRuntimeInfo</a>>>,scala.collection.immutable.Set<java.lang.Object>,scala.collection.immutable.Set<java.lang.Object>,<a href="org/apache/gearpump/cluster/master/AppManager.MasterState.html" title="class in org.apache.gearpump.cluster.master">AppManager.MasterState</a>> implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/master/AppManager.MasterState$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.AppManager.MasterState$</a> extends scala.runtime.AbstractFunction2<java.lang.Object,scala.collection.immutable.Map<java.lang.Object,<a href="org/apache/gearpump/cluster/appmaster/ApplicationRuntimeInfo.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationRuntimeInfo</a>>,<a href="org/apache/gearpump/cluster/master/AppManager.MasterState.html" title="class in org.apache.gearpump.cluster.master">AppManager.MasterState</a>> implements Serializable</h3> </li> <li class="blockList"><a name="org.apache.gearpump.cluster.master.AppManager.RecoverApplication"> <!-- --> @@ -1248,7 +1355,7 @@ <li class="blockList"><a name="org.apache.gearpump.cluster.master.AppManager.RecoverApplication:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.AppManager.RecoverApplication$</a> extends scala.runtime.AbstractFunction1<<a href="org/apache/gearpump/cluster/appmaster/ApplicationState.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationState</a>,<a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication.html" title="class in org.apache.gearpump.cluster.master">AppManager.RecoverApplication</a>> implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication$.html" title="class in org.apache.gearpump.cluster.master">org.apache.gearpump.cluster.master.AppManager.RecoverApplication$</a> extends scala.runtime.AbstractFunction1<<a href="org/apache/gearpump/cluster/appmaster/ApplicationMetaData.html" title="class in org.apache.gearpump.cluster.appmaster">ApplicationMetaData</a>,<a href="org/apache/gearpump/cluster/master/AppManager.RecoverApplication.html" title="class in org.apache.gearpump.cluster.master">AppManager.RecoverApplication</a>> implements Serializable</h3> </li> <li class="blockList"><a name="org.apache.gearpump.cluster.master.InMemoryKVService.DeleteKVGroup"> <!-- --> @@ -2064,7 +2171,7 @@ <li class="blockList"><a name="org.apache.gearpump.streaming.ExecutorToAppMaster.MessageLoss:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss$.html" title="class in org.apache.gearpump.streaming">org.apache.gearpump.streaming.ExecutorToAppMaster.MessageLoss$</a> extends scala.runtime.AbstractFunction3<java.lang.Object,<a href="org/apache/gearpump/streaming/task/TaskId.html" title="class in org.apache.gearpump.streaming.task">TaskId</a>,java.lang.String,<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html" title="class in org.apache.gearpump.streaming">ExecutorToAppMaster.MessageLoss</a>> implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss$.html" title="class in org.apache.gearpump.streaming">org.apache.gearpump.streaming.ExecutorToAppMaster.MessageLoss$</a> extends scala.runtime.AbstractFunction4<java.lang.Object,<a href="org/apache/gearpump/streaming/task/TaskId.html" title="class in org.apache.gearpump.streaming.task">TaskId</a>,java.lang.String,scala.Option<java.lang.Throwable>,<a href="org/apache/gearpump/streaming/ExecutorToAppMaster.MessageLoss.html" title="class in org.apache.gearpump.streaming">ExecutorToAppMaster.MessageLoss</a>> implements Serializable</h3> </li> <li class="blockList"><a name="org.apache.gearpump.streaming.ExecutorToAppMaster.RegisterExecutor"> <!-- --> @@ -2202,6 +2309,11 @@ </a> <h3>Class <a href="org/apache/gearpump/streaming/appmaster/AppMaster.TaskActorRef$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.AppMaster.TaskActorRef$</a> extends scala.runtime.AbstractFunction1<akka.actor.ActorRef,<a href="org/apache/gearpump/streaming/appmaster/AppMaster.TaskActorRef.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.TaskActorRef</a>> implements Serializable</h3> </li> +<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.AppMaster:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dappmaster:DAppMaster:D:DexecutorBrief:D1:D:Danonfun:Dapply:D9"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.streaming.appmaster.AppMaster$$anonfun$org$apache$gearpump$streaming$appmaster$AppMaster$$executorBrief$1$$anonfun$apply$9 extends java.lang.Object implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.AppMasterSpec.TaskStarted:D"> <!-- --> </a> @@ -2267,6 +2379,11 @@ </a> <h3>Class <a href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock$.html" title="class in org.apache.gearpump.streaming.appmaster">org.apache.gearpump.streaming.appmaster.ClockService.StoredStartClock$</a> extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/streaming/appmaster/ClockService.StoredStartClock.html" title="class in org.apache.gearpump.streaming.appmaster">ClockService.StoredStartClock</a>> implements Serializable</h3> </li> +<li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.ClockService:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dappmaster:DClockService:D:DupdateCheckpointClocks:D2:D:Danonfun:Dapply:D1"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.streaming.appmaster.ClockService$$anonfun$org$apache$gearpump$streaming$appmaster$ClockService$$updateCheckpointClocks$2$$anonfun$apply$1 extends java.lang.Object implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.DagManager.DagInitiated:D"> <!-- --> </a> @@ -2526,7 +2643,7 @@ <li class="blockList"><a name="org.apache.gearpump.streaming.appmaster.StreamAppMasterSummary:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.appmaster.StreamAppMasterSummary$ extends scala.runtime.AbstractFunction16<java.lang.String,java.lang.Object,java.lang.String,java.lang.String,java.lang.Object,java.lang.String,java.lang.Object,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a><java.lang.Object,java.lang.String>,scala.collection.immutable.List<<a href="org/apache/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.ExecutorBrief</a>>,scala.collection.immutable.Map<java.lang.Object,<a href="org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" title="class in org.apache.gearpump.streaming.appmaster">ProcessorSummary</a>>,scala.collection.immutable.Map<java.lang.Object,java.lang.Object>,<a href="org/apache/gearpump/util/HistoryMetricsService.HistoryMetricsCon fig.html" title="class in org.apache.gearpump.util">HistoryMetricsService.HistoryMetricsConfig</a>,<a href="org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in org.apache.gearpump.streaming.appmaster">StreamAppMasterSummary</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.appmaster.StreamAppMasterSummary$ extends scala.runtime.AbstractFunction16<java.lang.String,java.lang.Object,java.lang.String,java.lang.String,java.lang.Object,<a href="org/apache/gearpump/cluster/ApplicationStatus.html" title="class in org.apache.gearpump.cluster">ApplicationStatus</a>,java.lang.Object,java.lang.Object,java.lang.String,java.lang.String,java.lang.String,<a href="org/apache/gearpump/util/Graph.html" title="class in org.apache.gearpump.util">Graph</a><java.lang.Object,java.lang.String>,scala.collection.immutable.List<<a href="org/apache/gearpump/streaming/appmaster/AppMaster.ExecutorBrief.html" title="class in org.apache.gearpump.streaming.appmaster">AppMaster.ExecutorBrief</a>>,scala.collection.immutable.Map<java.lang.Object,<a href="org/apache/gearpump/streaming/appmaster/ProcessorSummary.html" title="class in org.apache.gearpump.streaming.appmaster">ProcessorSummary</a>>,scala.collection.immutable.Map< java.lang.Object,java.lang.Object>,<a href="org/apache/gearpump/util/HistoryMetricsService.HistoryMetricsConfig.html" title="class in org.apache.gearpump.util">HistoryMetricsService.HistoryMetricsConfig</a>,<a href="org/apache/gearpump/streaming/appmaster/StreamAppMasterSummary.html" title="class in org.apache.gearpump.streaming.appmaster">StreamAppMasterSummary</a>> implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -2693,27 +2810,90 @@ </ul> </li> <li class="blockList"> -<h2 title="Package">Package org.apache.gearpump.streaming.dsl</h2> +<h2 title="Package">Package org.apache.gearpump.streaming.dsl.api.functions</h2> <ul class="blockList"> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.CollectionDataSource"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.FilterFunction"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/api/functions/FilterFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">org.apache.gearpump.streaming.dsl.api.functions.FilterFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.FilterFunction:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl">org.apache.gearpump.streaming.dsl.CollectionDataSource</a> extends java.lang.Object implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.api.functions.FilterFunction$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> +</li> +</ul> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.LoggerSink"> +</ul> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.FoldFunction"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl">org.apache.gearpump.streaming.dsl.LoggerSink</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/api/functions/FoldFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">org.apache.gearpump.streaming.dsl.api.functions.FoldFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.Stream.Sink"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.MapFunction"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/Stream.Sink.html" title="class in org.apache.gearpump.streaming.dsl">org.apache.gearpump.streaming.dsl.Stream.Sink</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/api/functions/MapFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">org.apache.gearpump.streaming.dsl.api.functions.MapFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.StreamApp.Source"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.MapFunction:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/StreamApp.Source.html" title="class in org.apache.gearpump.streaming.dsl">org.apache.gearpump.streaming.dsl.StreamApp.Source</a> extends java.lang.Object implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.api.functions.MapFunction$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.ReduceFunction"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/api/functions/ReduceFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">org.apache.gearpump.streaming.dsl.api.functions.ReduceFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/api/functions/FoldFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">FoldFunction</a><<a href="org/apache/gearpump/streaming/dsl/api/functions/ReduceFunction.html" title="type parameter in ReduceFunction">T</a>,scala.Option<<a href="org/apache/gearpump/streaming/dsl/api/functions/ReduceFunction.html" title="type parameter in ReduceFunction">T</a>>> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.api.functions.ReduceFunction:D"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.streaming.dsl.api.functions.ReduceFunction$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> +</li> +</ul> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"> +<h2 title="Package">Package org.apache.gearpump.streaming.dsl.javaapi.functions</h2> +<ul class="blockList"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/javaapi/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.javaapi.functions">org.apache.gearpump.streaming.dsl.javaapi.functions.FlatMapFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.javaapi.functions.GroupByFunction"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="class in org.apache.gearpump.streaming.dsl.javaapi.functions">org.apache.gearpump.streaming.dsl.javaapi.functions.GroupByFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/api/functions/MapFunction.html" title="class in org.apache.gearpump.streaming.dsl.api.functions">MapFunction</a><<a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="type parameter in GroupByFunction">T</a>,<a href="org/apache/gearpump/streaming/dsl/javaapi/functions/GroupByFunction.html" title="type parameter in GroupByFunction">GROUP</a>> implements Serializable</h3> </li> </ul> </li> @@ -2943,20 +3123,108 @@ </a> <h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/AndThen.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.AndThen</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.EmitFunction"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.AndThen:D"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.streaming.dsl.plan.functions.AndThen$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.Emit"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/Emit.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.Emit</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapper.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FlatMapper</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/FoldRunner.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FoldRunner</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner:D"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.streaming.dsl.plan.functions.FunctionRunner$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> +</li> +</ul> +</li> +</ul> +</li> +</ul> +</li> +<li class="blockList"> +<h2 title="Package">Package org.apache.gearpump.streaming.dsl.scalaapi</h2> +<ul class="blockList"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.CollectionDataSource"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/CollectionDataSource.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">org.apache.gearpump.streaming.dsl.scalaapi.CollectionDataSource</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.LoggerSink"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/LoggerSink.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">org.apache.gearpump.streaming.dsl.scalaapi.LoggerSink</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.Stream.Sink"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/Stream.Sink.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">org.apache.gearpump.streaming.dsl.scalaapi.Stream.Sink</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.StreamApp.Source"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/StreamApp.Source.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi">org.apache.gearpump.streaming.dsl.scalaapi.StreamApp.Source</a> extends java.lang.Object implements Serializable</h3> +</li> +</ul> +</li> +<li class="blockList"> +<h2 title="Package">Package org.apache.gearpump.streaming.dsl.scalaapi.functions</h2> +<ul class="blockList"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/EmitFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.EmitFunction</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">SerializableFunction</a> implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.FlatMapFunction"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/FlatMapFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.FlatMapFunction</a> extends java.lang.Object implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.scalaapi.functions.FlatMapFunction$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.plan.functions.ReduceFunction"> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/plan/functions/ReduceFunction.html" title="class in org.apache.gearpump.streaming.dsl.plan.functions">org.apache.gearpump.streaming.dsl.plan.functions.ReduceFunction</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/scalaapi/functions/SerializableFunction.html" title="class in org.apache.gearpump.streaming.dsl.scalaapi.functions">org.apache.gearpump.streaming.dsl.scalaapi.functions.SerializableFunction</a> extends java.lang.Object implements Serializable</h3> </li> </ul> </li> @@ -3015,15 +3283,15 @@ </li> </ul> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFn"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.CountWindowFn</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">NonMergingWindowFunction</a><<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFunction.html" title="type parameter in CountWindowFunction">T</a>> implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFn:D"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.dsl.window.api.CountWindowFn$ extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/streaming/dsl/window/api/CountWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">CountWindowFn</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.window.api.CountWindowFunction$ extends java.lang.Object implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -3099,15 +3367,15 @@ </li> </ul> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/SessionWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn:D"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFn$ extends scala.runtime.AbstractFunction2<java.time.Duration,java.time.Duration,<a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFn.html" title="class in org.apache.gearpump.streaming.dsl.window.api">SlidingWindowFn</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.window.api.SessionWindowFunction$ extends java.lang.Object implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -3120,15 +3388,15 @@ </li> </ul> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Window"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/Window.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Window</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction</a> extends <a href="org/apache/gearpump/streaming/dsl/window/api/NonMergingWindowFunction.html" title="class in org.apache.gearpump.streaming.dsl.window.api">NonMergingWindowFunction</a><<a href="org/apache/gearpump/streaming/dsl/window/api/SlidingWindowFunction.html" title="type parameter in SlidingWindowFunction">T</a>> implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Window:D"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.dsl.window.api.Window$ extends scala.runtime.AbstractFunction3<<a href="org/apache/gearpump/streaming/dsl/window/api/WindowFn.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">WindowFn</a>,<a href="org/apache/gearpump/streaming/dsl/window/api/Trigger.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">Trigger</a>,<a href="org/apache/gearpump/streaming/dsl/window/api/AccumulationMode.html" title="interface in org.apache.gearpump.streaming.dsl.window.api">AccumulationMode</a>,<a href="org/apache/gearpump/streaming/dsl/window/api/Window.html" title="class in org.apache.gearpump.streaming.dsl.window.api">Window</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.window.api.SlidingWindowFunction$ extends java.lang.Object implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -3141,20 +3409,15 @@ </li> </ul> </li> -</ul> -</li> -<li class="blockList"> -<h2 title="Package">Package org.apache.gearpump.streaming.dsl.window.impl</h2> -<ul class="blockList"> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Bucket"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Windows"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/Bucket.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.Bucket</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/api/Windows.html" title="class in org.apache.gearpump.streaming.dsl.window.api">org.apache.gearpump.streaming.dsl.window.api.Windows</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Bucket:D"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.api.Windows:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.dsl.window.impl.Bucket$ extends java.lang.Object implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.window.api.Windows$ extends java.lang.Object implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -3167,25 +3430,41 @@ </li> </ul> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup"> +</ul> +</li> +<li class="blockList"> +<h2 title="Package">Package org.apache.gearpump.streaming.dsl.window.impl</h2> +<ul class="blockList"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.WindowGroup.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup:D"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow:D"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/DefaultWindowRunner.WindowGroup$.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.DefaultWindowRunner.WindowGroup$</a> extends java.lang.Object implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow"> +</ul> +</li> +</ul> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Window"> <!-- --> </a> -<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/GroupAlsoByWindow.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow</a> extends java.lang.Object implements Serializable</h3> +<h3>Class <a href="org/apache/gearpump/streaming/dsl/window/impl/Window.html" title="class in org.apache.gearpump.streaming.dsl.window.impl">org.apache.gearpump.streaming.dsl.window.impl.Window</a> extends java.lang.Object implements Serializable</h3> </li> -<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow:D"> +<li class="blockList"><a name="org.apache.gearpump.streaming.dsl.window.impl.Window:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.dsl.window.impl.GroupAlsoByWindow$ extends java.lang.Object implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.dsl.window.impl.Window$ extends java.lang.Object implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -3345,9 +3624,6 @@ </ul> </li> <li class="blockList"> -<h2 title="Package">Package org.apache.gearpump.streaming.javaapi.dsl.functions</h2> -</li> -<li class="blockList"> <h2 title="Package">Package org.apache.gearpump.streaming.kafka</h2> <ul class="blockList"> <li class="blockList"><a name="org.apache.gearpump.streaming.kafka.KafkaSink"> @@ -3582,7 +3858,7 @@ <li class="blockList"><a name="org.apache.gearpump.streaming.source.Watermark:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.source.Watermark$ extends scala.runtime.AbstractFunction1<java.time.Instant,<a href="org/apache/gearpump/streaming/source/Watermark.html" title="class in org.apache.gearpump.streaming.source">Watermark</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.source.Watermark$ extends java.lang.Object implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -3593,6 +3869,19 @@ </li> </ul> </li> +<li class="blockList"> +<h3>Serialized Fields</h3> +<ul class="blockList"> +<li class="blockList"> +<h4>MAX</h4> +<pre>java.time.Instant MAX</pre> +</li> +<li class="blockListLast"> +<h4>MIN</h4> +<pre>java.time.Instant MIN</pre> +</li> +</ul> +</li> </ul> </li> </ul> @@ -3748,6 +4037,27 @@ </li> </ul> </li> +<li class="blockList"><a name="org.apache.gearpump.streaming.task.EndingClock"> +<!-- --> +</a> +<h3>Class <a href="org/apache/gearpump/streaming/task/EndingClock.html" title="class in org.apache.gearpump.streaming.task">org.apache.gearpump.streaming.task.EndingClock</a> extends java.lang.Object implements Serializable</h3> +</li> +<li class="blockList"><a name="org.apache.gearpump.streaming.task.EndingClock:D"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.streaming.task.EndingClock$ extends java.lang.Object implements Serializable</h3> +<ul class="blockList"> +<li class="blockList"> +<h3>Serialization Methods</h3> +<ul class="blockList"> +<li class="blockListLast"> +<h4>readResolve</h4> +<pre>private java.lang.Object readResolve()</pre> +</li> +</ul> +</li> +</ul> +</li> <li class="blockList"><a name="org.apache.gearpump.streaming.task.GetCheckpointClock"> <!-- --> </a> @@ -3903,7 +4213,7 @@ <li class="blockList"><a name="org.apache.gearpump.streaming.task.SendMessageLoss:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.task.SendMessageLoss$ extends scala.runtime.AbstractFunction0<<a href="org/apache/gearpump/streaming/task/SendMessageLoss.html" title="class in org.apache.gearpump.streaming.task">SendMessageLoss</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.task.SendMessageLoss$ extends java.lang.Object implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -4004,6 +4314,11 @@ </a> <h3>Class <a href="org/apache/gearpump/streaming/task/TaskActor.SendAck$.html" title="class in org.apache.gearpump.streaming.task">org.apache.gearpump.streaming.task.TaskActor.SendAck$</a> extends scala.runtime.AbstractFunction2<<a href="org/apache/gearpump/streaming/task/Ack.html" title="class in org.apache.gearpump.streaming.task">Ack</a>,<a href="org/apache/gearpump/streaming/task/TaskId.html" title="class in org.apache.gearpump.streaming.task">TaskId</a>,<a href="org/apache/gearpump/streaming/task/TaskActor.SendAck.html" title="class in org.apache.gearpump.streaming.task">TaskActor.SendAck</a>> implements Serializable</h3> </li> +<li class="blockList"><a name="org.apache.gearpump.streaming.task.TaskActor:D:Danonfun:Dorg:Dapache:Dgearpump:Dstreaming:Dtask:DTaskActor:D:DonStartClock:D4:D:Danonfun:Dapply:D1"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.streaming.task.TaskActor$$anonfun$org$apache$gearpump$streaming$task$TaskActor$$onStartClock$4$$anonfun$apply$1 extends java.lang.Object implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.gearpump.streaming.task.TaskContextData"> <!-- --> </a> @@ -4096,7 +4411,7 @@ <li class="blockList"><a name="org.apache.gearpump.streaming.task.UpstreamMinClock:D"> <!-- --> </a> -<h3>Class org.apache.gearpump.streaming.task.UpstreamMinClock$ extends scala.runtime.AbstractFunction1<java.lang.Object,<a href="org/apache/gearpump/streaming/task/UpstreamMinClock.html" title="class in org.apache.gearpump.streaming.task">UpstreamMinClock</a>> implements Serializable</h3> +<h3>Class org.apache.gearpump.streaming.task.UpstreamMinClock$ extends scala.runtime.AbstractFunction1<scala.Option<java.lang.Object>,<a href="org/apache/gearpump/streaming/task/UpstreamMinClock.html" title="class in org.apache.gearpump.streaming.task">UpstreamMinClock</a>> implements Serializable</h3> <ul class="blockList"> <li class="blockList"> <h3>Serialization Methods</h3> @@ -4349,6 +4664,11 @@ </li> </ul> </li> +<li class="blockList"><a name="org.apache.gearpump.util.Graph:D:Danonfun:DgetAcyclicCopy:D2:D:Danonfun:Dapply:D4:D:Danonfun:Dapply:D5:D:Danonfun:Dapply:D6"> +<!-- --> +</a> +<h3>Class org.apache.gearpump.util.Graph$$anonfun$getAcyclicCopy$2$$anonfun$apply$4$$anonfun$apply$5$$anonfun$apply$6 extends java.lang.Object implements Serializable</h3> +</li> <li class="blockList"><a name="org.apache.gearpump.util.GraphSpec.Edge"> <!-- --> </a> http://git-wip-us.apache.org/repos/asf/incubator-gearpump-site/blob/ec689a85/content/releases/latest/api/java/stylesheet.css ---------------------------------------------------------------------- diff --git a/content/releases/latest/api/java/stylesheet.css b/content/releases/latest/api/java/stylesheet.css index cebb4fd..98055b2 100644 --- a/content/releases/latest/api/java/stylesheet.css +++ b/content/releases/latest/api/java/stylesheet.css @@ -463,7 +463,6 @@ Table styles .useSummary td, .constantsSummary td, .deprecatedSummary td { text-align:left; padding:0px 0px 12px 10px; - width:100%; } th.colOne, th.colFirst, th.colLast, .useSummary th, .constantsSummary th, td.colOne, td.colFirst, td.colLast, .useSummary td, .constantsSummary td{ @@ -488,6 +487,7 @@ td.colOne, th.colOne { font-size:13px; } .overviewSummary td.colFirst, .overviewSummary th.colFirst, +.useSummary td.colFirst, .useSummary th.colFirst, .overviewSummary td.colOne, .overviewSummary th.colOne, .memberSummary td.colFirst, .memberSummary th.colFirst, .memberSummary td.colOne, .memberSummary th.colOne,
