Package org.apache.beam.runners.flink.adapter

Class FlinkKey

java.lang.Object

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

All Implemented Interfaces:

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

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

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlinkKey()

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
<K> K	getKey(Coder<K> coder)
ByteBuffer	getSerializedKey()
int	hashCode()
static FlinkKey	of(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 Details

FlinkKey

public FlinkKey()

Method Details

getSerializedKey

public ByteBuffer getSerializedKey()

of

public static FlinkKey of(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 IOException

Specified by:

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

Throws:

IOException

read

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

Specified by:

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

Throws:

IOException

getKey

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

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(@Nullable
 Object obj)

Overrides:

equals in class Object