public static class WordCount.FormatAsTextFn extends SimpleFunction<KV<java.lang.String,java.lang.Long>,java.lang.String>
Constructor and Description |
---|
FormatAsTextFn() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
apply(KV<java.lang.String,java.lang.Long> input)
Returns the result of invoking this function on the given input.
|
fromSerializableFunctionWithOutputType
fromProcessFunctionWithOutputType, getInputTypeDescriptor, getOutputTypeDescriptor, populateDisplayData
public java.lang.String apply(KV<java.lang.String,java.lang.Long> input)
ProcessFunction
apply
in interface ProcessFunction<KV<java.lang.String,java.lang.Long>,java.lang.String>
apply
in interface SerializableFunction<KV<java.lang.String,java.lang.Long>,java.lang.String>
apply
in class SimpleFunction<KV<java.lang.String,java.lang.Long>,java.lang.String>