org.apache.flink.streaming.runtime.io

Class RecordProcessorUtils

java.lang.Object

org.apache.flink.streaming.runtime.io.RecordProcessorUtils

public class RecordProcessorUtils
extends Object

Utility class for creating record processor for Input StreamOperator.

Method Summary

Modifier and Type	Method and Description
static <T> ThrowingConsumer<StreamRecord<T>,Exception>	getRecordProcessor(Input<T> input) Get record processor for Input, which will omit call of Input.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>) if it doesn't have key context.
static <T> ThrowingConsumer<StreamRecord<T>,Exception>	getRecordProcessor1(TwoInputStreamOperator<T,?,?> operator) Get record processor for the first input of TwoInputStreamOperator, which will omit call of StreamOperator.setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) if it doesn't have key context.
static <T> ThrowingConsumer<StreamRecord<T>,Exception>	getRecordProcessor2(TwoInputStreamOperator<?,T,?> operator) Get record processor for the second input of TwoInputStreamOperator, which will omit call of StreamOperator.setKeyContextElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) if it doesn't have key context.

Methods inherited from class java.lang.Object

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

Method Detail

getRecordProcessor

public static <T> ThrowingConsumer<StreamRecord<T>,Exception> getRecordProcessor(Input<T> input)

Get record processor for Input, which will omit call of Input.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>) if it doesn't have key context.

Parameters:

input - the Input

Returns:

the record processor

getRecordProcessor1

public static <T> ThrowingConsumer<StreamRecord<T>,Exception> getRecordProcessor1(TwoInputStreamOperator<T,?,?> operator)

Get record processor for the first input of TwoInputStreamOperator, which will omit call of StreamOperator.setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) if it doesn't have key context.

Parameters:

operator - the TwoInputStreamOperator

Returns:

the record processor

getRecordProcessor2

public static <T> ThrowingConsumer<StreamRecord<T>,Exception> getRecordProcessor2(TwoInputStreamOperator<?,T,?> operator)

Get record processor for the second input of TwoInputStreamOperator, which will omit call of StreamOperator.setKeyContextElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) if it doesn't have key context.

Parameters:

operator - the TwoInputStreamOperator

Returns:

the record processor