IN1
- The type of the elements in the first input.IN2
- The type of the elements in the second input.OUT
- The type of the result elements.@Public public abstract class RichCrossFunction<IN1,IN2,OUT> extends AbstractRichFunction implements CrossFunction<IN1,IN2,OUT>
CrossFunction
. As a RichFunction
, it gives access to the
RuntimeContext
and provides setup and teardown
methods: RichFunction.open(org.apache.flink.configuration.Configuration)
and RichFunction.close()
.Constructor and Description |
---|
RichCrossFunction() |
Modifier and Type | Method and Description |
---|---|
abstract OUT |
cross(IN1 first,
IN2 second)
Cross UDF method.
|
close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public abstract OUT cross(IN1 first, IN2 second) throws Exception
CrossFunction
cross
in interface CrossFunction<IN1,IN2,OUT>
first
- Element from first input.second
- Element from the second input.Exception
- The function may throw Exceptions, which will cause the program to cancel,
and may trigger the recovery logic.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.