List of sink() Examples

Examples of sink()

cascading.scheme.Scheme.sink()

Method sink writes out the given {@link Tuple} found on {@link cascading.scheme.SinkCall#getOutgoingEntry()} tothe {@link cascading.scheme.SinkCall#getOutput()}.

This method may optionally throw a {@link cascading.tap.TapException} if it cannot process a particularinstance of data. If the payload Tuple is set on the TapException, that Tuple will be written to any applicable failure trap Tap. If not set, the incoming Tuple will be written instead. @param flowProcess of Process @param sinkCall of SinkCall

com.alibaba.otter.canal.sink.entry.group.GroupEventSink.sink()

java.nio.channels.Pipe.sink()

Returns this pipe's sink channel. @return This pipe's sink channel

org.apache.axis2.transport.nhttp.util.PipeImpl.sink()

org.apache.synapse.transport.nhttp.util.PipeImpl.sink()

ptolemy.graph.Edge.sink()

Return the sink node of the edge. @return The sink node.


        for (int i = 0; i < edges.length; i++) {
            Edge edge = (Edge) edges[i];


            if (edge.source().getWeight().equals(inputPort)
                    && edge.sink().getWeight().equals(outputPort)) {
                dependencyGraph.removeEdge(edge);
            }
        }
    }

                    .iterator();


            while (outputEdges.hasNext()) {
                Edge edge = (Edge) outputEdges.next();
                int sinkLabel = ((DirectedGraph) graph())
                        .nodeLabel(edge.sink());


                if (_allPairShortestPath[0][i][sinkLabel] > _edgeLengths
                        .toDouble(edge)) {
                    _allPairShortestPath[0][i][sinkLabel] = _edgeLengths
                            .toDouble(edge);

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.

Examples of sink()

Examples of ptolemy.graph.Edge.sink()

Examples of ptolemy.graph.Edge.sink()