public class ProxyKeySelector<T,KEY> extends Object implements org.apache.flink.api.java.functions.KeySelector<IterationRecord<T>,KEY>
Constructor and Description |
---|
ProxyKeySelector(org.apache.flink.api.java.functions.KeySelector<T,KEY> wrappedKeySelector) |
Modifier and Type | Method and Description |
---|---|
KEY |
getKey(IterationRecord<T> record) |
org.apache.flink.api.java.functions.KeySelector<T,KEY> |
getWrappedKeySelector() |
public org.apache.flink.api.java.functions.KeySelector<T,KEY> getWrappedKeySelector()
public KEY getKey(IterationRecord<T> record) throws Exception
getKey
in interface org.apache.flink.api.java.functions.KeySelector<IterationRecord<T>,KEY>
Exception
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.