org.apache.beam.runners.flink.adapter

Class FlinkKey

java.lang.Object

org.apache.beam.runners.flink.adapter.FlinkKey

All Implemented Interfaces:

java.io.Serializable, org.apache.flink.core.io.IOReadableWritable, org.apache.flink.types.Value

public class FlinkKey
extends java.lang.Object
implements org.apache.flink.types.Value

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FlinkKey()

Method Summary

Modifier and Type	Method and Description
boolean	equals(java.lang.Object obj)
<K> K	getKey(Coder<K> coder)
java.nio.ByteBuffer	getSerializedKey()
int	hashCode()
static FlinkKey	of(java.nio.ByteBuffer bytes)
static <K> FlinkKey	of(K key, Coder<K> coder)
void	read(org.apache.flink.core.memory.DataInputView in)
void	write(org.apache.flink.core.memory.DataOutputView out)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FlinkKey

public FlinkKey()

Method Detail

getSerializedKey

public java.nio.ByteBuffer getSerializedKey()

of

public static FlinkKey of(java.nio.ByteBuffer bytes)

of

public static <K> FlinkKey of(K key,
                              Coder<K> coder)

write

public void write(org.apache.flink.core.memory.DataOutputView out)
           throws java.io.IOException

Specified by:

write in interface org.apache.flink.core.io.IOReadableWritable

Throws:

java.io.IOException

read

public void read(org.apache.flink.core.memory.DataInputView in)
          throws java.io.IOException

Specified by:

read in interface org.apache.flink.core.io.IOReadableWritable

Throws:

java.io.IOException

getKey

public <K> K getKey(Coder<K> coder)

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(@Nullable
                      java.lang.Object obj)

Overrides:

equals in class java.lang.Object