org.apache.flink.graph.asm.result

Class BinaryResultBase<K>

java.lang.Object

org.apache.flink.graph.asm.result.ResultBase

org.apache.flink.graph.asm.result.BinaryResultBase<K>

Type Parameters:

K - graph ID type

All Implemented Interfaces:

Serializable, BinaryResult<K>, TranslatableResult<K>

Direct Known Subclasses:

AdamicAdar.Result, JaccardIndex.Result

public abstract class BinaryResultBase<K>
extends ResultBase
implements BinaryResult<K>, TranslatableResult<K>

Base class for algorithm results for a pair of vertices.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.graph.asm.result.BinaryResult

BinaryResult.MirrorResult<T,RT extends BinaryResult<T>>

Constructor Summary

Constructors

Constructor and Description
BinaryResultBase()

Method Summary

Modifier and Type	Method and Description
K	getVertexId0() Get the first vertex ID.
K	getVertexId1() Get the second vertex ID.
void	setVertexId0(K vertexId0) Set the first vertex ID.
void	setVertexId1(K vertexId1) Set the second vertex ID.
<T> TranslatableResult<T>	translate(TranslateFunction<K,T> translator, TranslatableResult<T> reuse, org.apache.flink.util.Collector<TranslatableResult<T>> out) Output the result after transforming the vertex ID type.

Methods inherited from class org.apache.flink.graph.asm.result.ResultBase

toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

BinaryResultBase

public BinaryResultBase()

Method Detail

getVertexId0

public K getVertexId0()

Description copied from interface: BinaryResult

Get the first vertex ID.

Specified by:

getVertexId0 in interface BinaryResult<K>

Returns:

first vertex ID

setVertexId0

public void setVertexId0(K vertexId0)

Description copied from interface: BinaryResult

Set the first vertex ID.

Specified by:

setVertexId0 in interface BinaryResult<K>

Parameters:

vertexId0 - new vertex ID

getVertexId1

public K getVertexId1()

Description copied from interface: BinaryResult

Get the second vertex ID.

Specified by:

getVertexId1 in interface BinaryResult<K>

Returns:

second vertex ID

setVertexId1

public void setVertexId1(K vertexId1)

Description copied from interface: BinaryResult

Set the second vertex ID.

Specified by:

setVertexId1 in interface BinaryResult<K>

Parameters:

vertexId1 - new vertex ID

translate

public <T> TranslatableResult<T> translate(TranslateFunction<K,T> translator,
                                           TranslatableResult<T> reuse,
                                           org.apache.flink.util.Collector<TranslatableResult<T>> out)
                                    throws Exception

Description copied from interface: TranslatableResult

Output the result after transforming the vertex ID type.

Specified by:

translate in interface TranslatableResult<K>

Type Parameters:

T - ID output type

Parameters:

translator - translates type K to type T

reuse - reusable value

out - output collector

Returns:

reusable result

Throws:

Exception - on error