| <!DOCTYPE HTML> |
| <!-- NewPage --> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (11.0.9.1) on Fri Sep 09 19:30:40 KST 2022 --> |
| <title>Serialized Form (Nemo Project 0.4 API)</title> |
| <meta http-equiv="Content-Type" content="text/html; charset=UTF-8"> |
| <meta name="dc.created" content="2022-09-09"> |
| <link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style"> |
| <link rel="stylesheet" type="text/css" href="jquery/jquery-ui.css" title="Style"> |
| <script type="text/javascript" src="script.js"></script> |
| <script type="text/javascript" src="jquery/jszip/dist/jszip.min.js"></script> |
| <script type="text/javascript" src="jquery/jszip-utils/dist/jszip-utils.min.js"></script> |
| <!--[if IE]> |
| <script type="text/javascript" src="jquery/jszip-utils/dist/jszip-utils-ie.min.js"></script> |
| <![endif]--> |
| <script type="text/javascript" src="jquery/jquery-3.5.1.js"></script> |
| <script type="text/javascript" src="jquery/jquery-ui.js"></script> |
| </head> |
| <body> |
| <script type="text/javascript"><!-- |
| try { |
| if (location.href.indexOf('is-external=true') == -1) { |
| parent.document.title="Serialized Form (Nemo Project 0.4 API)"; |
| } |
| } |
| catch(err) { |
| } |
| //--> |
| var pathtoroot = "./"; |
| var useModuleDirectories = true; |
| loadScripts(document, 'script');</script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| <header role="banner"> |
| <nav role="navigation"> |
| <div class="fixedNav"> |
| <!-- ========= START OF TOP NAVBAR ======= --> |
| <div class="topNav"><a id="navbar.top"> |
| <!-- --> |
| </a> |
| <div class="skipNav"><a href="#skip.navbar.top" title="Skip navigation links">Skip navigation links</a></div> |
| <a id="navbar.top.firstrow"> |
| <!-- --> |
| </a> |
| <ul class="navList" title="Navigation"> |
| <li><a href="index.html">Overview</a></li> |
| <li>Package</li> |
| <li>Class</li> |
| <li>Use</li> |
| <li><a href="overview-tree.html">Tree</a></li> |
| <li><a href="deprecated-list.html">Deprecated</a></li> |
| <li><a href="index-all.html">Index</a></li> |
| <li><a href="help-doc.html">Help</a></li> |
| </ul> |
| </div> |
| <div class="subNav"> |
| <ul class="navList" id="allclasses_navbar_top"> |
| <li><a href="allclasses.html">All Classes</a></li> |
| </ul> |
| <ul class="navListSearch"> |
| <li><label for="search">SEARCH:</label> |
| <input type="text" id="search" value="search" disabled="disabled"> |
| <input type="reset" id="reset" value="reset" disabled="disabled"> |
| </li> |
| </ul> |
| <div> |
| <script type="text/javascript"><!-- |
| allClassesLink = document.getElementById("allclasses_navbar_top"); |
| if(window==top) { |
| allClassesLink.style.display = "block"; |
| } |
| else { |
| allClassesLink.style.display = "none"; |
| } |
| //--> |
| </script> |
| <noscript> |
| <div>JavaScript is disabled on your browser.</div> |
| </noscript> |
| </div> |
| <a id="skip.navbar.top"> |
| <!-- --> |
| </a></div> |
| <!-- ========= END OF TOP NAVBAR ========= --> |
| </div> |
| <div class="navPadding"> </div> |
| <script type="text/javascript"><!-- |
| $('.navPadding').css('padding-top', $('.fixedNav').css("height")); |
| //--> |
| </script> |
| </nav> |
| </header> |
| <main role="main"> |
| <div class="header"> |
| <h1 title="Serialized Form" class="title">Serialized Form</h1> |
| </div> |
| <div class="serializedFormContainer"> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.HashRange"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/HashRange.html" title="class in org.apache.nemo.common">org.apache.nemo.common.HashRange</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>rangeBeginInclusive</h4> |
| <pre>int rangeBeginInclusive</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>rangeEndExclusive</h4> |
| <pre>int rangeEndExclusive</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.Pair"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/Pair.html" title="class in org.apache.nemo.common">org.apache.nemo.common.Pair</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>left</h4> |
| <pre><a href="org/apache/nemo/common/Pair.html" title="type parameter in Pair">A</a> left</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>right</h4> |
| <pre><a href="org/apache/nemo/common/Pair.html" title="type parameter in Pair">B</a> right</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.PairKeyExtractor"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/PairKeyExtractor.html" title="class in org.apache.nemo.common">org.apache.nemo.common.PairKeyExtractor</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.coder</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.BytesDecoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/BytesDecoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.BytesDecoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.BytesEncoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/BytesEncoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.BytesEncoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.DecoderFactory.DummyDecoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/DecoderFactory.DummyDecoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.DecoderFactory.DummyDecoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>dummyDecoder</h4> |
| <pre><a href="org/apache/nemo/common/coder/DecoderFactory.Decoder.html" title="interface in org.apache.nemo.common.coder">DecoderFactory.Decoder</a> dummyDecoder</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.EncoderFactory.DummyEncoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/EncoderFactory.DummyEncoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.EncoderFactory.DummyEncoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>dummyEncoder</h4> |
| <pre><a href="org/apache/nemo/common/coder/EncoderFactory.Encoder.html" title="interface in org.apache.nemo.common.coder">EncoderFactory.Encoder</a> dummyEncoder</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.IntDecoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/IntDecoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.IntDecoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.IntEncoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/IntEncoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.IntEncoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.LongDecoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/LongDecoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.LongDecoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.LongEncoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/LongEncoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.LongEncoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.PairDecoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/PairDecoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.PairDecoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>leftDecoderFactory</h4> |
| <pre><a href="org/apache/nemo/common/coder/DecoderFactory.html" title="interface in org.apache.nemo.common.coder">DecoderFactory</a><<a href="org/apache/nemo/common/coder/PairDecoderFactory.html" title="type parameter in PairDecoderFactory">A</a> extends java.io.Serializable> leftDecoderFactory</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>rightDecoderFactory</h4> |
| <pre><a href="org/apache/nemo/common/coder/DecoderFactory.html" title="interface in org.apache.nemo.common.coder">DecoderFactory</a><<a href="org/apache/nemo/common/coder/PairDecoderFactory.html" title="type parameter in PairDecoderFactory">B</a> extends java.io.Serializable> rightDecoderFactory</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.coder.PairEncoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/coder/PairEncoderFactory.html" title="class in org.apache.nemo.common.coder">org.apache.nemo.common.coder.PairEncoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>leftEncoderFactory</h4> |
| <pre><a href="org/apache/nemo/common/coder/EncoderFactory.html" title="interface in org.apache.nemo.common.coder">EncoderFactory</a><<a href="org/apache/nemo/common/coder/PairEncoderFactory.html" title="type parameter in PairEncoderFactory">A</a> extends java.io.Serializable> leftEncoderFactory</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>rightEncoderFactory</h4> |
| <pre><a href="org/apache/nemo/common/coder/EncoderFactory.html" title="interface in org.apache.nemo.common.coder">EncoderFactory</a><<a href="org/apache/nemo/common/coder/PairEncoderFactory.html" title="type parameter in PairEncoderFactory">B</a> extends java.io.Serializable> rightEncoderFactory</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.dag</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.dag.DAG"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/dag/DAG.html" title="class in org.apache.nemo.common.dag">org.apache.nemo.common.dag.DAG</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>assignedLoopVertexMap</h4> |
| <pre>java.util.Map<java.lang.String,​<a href="org/apache/nemo/common/ir/vertex/LoopVertex.html" title="class in org.apache.nemo.common.ir.vertex">LoopVertex</a>> assignedLoopVertexMap</pre> |
| </li> |
| <li class="blockList"> |
| <h4>incomingEdges</h4> |
| <pre>java.util.Map<java.lang.String,​java.util.List<<a href="org/apache/nemo/common/dag/DAG.html" title="type parameter in DAG">E</a> extends <a href="org/apache/nemo/common/dag/Edge.html" title="class in org.apache.nemo.common.dag">Edge</a><<a href="org/apache/nemo/common/dag/DAG.html" title="type parameter in DAG">V</a>>>> incomingEdges</pre> |
| </li> |
| <li class="blockList"> |
| <h4>loopStackDepthMap</h4> |
| <pre>java.util.Map<java.lang.String,​java.lang.Integer> loopStackDepthMap</pre> |
| </li> |
| <li class="blockList"> |
| <h4>outgoingEdges</h4> |
| <pre>java.util.Map<java.lang.String,​java.util.List<<a href="org/apache/nemo/common/dag/DAG.html" title="type parameter in DAG">E</a> extends <a href="org/apache/nemo/common/dag/Edge.html" title="class in org.apache.nemo.common.dag">Edge</a><<a href="org/apache/nemo/common/dag/DAG.html" title="type parameter in DAG">V</a>>>> outgoingEdges</pre> |
| </li> |
| <li class="blockList"> |
| <h4>rootVertices</h4> |
| <pre>java.util.List<<a href="org/apache/nemo/common/dag/DAG.html" title="type parameter in DAG">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a>> rootVertices</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>vertices</h4> |
| <pre>java.util.List<<a href="org/apache/nemo/common/dag/DAG.html" title="type parameter in DAG">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a>> vertices</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.dag.DAGBuilder"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/dag/DAGBuilder.html" title="class in org.apache.nemo.common.dag">org.apache.nemo.common.dag.DAGBuilder</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>assignedLoopVertexMap</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a>,​<a href="org/apache/nemo/common/ir/vertex/LoopVertex.html" title="class in org.apache.nemo.common.ir.vertex">LoopVertex</a>> assignedLoopVertexMap</pre> |
| </li> |
| <li class="blockList"> |
| <h4>incomingEdges</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a>,​java.util.Set<<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">E</a> extends <a href="org/apache/nemo/common/dag/Edge.html" title="class in org.apache.nemo.common.dag">Edge</a><<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">V</a>>>> incomingEdges</pre> |
| </li> |
| <li class="blockList"> |
| <h4>loopStackDepthMap</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a>,​java.lang.Integer> loopStackDepthMap</pre> |
| </li> |
| <li class="blockList"> |
| <h4>outgoingEdges</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a>,​java.util.Set<<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">E</a> extends <a href="org/apache/nemo/common/dag/Edge.html" title="class in org.apache.nemo.common.dag">Edge</a><<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">V</a>>>> outgoingEdges</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>vertices</h4> |
| <pre>java.util.Set<<a href="org/apache/nemo/common/dag/DAGBuilder.html" title="type parameter in DAGBuilder">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a>> vertices</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.dag.Edge"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/dag/Edge.html" title="class in org.apache.nemo.common.dag">org.apache.nemo.common.dag.Edge</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>dst</h4> |
| <pre><a href="org/apache/nemo/common/dag/Edge.html" title="type parameter in Edge">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a> dst</pre> |
| </li> |
| <li class="blockList"> |
| <h4>id</h4> |
| <pre>java.lang.String id</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>src</h4> |
| <pre><a href="org/apache/nemo/common/dag/Edge.html" title="type parameter in Edge">V</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a> src</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.dag.Vertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">org.apache.nemo.common.dag.Vertex</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>id</h4> |
| <pre>java.lang.String id</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.exception</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.BlockFetchException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/BlockFetchException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.BlockFetchException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.BlockWriteException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/BlockWriteException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.BlockWriteException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.CompileTimeOptimizationException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/CompileTimeOptimizationException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.CompileTimeOptimizationException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.ContainerException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/ContainerException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.ContainerException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.DataSourceException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/DataSourceException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.DataSourceException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.DynamicOptimizationException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/DynamicOptimizationException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.DynamicOptimizationException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.IllegalEdgeOperationException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/IllegalEdgeOperationException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.IllegalEdgeOperationException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.IllegalMessageException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/IllegalMessageException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.IllegalMessageException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.IllegalStateTransitionException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/IllegalStateTransitionException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.IllegalStateTransitionException</a> extends java.lang.Exception implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.IllegalVertexOperationException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/IllegalVertexOperationException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.IllegalVertexOperationException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.InvalidParameterException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/InvalidParameterException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.InvalidParameterException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.InvalidUserMainException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/InvalidUserMainException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.InvalidUserMainException</a> extends java.lang.Exception implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.JsonParseException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/JsonParseException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.JsonParseException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.MetricException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/MetricException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.MetricException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.NodeConnectionException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/NodeConnectionException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.NodeConnectionException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.OutputMismatchException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/OutputMismatchException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.OutputMismatchException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.PhysicalPlanGenerationException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/PhysicalPlanGenerationException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.PhysicalPlanGenerationException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.RuntimeOptimizationException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/RuntimeOptimizationException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.RuntimeOptimizationException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.SchedulingException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/SchedulingException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.SchedulingException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.SimulationException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/SimulationException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.SimulationException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnknownExecutionStateException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnknownExecutionStateException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnknownExecutionStateException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnknownFailureCauseException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnknownFailureCauseException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnknownFailureCauseException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnrecoverableFailureException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnrecoverableFailureException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnrecoverableFailureException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnsupportedBlockStoreException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnsupportedBlockStoreException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnsupportedBlockStoreException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnsupportedCommPatternException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnsupportedCommPatternException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnsupportedCommPatternException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnsupportedCompressionException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnsupportedCompressionException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnsupportedCompressionException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnsupportedExecutionPropertyException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnsupportedExecutionPropertyException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnsupportedExecutionPropertyException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnsupportedMethodException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnsupportedMethodException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnsupportedMethodException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnsupportedMetricException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnsupportedMetricException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnsupportedMetricException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.exception.UnsupportedPartitionerException"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/exception/UnsupportedPartitionerException.html" title="class in org.apache.nemo.common.exception">org.apache.nemo.common.exception.UnsupportedPartitionerException</a> extends java.lang.RuntimeException implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.BoundedIteratorReadable"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/BoundedIteratorReadable.html" title="class in org.apache.nemo.common.ir">org.apache.nemo.common.ir.BoundedIteratorReadable</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>iterator</h4> |
| <pre>java.util.Iterator<<a href="org/apache/nemo/common/ir/BoundedIteratorReadable.html" title="type parameter in BoundedIteratorReadable">O</a>> iterator</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.IRDAG"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/IRDAG.html" title="class in org.apache.nemo.common.ir">org.apache.nemo.common.ir.IRDAG</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>dagSnapshot</h4> |
| <pre><a href="org/apache/nemo/common/dag/DAG.html" title="class in org.apache.nemo.common.dag">DAG</a><<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>> dagSnapshot</pre> |
| </li> |
| <li class="blockList"> |
| <h4>executorInfo</h4> |
| <pre>java.util.List<<a href="org/apache/nemo/common/Pair.html" title="class in org.apache.nemo.common">Pair</a><java.lang.Integer,​<a href="org/apache/nemo/common/ir/executionproperty/ResourceSpecification.html" title="class in org.apache.nemo.common.ir.executionproperty">ResourceSpecification</a>>> executorInfo</pre> |
| <div class="block">To remember the specifications of the executors used to run the IR DAG with.</div> |
| </li> |
| <li class="blockList"> |
| <h4>messageVertexToGroup</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​java.util.Set<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>>> messageVertexToGroup</pre> |
| </li> |
| <li class="blockList"> |
| <h4>modifiedDAG</h4> |
| <pre><a href="org/apache/nemo/common/dag/DAG.html" title="class in org.apache.nemo.common.dag">DAG</a><<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>> modifiedDAG</pre> |
| </li> |
| <li class="blockList"> |
| <h4>samplingVertexToGroup</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/vertex/utility/SamplingVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility">SamplingVertex</a>,​java.util.Set<<a href="org/apache/nemo/common/ir/vertex/utility/SamplingVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility">SamplingVertex</a>>> samplingVertexToGroup</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>streamVertexToOriginalEdge</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/vertex/utility/RelayVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility">RelayVertex</a>,​<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>> streamVertexToOriginalEdge</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir.edge</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.IREdge"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">org.apache.nemo.common.ir.edge.IREdge</a> extends <a href="org/apache/nemo/common/dag/Edge.html" title="class in org.apache.nemo.common.dag">Edge</a><<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>executionProperties</h4> |
| <pre><a href="org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMap.html" title="class in org.apache.nemo.common.ir.executionproperty">ExecutionPropertyMap</a><<a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a>> executionProperties</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir.edge.executionproperty</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.AdditionalOutputTagProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/AdditionalOutputTagProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.AdditionalOutputTagProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><java.lang.String> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.BlockFetchFailureProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/BlockFetchFailureProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.BlockFetchFailureProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/BlockFetchFailureProperty.Value.html" title="enum in org.apache.nemo.common.ir.edge.executionproperty">BlockFetchFailureProperty.Value</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.CacheIDProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/CacheIDProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.CacheIDProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><java.util.UUID> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.CommunicationPatternProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/CommunicationPatternProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.CommunicationPatternProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/CommunicationPatternProperty.Value.html" title="enum in org.apache.nemo.common.ir.edge.executionproperty">CommunicationPatternProperty.Value</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.CompressionProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/CompressionProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.CompressionProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/CompressionProperty.Value.html" title="enum in org.apache.nemo.common.ir.edge.executionproperty">CompressionProperty.Value</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.DataFlowProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/DataFlowProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.DataFlowProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/DataFlowProperty.Value.html" title="enum in org.apache.nemo.common.ir.edge.executionproperty">DataFlowProperty.Value</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.DataPersistenceProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/DataPersistenceProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.DataPersistenceProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/DataPersistenceProperty.Value.html" title="enum in org.apache.nemo.common.ir.edge.executionproperty">DataPersistenceProperty.Value</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.DataStoreProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/DataStoreProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.DataStoreProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/DataStoreProperty.Value.html" title="enum in org.apache.nemo.common.ir.edge.executionproperty">DataStoreProperty.Value</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.DecoderProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/DecoderProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.DecoderProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/coder/DecoderFactory.html" title="interface in org.apache.nemo.common.coder">DecoderFactory</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.DecompressionProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/DecompressionProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.DecompressionProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/CompressionProperty.Value.html" title="enum in org.apache.nemo.common.ir.edge.executionproperty">CompressionProperty.Value</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.DuplicateEdgeGroupProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/DuplicateEdgeGroupProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.DuplicateEdgeGroupProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/DuplicateEdgeGroupPropertyValue.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">DuplicateEdgeGroupPropertyValue</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.DuplicateEdgeGroupPropertyValue"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/DuplicateEdgeGroupPropertyValue.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.DuplicateEdgeGroupPropertyValue</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>groupId</h4> |
| <pre>java.lang.String groupId</pre> |
| </li> |
| <li class="blockList"> |
| <h4>groupSize</h4> |
| <pre>int groupSize</pre> |
| </li> |
| <li class="blockList"> |
| <h4>isRepresentativeEdgeDecided</h4> |
| <pre>boolean isRepresentativeEdgeDecided</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>representativeEdgeId</h4> |
| <pre>java.lang.String representativeEdgeId</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.EncoderProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/EncoderProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.EncoderProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/coder/EncoderFactory.html" title="interface in org.apache.nemo.common.coder">EncoderFactory</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.KeyDecoderProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/KeyDecoderProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.KeyDecoderProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/coder/DecoderFactory.html" title="interface in org.apache.nemo.common.coder">DecoderFactory</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.KeyEncoderProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/KeyEncoderProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.KeyEncoderProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/coder/EncoderFactory.html" title="interface in org.apache.nemo.common.coder">EncoderFactory</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.KeyExtractorProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/KeyExtractorProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.KeyExtractorProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/KeyExtractor.html" title="interface in org.apache.nemo.common">KeyExtractor</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.MessageIdEdgeProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/MessageIdEdgeProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.MessageIdEdgeProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><java.util.HashSet<java.lang.Integer>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.PartitionerProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/PartitionerProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.PartitionerProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><<a href="org/apache/nemo/common/Pair.html" title="class in org.apache.nemo.common">Pair</a><<a href="org/apache/nemo/common/ir/edge/executionproperty/PartitionerProperty.Type.html" title="enum in org.apache.nemo.common.ir.edge.executionproperty">PartitionerProperty.Type</a>,​java.lang.Integer>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.PartitionSetProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/PartitionSetProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.PartitionSetProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><java.util.ArrayList<<a href="org/apache/nemo/common/KeyRange.html" title="interface in org.apache.nemo.common">KeyRange</a>>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.edge.executionproperty.SubPartitionSetProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/edge/executionproperty/SubPartitionSetProperty.html" title="class in org.apache.nemo.common.ir.edge.executionproperty">org.apache.nemo.common.ir.edge.executionproperty.SubPartitionSetProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">EdgeExecutionProperty</a><java.util.ArrayList<<a href="org/apache/nemo/common/KeyRange.html" title="interface in org.apache.nemo.common">KeyRange</a>>> implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir.executionproperty</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.executionproperty.EdgeExecutionProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">org.apache.nemo.common.ir.executionproperty.EdgeExecutionProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/ExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">ExecutionProperty</a><<a href="org/apache/nemo/common/ir/executionproperty/EdgeExecutionProperty.html" title="type parameter in EdgeExecutionProperty">T</a> extends java.io.Serializable> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.executionproperty.ExecutionProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/executionproperty/ExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">org.apache.nemo.common.ir.executionproperty.ExecutionProperty</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>value</h4> |
| <pre><a href="org/apache/nemo/common/ir/executionproperty/ExecutionProperty.html" title="type parameter in ExecutionProperty">T</a> extends java.io.Serializable value</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.executionproperty.ExecutionPropertyMap"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMap.html" title="class in org.apache.nemo.common.ir.executionproperty">org.apache.nemo.common.ir.executionproperty.ExecutionPropertyMap</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>finalizedProperties</h4> |
| <pre>java.util.Set<java.lang.Class<? extends <a href="org/apache/nemo/common/ir/executionproperty/ExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">ExecutionProperty</a>>> finalizedProperties</pre> |
| </li> |
| <li class="blockList"> |
| <h4>id</h4> |
| <pre>java.lang.String id</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>properties</h4> |
| <pre>java.util.Map<java.lang.Class<? extends <a href="org/apache/nemo/common/ir/executionproperty/ExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">ExecutionProperty</a>>,​<a href="org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMap.html" title="type parameter in ExecutionPropertyMap">T</a> extends <a href="org/apache/nemo/common/ir/executionproperty/ExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">ExecutionProperty</a>> properties</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.executionproperty.VertexExecutionProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">org.apache.nemo.common.ir.executionproperty.VertexExecutionProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/ExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">ExecutionProperty</a><<a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="type parameter in VertexExecutionProperty">T</a> extends java.io.Serializable> implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir.vertex</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.CachedSourceVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/CachedSourceVertex.html" title="class in org.apache.nemo.common.ir.vertex">org.apache.nemo.common.ir.vertex.CachedSourceVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/SourceVertex.html" title="class in org.apache.nemo.common.ir.vertex">SourceVertex</a><<a href="org/apache/nemo/common/ir/vertex/CachedSourceVertex.html" title="type parameter in CachedSourceVertex">T</a>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>readables</h4> |
| <pre>java.util.List<<a href="org/apache/nemo/common/ir/Readable.html" title="interface in org.apache.nemo.common.ir">Readable</a><<a href="org/apache/nemo/common/ir/vertex/CachedSourceVertex.html" title="type parameter in CachedSourceVertex">T</a>>> readables</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.InMemorySourceVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/InMemorySourceVertex.html" title="class in org.apache.nemo.common.ir.vertex">org.apache.nemo.common.ir.vertex.InMemorySourceVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/SourceVertex.html" title="class in org.apache.nemo.common.ir.vertex">SourceVertex</a><<a href="org/apache/nemo/common/ir/vertex/InMemorySourceVertex.html" title="type parameter in InMemorySourceVertex">T</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.IRVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">org.apache.nemo.common.ir.vertex.IRVertex</a> extends <a href="org/apache/nemo/common/dag/Vertex.html" title="class in org.apache.nemo.common.dag">Vertex</a> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>executionProperties</h4> |
| <pre><a href="org/apache/nemo/common/ir/executionproperty/ExecutionPropertyMap.html" title="class in org.apache.nemo.common.ir.executionproperty">ExecutionPropertyMap</a><<a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a>> executionProperties</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.LoopVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/LoopVertex.html" title="class in org.apache.nemo.common.ir.vertex">org.apache.nemo.common.ir.vertex.LoopVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>builder</h4> |
| <pre><a href="org/apache/nemo/common/dag/DAGBuilder.html" title="class in org.apache.nemo.common.dag">DAGBuilder</a><<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>> builder</pre> |
| </li> |
| <li class="blockList"> |
| <h4>compositeTransformFullName</h4> |
| <pre>java.lang.String compositeTransformFullName</pre> |
| </li> |
| <li class="blockList"> |
| <h4>dagIncomingEdges</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​java.util.Set<<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>>> dagIncomingEdges</pre> |
| </li> |
| <li class="blockList"> |
| <h4>dagOutgoingEdges</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​java.util.Set<<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>>> dagOutgoingEdges</pre> |
| </li> |
| <li class="blockList"> |
| <h4>duplicateEdgeGroupId</h4> |
| <pre>java.util.concurrent.atomic.AtomicInteger duplicateEdgeGroupId</pre> |
| </li> |
| <li class="blockList"> |
| <h4>edgeWithInternalVertexToEdgeWithLoop</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>,​<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>> edgeWithInternalVertexToEdgeWithLoop</pre> |
| </li> |
| <li class="blockList"> |
| <h4>edgeWithLoopToEdgeWithInternalVertex</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>,​<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>> edgeWithLoopToEdgeWithInternalVertex</pre> |
| </li> |
| <li class="blockList"> |
| <h4>iterativeIncomingEdges</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​java.util.Set<<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>>> iterativeIncomingEdges</pre> |
| </li> |
| <li class="blockList"> |
| <h4>maxNumberOfIterations</h4> |
| <pre>java.lang.Integer maxNumberOfIterations</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>nonIterativeIncomingEdges</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​java.util.Set<<a href="org/apache/nemo/common/ir/edge/IREdge.html" title="class in org.apache.nemo.common.ir.edge">IREdge</a>>> nonIterativeIncomingEdges</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.OperatorVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/OperatorVertex.html" title="class in org.apache.nemo.common.ir.vertex">org.apache.nemo.common.ir.vertex.OperatorVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>transform</h4> |
| <pre><a href="org/apache/nemo/common/ir/vertex/transform/Transform.html" title="interface in org.apache.nemo.common.ir.vertex.transform">Transform</a> transform</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.SourceVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/SourceVertex.html" title="class in org.apache.nemo.common.ir.vertex">org.apache.nemo.common.ir.vertex.SourceVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a> implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir.vertex.executionproperty</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ClonedSchedulingProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ClonedSchedulingProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><<a href="org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.CloneConf.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">ClonedSchedulingProperty.CloneConf</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ClonedSchedulingProperty.CloneConf"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ClonedSchedulingProperty.CloneConf.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ClonedSchedulingProperty.CloneConf</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>fractionToWaitFor</h4> |
| <pre>double fractionToWaitFor</pre> |
| </li> |
| <li class="blockList"> |
| <h4>medianTimeMultiplier</h4> |
| <pre>double medianTimeMultiplier</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>upFrontCloning</h4> |
| <pre>boolean upFrontCloning</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.EnableDynamicTaskSizingProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/EnableDynamicTaskSizingProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.EnableDynamicTaskSizingProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.lang.Boolean> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.IgnoreSchedulingTempDataReceiverProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/IgnoreSchedulingTempDataReceiverProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.IgnoreSchedulingTempDataReceiverProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.lang.Boolean> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.MessageIdVertexProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/MessageIdVertexProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.MessageIdVertexProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.lang.Integer> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ParallelismProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ParallelismProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ParallelismProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.lang.Integer> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ResourceAntiAffinityProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ResourceAntiAffinityProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ResourceAntiAffinityProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.util.HashSet<java.lang.Integer>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ResourceLambdaProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ResourceLambdaProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ResourceLambdaProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><<a href="org/apache/nemo/common/ir/vertex/executionproperty/ResourceLambdaProperty.Value.html" title="enum in org.apache.nemo.common.ir.vertex.executionproperty">ResourceLambdaProperty.Value</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ResourceLocalityProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ResourceLocalityProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ResourceLocalityProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.lang.Boolean> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ResourcePriorityProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ResourcePriorityProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ResourcePriorityProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.lang.String> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ResourceSiteProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ResourceSiteProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ResourceSiteProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.util.HashMap<java.lang.String,​java.lang.Integer>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ResourceSlotProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ResourceSlotProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ResourceSlotProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.lang.Boolean> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.executionproperty.ScheduleGroupProperty"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/executionproperty/ScheduleGroupProperty.html" title="class in org.apache.nemo.common.ir.vertex.executionproperty">org.apache.nemo.common.ir.vertex.executionproperty.ScheduleGroupProperty</a> extends <a href="org/apache/nemo/common/ir/executionproperty/VertexExecutionProperty.html" title="class in org.apache.nemo.common.ir.executionproperty">VertexExecutionProperty</a><java.lang.Integer> implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir.vertex.transform</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">org.apache.nemo.common.ir.vertex.transform.LatencymarkEmitTransform</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>outputCollector</h4> |
| <pre><a href="org/apache/nemo/common/ir/OutputCollector.html" title="interface in org.apache.nemo.common.ir">OutputCollector</a><<a href="org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.html" title="type parameter in LatencymarkEmitTransform">O</a>> outputCollector</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.transform.MessageAggregatorTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">org.apache.nemo.common.ir.vertex.transform.MessageAggregatorTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">NoWatermarkEmitTransform</a><<a href="org/apache/nemo/common/Pair.html" title="class in org.apache.nemo.common">Pair</a><<a href="org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.html" title="type parameter in MessageAggregatorTransform">K</a>,​<a href="org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.html" title="type parameter in MessageAggregatorTransform">V</a>>,​<a href="org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.html" title="type parameter in MessageAggregatorTransform">O</a>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>aggregator</h4> |
| <pre><a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageAggregatorVertex.MessageAggregatorFunction.html" title="interface in org.apache.nemo.common.ir.vertex.utility.runtimepass">MessageAggregatorVertex.MessageAggregatorFunction</a><<a href="org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.html" title="type parameter in MessageAggregatorTransform">K</a>,​<a href="org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.html" title="type parameter in MessageAggregatorTransform">V</a>,​<a href="org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.html" title="type parameter in MessageAggregatorTransform">O</a>> aggregator</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>initialStateSupplier</h4> |
| <pre><a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageAggregatorVertex.InitialStateSupplier.html" title="interface in org.apache.nemo.common.ir.vertex.utility.runtimepass">MessageAggregatorVertex.InitialStateSupplier</a><<a href="org/apache/nemo/common/ir/vertex/transform/MessageAggregatorTransform.html" title="type parameter in MessageAggregatorTransform">O</a>> initialStateSupplier</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.transform.MessageGeneratorTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">org.apache.nemo.common.ir.vertex.transform.MessageGeneratorTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">NoWatermarkEmitTransform</a><<a href="org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.html" title="type parameter in MessageGeneratorTransform">I</a>,​<a href="org/apache/nemo/common/Pair.html" title="class in org.apache.nemo.common">Pair</a><<a href="org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.html" title="type parameter in MessageGeneratorTransform">K</a>,​<a href="org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.html" title="type parameter in MessageGeneratorTransform">V</a>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>userFunction</h4> |
| <pre><a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.MessageGeneratorFunction.html" title="interface in org.apache.nemo.common.ir.vertex.utility.runtimepass">MessageGeneratorVertex.MessageGeneratorFunction</a><<a href="org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.html" title="type parameter in MessageGeneratorTransform">I</a>,​<a href="org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.html" title="type parameter in MessageGeneratorTransform">K</a>,​<a href="org/apache/nemo/common/ir/vertex/transform/MessageGeneratorTransform.html" title="type parameter in MessageGeneratorTransform">V</a>> userFunction</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">org.apache.nemo.common.ir.vertex.transform.NoWatermarkEmitTransform</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.transform.SignalTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/transform/SignalTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">org.apache.nemo.common.ir.vertex.transform.SignalTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">NoWatermarkEmitTransform</a><java.lang.Void,​java.lang.Void> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.transform.StreamTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/transform/StreamTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">org.apache.nemo.common.ir.vertex.transform.StreamTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">LatencymarkEmitTransform</a><<a href="org/apache/nemo/common/ir/vertex/transform/StreamTransform.html" title="type parameter in StreamTransform">T</a>,​<a href="org/apache/nemo/common/ir/vertex/transform/StreamTransform.html" title="type parameter in StreamTransform">T</a>> implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir.vertex.utility</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.utility.RelayVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/utility/RelayVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility">org.apache.nemo.common.ir.vertex.utility.RelayVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/OperatorVertex.html" title="class in org.apache.nemo.common.ir.vertex">OperatorVertex</a> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.utility.SamplingVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/utility/SamplingVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility">org.apache.nemo.common.ir.vertex.utility.SamplingVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>cloneOfOriginalVertex</h4> |
| <pre><a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a> cloneOfOriginalVertex</pre> |
| </li> |
| <li class="blockList"> |
| <h4>desiredSampleRate</h4> |
| <pre>float desiredSampleRate</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>originalVertex</h4> |
| <pre><a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a> originalVertex</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.utility.TaskSizeSplitterVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/utility/TaskSizeSplitterVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility">org.apache.nemo.common.ir.vertex.utility.TaskSizeSplitterVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/LoopVertex.html" title="class in org.apache.nemo.common.ir.vertex">LoopVertex</a> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>groupEndingVertices</h4> |
| <pre>java.util.Set<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>> groupEndingVertices</pre> |
| </li> |
| <li class="blockList"> |
| <h4>groupStartingVertices</h4> |
| <pre>java.util.Set<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>> groupStartingVertices</pre> |
| </li> |
| <li class="blockList"> |
| <h4>mapOfOriginalVertexToClone</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>,​<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>> mapOfOriginalVertexToClone</pre> |
| </li> |
| <li class="blockList"> |
| <h4>originalVertices</h4> |
| <pre>java.util.Set<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>> originalVertices</pre> |
| </li> |
| <li class="blockList"> |
| <h4>partitionerProperty</h4> |
| <pre>int partitionerProperty</pre> |
| </li> |
| <li class="blockList"> |
| <h4>testingTrial</h4> |
| <pre>org.apache.commons.lang.mutable.MutableInt testingTrial</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>verticesWithGroupOutgoingEdges</h4> |
| <pre>java.util.Set<<a href="org/apache/nemo/common/ir/vertex/IRVertex.html" title="class in org.apache.nemo.common.ir.vertex">IRVertex</a>> verticesWithGroupOutgoingEdges</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.ir.vertex.utility.runtimepass</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageAggregatorVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageAggregatorVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility.runtimepass">org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageAggregatorVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/OperatorVertex.html" title="class in org.apache.nemo.common.ir.vertex">OperatorVertex</a> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageGeneratorVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility.runtimepass">org.apache.nemo.common.ir.vertex.utility.runtimepass.MessageGeneratorVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/OperatorVertex.html" title="class in org.apache.nemo.common.ir.vertex">OperatorVertex</a> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>messageFunction</h4> |
| <pre><a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.MessageGeneratorFunction.html" title="interface in org.apache.nemo.common.ir.vertex.utility.runtimepass">MessageGeneratorVertex.MessageGeneratorFunction</a><<a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.html" title="type parameter in MessageGeneratorVertex">I</a>,​<a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.html" title="type parameter in MessageGeneratorVertex">K</a>,​<a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/MessageGeneratorVertex.html" title="type parameter in MessageGeneratorVertex">V</a>> messageFunction</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.ir.vertex.utility.runtimepass.SignalVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/ir/vertex/utility/runtimepass/SignalVertex.html" title="class in org.apache.nemo.common.ir.vertex.utility.runtimepass">org.apache.nemo.common.ir.vertex.utility.runtimepass.SignalVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/OperatorVertex.html" title="class in org.apache.nemo.common.ir.vertex">OperatorVertex</a> implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.punctuation</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.punctuation.LatencyMark"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/punctuation/LatencyMark.html" title="class in org.apache.nemo.common.punctuation">org.apache.nemo.common.punctuation.LatencyMark</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>createdTaskId</h4> |
| <pre>java.lang.String createdTaskId</pre> |
| </li> |
| <li class="blockList"> |
| <h4>createdTimestamp</h4> |
| <pre>long createdTimestamp</pre> |
| </li> |
| <li class="blockList"> |
| <h4>previousSentTimestamp</h4> |
| <pre>long previousSentTimestamp</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>previousTaskId</h4> |
| <pre>java.lang.String previousTaskId</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.punctuation.Watermark"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/punctuation/Watermark.html" title="class in org.apache.nemo.common.punctuation">org.apache.nemo.common.punctuation.Watermark</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>timestamp</h4> |
| <pre>long timestamp</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.common.test</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.common.test.EmptyComponents.EmptySourceVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/test/EmptyComponents.EmptySourceVertex.html" title="class in org.apache.nemo.common.test">org.apache.nemo.common.test.EmptyComponents.EmptySourceVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/SourceVertex.html" title="class in org.apache.nemo.common.ir.vertex">SourceVertex</a><<a href="org/apache/nemo/common/test/EmptyComponents.EmptySourceVertex.html" title="type parameter in EmptyComponents.EmptySourceVertex">T</a>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>minNumReadables</h4> |
| <pre>int minNumReadables</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>name</h4> |
| <pre>java.lang.String name</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.common.test.EmptyComponents.EmptyTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/common/test/EmptyComponents.EmptyTransform.html" title="class in org.apache.nemo.common.test">org.apache.nemo.common.test.EmptyComponents.EmptyTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">NoWatermarkEmitTransform</a><<a href="org/apache/nemo/common/test/EmptyComponents.EmptyTransform.html" title="type parameter in EmptyComponents.EmptyTransform">I</a>,​<a href="org/apache/nemo/common/test/EmptyComponents.EmptyTransform.html" title="type parameter in EmptyComponents.EmptyTransform">O</a>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>name</h4> |
| <pre>java.lang.String name</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.compiler.frontend.beam.coder</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.coder.BeamDecoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/coder/BeamDecoderFactory.html" title="class in org.apache.nemo.compiler.frontend.beam.coder">org.apache.nemo.compiler.frontend.beam.coder.BeamDecoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>beamCoder</h4> |
| <pre>org.apache.beam.sdk.coders.Coder<<a href="org/apache/nemo/compiler/frontend/beam/coder/BeamDecoderFactory.html" title="type parameter in BeamDecoderFactory">T</a>> beamCoder</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.coder.BeamEncoderFactory"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/coder/BeamEncoderFactory.html" title="class in org.apache.nemo.compiler.frontend.beam.coder">org.apache.nemo.compiler.frontend.beam.coder.BeamEncoderFactory</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>beamCoder</h4> |
| <pre>org.apache.beam.sdk.coders.Coder<<a href="org/apache/nemo/compiler/frontend/beam/coder/BeamEncoderFactory.html" title="type parameter in BeamEncoderFactory">T</a>> beamCoder</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.coder.SideInputCoder"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/coder/SideInputCoder.html" title="class in org.apache.nemo.compiler.frontend.beam.coder">org.apache.nemo.compiler.frontend.beam.coder.SideInputCoder</a> extends org.apache.beam.sdk.coders.StructuredCoder<<a href="org/apache/nemo/compiler/frontend/beam/SideInputElement.html" title="class in org.apache.nemo.compiler.frontend.beam">SideInputElement</a><<a href="org/apache/nemo/compiler/frontend/beam/coder/SideInputCoder.html" title="type parameter in SideInputCoder">T</a>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>valueCoder</h4> |
| <pre>org.apache.beam.sdk.coders.Coder<<a href="org/apache/nemo/compiler/frontend/beam/coder/SideInputCoder.html" title="type parameter in SideInputCoder">T</a>> valueCoder</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.compiler.frontend.beam.source</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.source.BeamBoundedSourceVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/source/BeamBoundedSourceVertex.html" title="class in org.apache.nemo.compiler.frontend.beam.source">org.apache.nemo.compiler.frontend.beam.source.BeamBoundedSourceVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/SourceVertex.html" title="class in org.apache.nemo.common.ir.vertex">SourceVertex</a><org.apache.beam.sdk.util.WindowedValue<<a href="org/apache/nemo/compiler/frontend/beam/source/BeamBoundedSourceVertex.html" title="type parameter in BeamBoundedSourceVertex">O</a>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>displayData</h4> |
| <pre>org.apache.beam.sdk.transforms.display.DisplayData displayData</pre> |
| </li> |
| <li class="blockList"> |
| <h4>estimatedSizeBytes</h4> |
| <pre>long estimatedSizeBytes</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>source</h4> |
| <pre>org.apache.beam.sdk.io.BoundedSource<<a href="org/apache/nemo/compiler/frontend/beam/source/BeamBoundedSourceVertex.html" title="type parameter in BeamBoundedSourceVertex">O</a>> source</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.source.BeamUnboundedSourceVertex"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/source/BeamUnboundedSourceVertex.html" title="class in org.apache.nemo.compiler.frontend.beam.source">org.apache.nemo.compiler.frontend.beam.source.BeamUnboundedSourceVertex</a> extends <a href="org/apache/nemo/common/ir/vertex/SourceVertex.html" title="class in org.apache.nemo.common.ir.vertex">SourceVertex</a><java.lang.Object> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>displayData</h4> |
| <pre>org.apache.beam.sdk.transforms.display.DisplayData displayData</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>source</h4> |
| <pre>org.apache.beam.sdk.io.UnboundedSource<<a href="org/apache/nemo/compiler/frontend/beam/source/BeamUnboundedSourceVertex.html" title="type parameter in BeamUnboundedSourceVertex">O</a>,​<a href="org/apache/nemo/compiler/frontend/beam/source/BeamUnboundedSourceVertex.html" title="type parameter in BeamUnboundedSourceVertex">M</a> extends org.apache.beam.sdk.io.UnboundedSource.CheckpointMark> source</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.compiler.frontend.beam.transform</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.AbstractDoFnTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.AbstractDoFnTransform</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>additionalOutputTags</h4> |
| <pre>java.util.List<org.apache.beam.sdk.values.TupleTag<?>> additionalOutputTags</pre> |
| </li> |
| <li class="blockList"> |
| <h4>bundleFinished</h4> |
| <pre>boolean bundleFinished</pre> |
| </li> |
| <li class="blockList"> |
| <h4>currBundleCount</h4> |
| <pre>long currBundleCount</pre> |
| </li> |
| <li class="blockList"> |
| <h4>displayData</h4> |
| <pre>org.apache.beam.sdk.transforms.display.DisplayData displayData</pre> |
| </li> |
| <li class="blockList"> |
| <h4>doFn</h4> |
| <pre>org.apache.beam.sdk.transforms.DoFn<<a href="org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.html" title="type parameter in AbstractDoFnTransform">InterT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.html" title="type parameter in AbstractDoFnTransform">OutputT</a>> doFn</pre> |
| </li> |
| <li class="blockList"> |
| <h4>doFnSchemaInformation</h4> |
| <pre>org.apache.beam.sdk.transforms.DoFnSchemaInformation doFnSchemaInformation</pre> |
| </li> |
| <li class="blockList"> |
| <h4>inputCoder</h4> |
| <pre>org.apache.beam.sdk.coders.Coder<<a href="org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.html" title="type parameter in AbstractDoFnTransform">InputT</a>> inputCoder</pre> |
| </li> |
| <li class="blockList"> |
| <h4>mainOutputTag</h4> |
| <pre>org.apache.beam.sdk.values.TupleTag<<a href="org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.html" title="type parameter in AbstractDoFnTransform">OutputT</a>> mainOutputTag</pre> |
| </li> |
| <li class="blockList"> |
| <h4>outputCoders</h4> |
| <pre>java.util.Map<org.apache.beam.sdk.values.TupleTag<?>,​org.apache.beam.sdk.coders.Coder<?>> outputCoders</pre> |
| </li> |
| <li class="blockList"> |
| <h4>prevBundleStartTime</h4> |
| <pre>long prevBundleStartTime</pre> |
| </li> |
| <li class="blockList"> |
| <h4>serializedOptions</h4> |
| <pre>org.apache.beam.runners.core.construction.SerializablePipelineOptions serializedOptions</pre> |
| </li> |
| <li class="blockList"> |
| <h4>sideInputMapping</h4> |
| <pre>java.util.Map<java.lang.String,​org.apache.beam.sdk.values.PCollectionView<?>> sideInputMapping</pre> |
| </li> |
| <li class="blockList"> |
| <h4>sideInputs</h4> |
| <pre>java.util.Map<java.lang.Integer,​org.apache.beam.sdk.values.PCollectionView<?>> sideInputs</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>windowingStrategy</h4> |
| <pre>org.apache.beam.sdk.values.WindowingStrategy<?,​?> windowingStrategy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.CombineFnFinalTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.CombineFnFinalTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">NoWatermarkEmitTransform</a><org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">A</a>>>,​org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">O</a>>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>combineFnRunner</h4> |
| <pre>org.apache.beam.runners.core.GlobalCombineFnRunner<?,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">A</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">O</a>> combineFnRunner</pre> |
| </li> |
| <li class="blockList"> |
| <h4>keyToAcuumulator</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">A</a>> keyToAcuumulator</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>outputCollector</h4> |
| <pre><a href="org/apache/nemo/common/ir/OutputCollector.html" title="interface in org.apache.nemo.common.ir">OutputCollector</a><org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnFinalTransform.html" title="type parameter in CombineFnFinalTransform">O</a>>>> outputCollector</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.CombineFnPartialTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.CombineFnPartialTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">NoWatermarkEmitTransform</a><org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">I</a>>>,​org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">A</a>>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>combineFnRunner</h4> |
| <pre>org.apache.beam.runners.core.GlobalCombineFnRunner<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">I</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">A</a>,​?> combineFnRunner</pre> |
| </li> |
| <li class="blockList"> |
| <h4>keyToAcuumulator</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">A</a>> keyToAcuumulator</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>outputCollector</h4> |
| <pre><a href="org/apache/nemo/common/ir/OutputCollector.html" title="interface in org.apache.nemo.common.ir">OutputCollector</a><org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CombineFnPartialTransform.html" title="type parameter in CombineFnPartialTransform">A</a>>>> outputCollector</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.CreateViewTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.CreateViewTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">LatencymarkEmitTransform</a><org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<?,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.html" title="type parameter in CreateViewTransform">I</a>>>,​org.apache.beam.sdk.util.WindowedValue<<a href="org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.html" title="type parameter in CreateViewTransform">O</a>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>currentOutputWatermark</h4> |
| <pre>long currentOutputWatermark</pre> |
| </li> |
| <li class="blockList"> |
| <h4>viewFn</h4> |
| <pre>org.apache.beam.sdk.transforms.ViewFn<org.apache.beam.sdk.transforms.Materializations.MultimapView<java.lang.Void,​?>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.html" title="type parameter in CreateViewTransform">O</a>> viewFn</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>windowListMap</h4> |
| <pre>java.util.Map<org.apache.beam.sdk.transforms.windowing.BoundedWindow,​java.util.List<<a href="org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.html" title="type parameter in CreateViewTransform">I</a>>> windowListMap</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.CreateViewTransform.MultiView"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.MultiView.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.CreateViewTransform.MultiView</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>iterable</h4> |
| <pre>java.lang.Iterable<<a href="org/apache/nemo/compiler/frontend/beam/transform/CreateViewTransform.MultiView.html" title="type parameter in CreateViewTransform.MultiView">T</a>> iterable</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.DoFnTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/DoFnTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.DoFnTransform</a> extends <a href="org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">AbstractDoFnTransform</a><<a href="org/apache/nemo/compiler/frontend/beam/transform/DoFnTransform.html" title="type parameter in DoFnTransform">InputT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/DoFnTransform.html" title="type parameter in DoFnTransform">InputT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/DoFnTransform.html" title="type parameter in DoFnTransform">OutputT</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.FinalCombineFn"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.FinalCombineFn</a> extends org.apache.beam.sdk.transforms.Combine.CombineFn<<a href="org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.html" title="type parameter in FinalCombineFn">AccumT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.html" title="type parameter in FinalCombineFn">AccumT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.html" title="type parameter in FinalCombineFn">Output</a>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>accumCoder</h4> |
| <pre>org.apache.beam.sdk.coders.Coder<<a href="org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.html" title="type parameter in FinalCombineFn">AccumT</a>> accumCoder</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>originFn</h4> |
| <pre>org.apache.beam.sdk.transforms.Combine.CombineFn<?,​<a href="org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.html" title="type parameter in FinalCombineFn">AccumT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/FinalCombineFn.html" title="type parameter in FinalCombineFn">Output</a>> originFn</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.FlattenTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.FlattenTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">LatencymarkEmitTransform</a><<a href="org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.html" title="type parameter in FlattenTransform">T</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/FlattenTransform.html" title="type parameter in FlattenTransform">T</a>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.GBKTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.GBKTransform</a> extends <a href="org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">AbstractDoFnTransform</a><org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">InputT</a>>,​org.apache.beam.runners.core.KeyedWorkItem<<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">InputT</a>>,​org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">OutputT</a>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>dataReceived</h4> |
| <pre>boolean dataReceived</pre> |
| </li> |
| <li class="blockList"> |
| <h4>inputWatermark</h4> |
| <pre><a href="org/apache/nemo/common/punctuation/Watermark.html" title="class in org.apache.nemo.common.punctuation">Watermark</a> inputWatermark</pre> |
| </li> |
| <li class="blockList"> |
| <h4>isPartialCombining</h4> |
| <pre>boolean isPartialCombining</pre> |
| </li> |
| <li class="blockList"> |
| <h4>keyOutputWatermarkMap</h4> |
| <pre>java.util.Map<<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">K</a>,​<a href="org/apache/nemo/common/punctuation/Watermark.html" title="class in org.apache.nemo.common.punctuation">Watermark</a>> keyOutputWatermarkMap</pre> |
| </li> |
| <li class="blockList"> |
| <h4>prevOutputWatermark</h4> |
| <pre><a href="org/apache/nemo/common/punctuation/Watermark.html" title="class in org.apache.nemo.common.punctuation">Watermark</a> prevOutputWatermark</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>reduceFn</h4> |
| <pre>org.apache.beam.runners.core.SystemReduceFn reduceFn</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.GBKTransform.GBKOutputCollector"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.GBKOutputCollector.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.GBKTransform.GBKOutputCollector</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>oc</h4> |
| <pre><a href="org/apache/nemo/common/ir/OutputCollector.html" title="interface in org.apache.nemo.common.ir">OutputCollector</a><org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">K</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/GBKTransform.html" title="type parameter in GBKTransform">OutputT</a>>>> oc</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.GroupByKeyTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/GroupByKeyTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.GroupByKeyTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/NoWatermarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">NoWatermarkEmitTransform</a><<a href="org/apache/nemo/compiler/frontend/beam/transform/GroupByKeyTransform.html" title="type parameter in GroupByKeyTransform">I</a>,​org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<java.lang.Object,​java.util.List>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>keyToValues</h4> |
| <pre>java.util.Map<java.lang.Object,​java.util.List> keyToValues</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>outputCollector</h4> |
| <pre><a href="org/apache/nemo/common/ir/OutputCollector.html" title="interface in org.apache.nemo.common.ir">OutputCollector</a><org.apache.beam.sdk.util.WindowedValue<org.apache.beam.sdk.values.KV<java.lang.Object,​java.util.List>>> outputCollector</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.LoopCompositeTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/LoopCompositeTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.LoopCompositeTransform</a> extends org.apache.beam.sdk.transforms.PTransform<<a href="org/apache/nemo/compiler/frontend/beam/transform/LoopCompositeTransform.html" title="type parameter in LoopCompositeTransform">inputT</a> extends org.apache.beam.sdk.values.PInput,​<a href="org/apache/nemo/compiler/frontend/beam/transform/LoopCompositeTransform.html" title="type parameter in LoopCompositeTransform">outputT</a> extends org.apache.beam.sdk.values.POutput> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.PartialCombineFn"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.PartialCombineFn</a> extends org.apache.beam.sdk.transforms.Combine.CombineFn<<a href="org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.html" title="type parameter in PartialCombineFn">InputT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.html" title="type parameter in PartialCombineFn">AccumT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.html" title="type parameter in PartialCombineFn">AccumT</a>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>accumCoder</h4> |
| <pre>org.apache.beam.sdk.coders.Coder<<a href="org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.html" title="type parameter in PartialCombineFn">AccumT</a>> accumCoder</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>originFn</h4> |
| <pre>org.apache.beam.sdk.transforms.Combine.CombineFn<<a href="org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.html" title="type parameter in PartialCombineFn">InputT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/PartialCombineFn.html" title="type parameter in PartialCombineFn">AccumT</a>,​?> originFn</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.PushBackDoFnTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.PushBackDoFnTransform</a> extends <a href="org/apache/nemo/compiler/frontend/beam/transform/AbstractDoFnTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">AbstractDoFnTransform</a><<a href="org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.html" title="type parameter in PushBackDoFnTransform">InputT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.html" title="type parameter in PushBackDoFnTransform">InputT</a>,​<a href="org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.html" title="type parameter in PushBackDoFnTransform">OutputT</a>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>curInputWatermark</h4> |
| <pre>long curInputWatermark</pre> |
| </li> |
| <li class="blockList"> |
| <h4>curOutputWatermark</h4> |
| <pre>long curOutputWatermark</pre> |
| </li> |
| <li class="blockList"> |
| <h4>curPushedBacks</h4> |
| <pre>java.util.List<org.apache.beam.sdk.util.WindowedValue<<a href="org/apache/nemo/compiler/frontend/beam/transform/PushBackDoFnTransform.html" title="type parameter in PushBackDoFnTransform">InputT</a>>> curPushedBacks</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>curPushedBackWatermark</h4> |
| <pre>long curPushedBackWatermark</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.SideInputTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.SideInputTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">LatencymarkEmitTransform</a><org.apache.beam.sdk.util.WindowedValue<<a href="org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.html" title="type parameter in SideInputTransform">T</a>>,​org.apache.beam.sdk.util.WindowedValue<<a href="org/apache/nemo/compiler/frontend/beam/SideInputElement.html" title="class in org.apache.nemo.compiler.frontend.beam">SideInputElement</a><<a href="org/apache/nemo/compiler/frontend/beam/transform/SideInputTransform.html" title="type parameter in SideInputTransform">T</a>>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>index</h4> |
| <pre>int index</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.beam.transform.WindowFnTransform"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/beam/transform/WindowFnTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">org.apache.nemo.compiler.frontend.beam.transform.WindowFnTransform</a> extends <a href="org/apache/nemo/common/ir/vertex/transform/LatencymarkEmitTransform.html" title="class in org.apache.nemo.common.ir.vertex.transform">LatencymarkEmitTransform</a><org.apache.beam.sdk.util.WindowedValue<<a href="org/apache/nemo/compiler/frontend/beam/transform/WindowFnTransform.html" title="type parameter in WindowFnTransform">T</a>>,​org.apache.beam.sdk.util.WindowedValue<<a href="org/apache/nemo/compiler/frontend/beam/transform/WindowFnTransform.html" title="type parameter in WindowFnTransform">T</a>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>displayData</h4> |
| <pre>org.apache.beam.sdk.transforms.display.DisplayData displayData</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>windowFn</h4> |
| <pre>org.apache.beam.sdk.transforms.windowing.WindowFn windowFn</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.compiler.frontend.spark</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.compiler.frontend.spark.SparkKeyExtractor"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/frontend/spark/SparkKeyExtractor.html" title="class in org.apache.nemo.compiler.frontend.spark">org.apache.nemo.compiler.frontend.spark.SparkKeyExtractor</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.compiler.optimizer.policy</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.BasicPullPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/BasicPullPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.BasicPullPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.BasicPushPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/BasicPushPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.BasicPushPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.ConditionalLargeShufflePolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/ConditionalLargeShufflePolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.ConditionalLargeShufflePolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.DataSkewPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/DataSkewPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.DataSkewPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.DefaultPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/DefaultPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.DefaultPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.DefaultPolicyWithSeparatePass"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/DefaultPolicyWithSeparatePass.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.DefaultPolicyWithSeparatePass</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.DisaggregationPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/DisaggregationPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.DisaggregationPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.DynamicTaskSizingPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/DynamicTaskSizingPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.DynamicTaskSizingPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.LambdaPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/LambdaPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.LambdaPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.LargeShufflePolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/LargeShufflePolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.LargeShufflePolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.PolicyImpl"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/PolicyImpl.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.PolicyImpl</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>compileTimePasses</h4> |
| <pre>java.util.List<<a href="org/apache/nemo/compiler/optimizer/pass/compiletime/CompileTimePass.html" title="class in org.apache.nemo.compiler.optimizer.pass.compiletime">CompileTimePass</a>> compileTimePasses</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>runTimePasses</h4> |
| <pre>java.util.Set<<a href="org/apache/nemo/compiler/optimizer/pass/runtime/RunTimePass.html" title="class in org.apache.nemo.compiler.optimizer.pass.runtime">RunTimePass</a><?>> runTimePasses</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.SamplingLargeShuffleSkewPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/SamplingLargeShuffleSkewPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.SamplingLargeShuffleSkewPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.StreamingPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/StreamingPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.StreamingPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.TestPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/TestPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.TestPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.TransientResourcePolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/TransientResourcePolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.TransientResourcePolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.compiler.optimizer.policy.XGBoostPolicy"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/compiler/optimizer/policy/XGBoostPolicy.html" title="class in org.apache.nemo.compiler.optimizer.policy">org.apache.nemo.compiler.optimizer.policy.XGBoostPolicy</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>policy</h4> |
| <pre><a href="org/apache/nemo/compiler/optimizer/policy/Policy.html" title="interface in org.apache.nemo.compiler.optimizer.policy">Policy</a> policy</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.examples.beam</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.AlternatingLeastSquare.CalculateNextMatrix"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/AlternatingLeastSquare.CalculateNextMatrix.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.AlternatingLeastSquare.CalculateNextMatrix</a> extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<java.lang.Integer,​org.apache.beam.sdk.values.KV<int[],​float[]>>,​org.apache.beam.sdk.values.KV<java.lang.Integer,​float[]>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>fixedMatrixView</h4> |
| <pre>org.apache.beam.sdk.values.PCollectionView<java.util.Map<java.lang.Integer,​float[]>> fixedMatrixView</pre> |
| </li> |
| <li class="blockList"> |
| <h4>lambda</h4> |
| <pre>double lambda</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>numFeatures</h4> |
| <pre>int numFeatures</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.AlternatingLeastSquare.CreateInitialMatrix"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/AlternatingLeastSquare.CreateInitialMatrix.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.AlternatingLeastSquare.CreateInitialMatrix</a> extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<java.lang.Integer,​org.apache.beam.sdk.values.KV<int[],​float[]>>,​org.apache.beam.sdk.values.KV<java.lang.Integer,​float[]>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>isDeterministic</h4> |
| <pre>boolean isDeterministic</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>numFeatures</h4> |
| <pre>int numFeatures</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.AlternatingLeastSquare.ParseLine"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/AlternatingLeastSquare.ParseLine.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.AlternatingLeastSquare.ParseLine</a> extends org.apache.beam.sdk.transforms.DoFn<java.lang.String,​org.apache.beam.sdk.values.KV<java.lang.Integer,​org.apache.beam.sdk.values.KV<int[],​float[]>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>isUserData</h4> |
| <pre>boolean isUserData</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.AlternatingLeastSquare.TrainingDataCombiner"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/AlternatingLeastSquare.TrainingDataCombiner.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.AlternatingLeastSquare.TrainingDataCombiner</a> extends org.apache.beam.sdk.transforms.Combine.CombineFn<org.apache.beam.sdk.values.KV<int[],​float[]>,​java.util.List<org.apache.beam.sdk.values.KV<int[],​float[]>>,​org.apache.beam.sdk.values.KV<int[],​float[]>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.AlternatingLeastSquare.UngroupSingleVectorList"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/AlternatingLeastSquare.UngroupSingleVectorList.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.AlternatingLeastSquare.UngroupSingleVectorList</a> extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<java.lang.Integer,​java.lang.Iterable<float[]>>,​org.apache.beam.sdk.values.KV<java.lang.Integer,​float[]>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.AlternatingLeastSquare.UpdateUserAndItemMatrix"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/AlternatingLeastSquare.UpdateUserAndItemMatrix.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.AlternatingLeastSquare.UpdateUserAndItemMatrix</a> extends <a href="org/apache/nemo/compiler/frontend/beam/transform/LoopCompositeTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">LoopCompositeTransform</a><org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Integer,​float[]>>,​org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Integer,​float[]>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>lambda</h4> |
| <pre>double lambda</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>numFeatures</h4> |
| <pre>java.lang.Integer numFeatures</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.AlternatingLeastSquareInefficient.UpdateUserAndItemMatrix</a> extends <a href="org/apache/nemo/compiler/frontend/beam/transform/LoopCompositeTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">LoopCompositeTransform</a><org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Integer,​float[]>>,​org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Integer,​float[]>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>lambda</h4> |
| <pre>java.lang.Double lambda</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>numFeatures</h4> |
| <pre>java.lang.Integer numFeatures</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.BeamWordCount.CountWords"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/BeamWordCount.CountWords.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.BeamWordCount.CountWords</a> extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,​org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.String,​java.lang.Long>>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.BeamWordCount.FormatAsTextFn"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/BeamWordCount.FormatAsTextFn.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.BeamWordCount.FormatAsTextFn</a> extends org.apache.beam.sdk.transforms.SimpleFunction<org.apache.beam.sdk.values.KV<java.lang.String,​java.lang.Long>,​java.lang.String> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.EDGARTop10BadRefererDocs.ValueComparator"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/EDGARTop10BadRefererDocs.ValueComparator.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.EDGARTop10BadRefererDocs.ValueComparator</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.EDGARTop10Documents.ValueComparator"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/EDGARTop10Documents.ValueComparator.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.EDGARTop10Documents.ValueComparator</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.FloatArrayCoder"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/FloatArrayCoder.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.FloatArrayCoder</a> extends org.apache.beam.sdk.coders.AtomicCoder<float[]> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.IntArrayCoder"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/IntArrayCoder.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.IntArrayCoder</a> extends org.apache.beam.sdk.coders.AtomicCoder<int[]> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.MultinomialLogisticRegression.ApplyGradient"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/MultinomialLogisticRegression.ApplyGradient.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.MultinomialLogisticRegression.ApplyGradient</a> extends org.apache.beam.sdk.transforms.DoFn<org.apache.beam.sdk.values.KV<java.lang.Integer,​org.apache.beam.sdk.transforms.join.CoGbkResult>,​org.apache.beam.sdk.values.KV<java.lang.Integer,​java.util.List<java.lang.Double>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>gradientTag</h4> |
| <pre>org.apache.beam.sdk.values.TupleTag<java.util.List<java.lang.Double>> gradientTag</pre> |
| </li> |
| <li class="blockList"> |
| <h4>iterationNum</h4> |
| <pre>java.lang.Integer iterationNum</pre> |
| </li> |
| <li class="blockList"> |
| <h4>modelTag</h4> |
| <pre>org.apache.beam.sdk.values.TupleTag<java.util.List<java.lang.Double>> modelTag</pre> |
| </li> |
| <li class="blockList"> |
| <h4>numClasses</h4> |
| <pre>java.lang.Integer numClasses</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>numFeatures</h4> |
| <pre>java.lang.Integer numFeatures</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.MultinomialLogisticRegression.CalculateGradient"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/MultinomialLogisticRegression.CalculateGradient.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.MultinomialLogisticRegression.CalculateGradient</a> extends org.apache.beam.sdk.transforms.DoFn<java.lang.String,​org.apache.beam.sdk.values.KV<java.lang.Integer,​java.util.List<java.lang.Double>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>gradients</h4> |
| <pre>java.util.List<java.util.List<java.lang.Double>> gradients</pre> |
| </li> |
| <li class="blockList"> |
| <h4>model</h4> |
| <pre>java.util.Map<java.lang.Integer,​java.util.List<java.lang.Double>> model</pre> |
| </li> |
| <li class="blockList"> |
| <h4>modelView</h4> |
| <pre>org.apache.beam.sdk.values.PCollectionView<java.util.Map<java.lang.Integer,​java.util.List<java.lang.Double>>> modelView</pre> |
| </li> |
| <li class="blockList"> |
| <h4>numClasses</h4> |
| <pre>java.lang.Integer numClasses</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>numFeatures</h4> |
| <pre>java.lang.Integer numFeatures</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.MultinomialLogisticRegression.CombineFunction"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/MultinomialLogisticRegression.CombineFunction.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.MultinomialLogisticRegression.CombineFunction</a> extends org.apache.beam.sdk.transforms.Combine.BinaryCombineFn<java.util.List<java.lang.Double>> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.MultinomialLogisticRegression.CombineFunctionForIterable"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/MultinomialLogisticRegression.CombineFunctionForIterable.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.MultinomialLogisticRegression.CombineFunctionForIterable</a> extends java.lang.Object implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.MultinomialLogisticRegression.UpdateModel"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/MultinomialLogisticRegression.UpdateModel.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.MultinomialLogisticRegression.UpdateModel</a> extends <a href="org/apache/nemo/compiler/frontend/beam/transform/LoopCompositeTransform.html" title="class in org.apache.nemo.compiler.frontend.beam.transform">LoopCompositeTransform</a><org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Integer,​java.util.List<java.lang.Double>>>,​org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Integer,​java.util.List<java.lang.Double>>>> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>iterationNum</h4> |
| <pre>java.lang.Integer iterationNum</pre> |
| </li> |
| <li class="blockList"> |
| <h4>numClasses</h4> |
| <pre>java.lang.Integer numClasses</pre> |
| </li> |
| <li class="blockList"> |
| <h4>numFeatures</h4> |
| <pre>java.lang.Integer numFeatures</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>readInput</h4> |
| <pre>org.apache.beam.sdk.values.PCollection<java.lang.String> readInput</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.ObjectCoderForString"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/ObjectCoderForString.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.ObjectCoderForString</a> extends org.apache.beam.sdk.coders.AtomicCoder<java.lang.Object> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>coder</h4> |
| <pre>org.apache.beam.sdk.coders.StringUtf8Coder coder</pre> |
| <div class="block">The actual coder.</div> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.WriteOneFilePerWindow"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/WriteOneFilePerWindow.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.WriteOneFilePerWindow</a> extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<java.lang.String>,​org.apache.beam.sdk.values.PDone> implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>filenamePrefix</h4> |
| <pre>java.lang.String filenamePrefix</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>numShards</h4> |
| <pre>java.lang.Integer numShards</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.beam.WriteOneFilePerWindow.PerWindowFiles"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/beam/WriteOneFilePerWindow.PerWindowFiles.html" title="class in org.apache.nemo.examples.beam">org.apache.nemo.examples.beam.WriteOneFilePerWindow.PerWindowFiles</a> extends org.apache.beam.sdk.io.FileBasedSink.FilenamePolicy implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockListLast"> |
| <h4>baseFilename</h4> |
| <pre>org.apache.beam.sdk.io.fs.ResourceId baseFilename</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.examples.spark.sql</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.examples.spark.sql.JavaSparkSQLExample.Person"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/spark/sql/JavaSparkSQLExample.Person.html" title="class in org.apache.nemo.examples.spark.sql">org.apache.nemo.examples.spark.sql.JavaSparkSQLExample.Person</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>age</h4> |
| <pre>int age</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>name</h4> |
| <pre>java.lang.String name</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.Average"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/spark/sql/JavaUserDefinedTypedAggregation.Average.html" title="class in org.apache.nemo.examples.spark.sql">org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.Average</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>count</h4> |
| <pre>long count</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>sum</h4> |
| <pre>long sum</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.Employee"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/spark/sql/JavaUserDefinedTypedAggregation.Employee.html" title="class in org.apache.nemo.examples.spark.sql">org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.Employee</a> extends java.lang.Object implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>name</h4> |
| <pre>java.lang.String name</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>salary</h4> |
| <pre>long salary</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.MyAverage"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/spark/sql/JavaUserDefinedTypedAggregation.MyAverage.html" title="class in org.apache.nemo.examples.spark.sql">org.apache.nemo.examples.spark.sql.JavaUserDefinedTypedAggregation.MyAverage</a> extends org.apache.spark.sql.expressions.Aggregator<<a href="org/apache/nemo/examples/spark/sql/JavaUserDefinedTypedAggregation.Employee.html" title="class in org.apache.nemo.examples.spark.sql">JavaUserDefinedTypedAggregation.Employee</a>,​<a href="org/apache/nemo/examples/spark/sql/JavaUserDefinedTypedAggregation.Average.html" title="class in org.apache.nemo.examples.spark.sql">JavaUserDefinedTypedAggregation.Average</a>,​java.lang.Double> implements Serializable</h3> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.examples.spark.sql.JavaUserDefinedUntypedAggregation.MyAverage"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/examples/spark/sql/JavaUserDefinedUntypedAggregation.MyAverage.html" title="class in org.apache.nemo.examples.spark.sql">org.apache.nemo.examples.spark.sql.JavaUserDefinedUntypedAggregation.MyAverage</a> extends org.apache.spark.sql.expressions.UserDefinedAggregateFunction implements Serializable</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>bufferSchema</h4> |
| <pre>org.apache.spark.sql.types.StructType bufferSchema</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>inputSchema</h4> |
| <pre>org.apache.spark.sql.types.StructType inputSchema</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </section> |
| </li> |
| <li class="blockList"> |
| <section role="region"> |
| <h2 title="Package">Package org.apache.nemo.runtime.common.comm</h2> |
| <ul class="blockList"> |
| <li class="blockList"><a id="org.apache.nemo.runtime.common.comm.ControlMessage.BlockLocationInfoMsg"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/runtime/common/comm/ControlMessage.BlockLocationInfoMsg.html" title="class in org.apache.nemo.runtime.common.comm">org.apache.nemo.runtime.common.comm.ControlMessage.BlockLocationInfoMsg</a> extends com.google.protobuf.GeneratedMessageV3 implements Serializable</h3> |
| <dl class="nameValue"> |
| <dt>serialVersionUID:</dt> |
| <dd>0L</dd> |
| </dl> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>bitField0_</h4> |
| <pre>int bitField0_</pre> |
| </li> |
| <li class="blockList"> |
| <h4>blockId_</h4> |
| <pre>java.lang.Object blockId_</pre> |
| </li> |
| <li class="blockList"> |
| <h4>memoizedIsInitialized</h4> |
| <pre>byte memoizedIsInitialized</pre> |
| </li> |
| <li class="blockList"> |
| <h4>ownerExecutorId_</h4> |
| <pre>java.lang.Object ownerExecutorId_</pre> |
| </li> |
| <li class="blockList"> |
| <h4>requestId_</h4> |
| <pre>long requestId_</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>state_</h4> |
| <pre>int state_</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a id="org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateChangedMsg"> |
| <!-- --> |
| </a> |
| <h3>Class <a href="org/apache/nemo/runtime/common/comm/ControlMessage.BlockStateChangedMsg.html" title="class in org.apache.nemo.runtime.common.comm">org.apache.nemo.runtime.common.comm.ControlMessage.BlockStateChangedMsg</a> extends com.google.protobuf.GeneratedMessageV3 implements Serializable</h3> |
| <dl class="nameValue"> |
| <dt>serialVersionUID:</dt> |
| <dd>0L</dd> |
| </dl> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h3>Serialized Fields</h3> |
| <ul class="blockList"> |
| <li class="blockList"> |
| <h4>bitField0_</h4> |
| <pre>int bitField0_</pre> |
| </li> |
| <li class="blockList"> |
| <h4>blockId_</h4> |
| <pre>java.lang.Object blockId_</pre> |
| </li> |
| <li class="blockList"> |
| <h4>executorId_</h4> |
| <pre>java.lang.Object executorId_</pre> |
| </li> |
| <li class="blockList"> |
| <h4>location_</h4> |
| <pre>java.lang.Object location_</pre> |
| </li> |
| <li class="blockList"> |
| <h4>memoizedIsInitialized</h4> |
| <pre>byte memoizedIsInitialized</pre> |
| </li> |
| <li class="blockListLast"> |
| <h4>state_</h4> |
| <pre>int state_</pre> |
| </li> |
| </ul> |
| </li> |
| </ul> |
| </li> |
| <li class="blockList"><a |
