org.apache.flink.python.util

Class PythonConnectorUtils

java.lang.Object

org.apache.flink.python.util.PythonConnectorUtils

public class PythonConnectorUtils
extends Object

Utility class for using DataStream connectors in Python.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PythonConnectorUtils.FirstColumnTopicSelectorInvocationHandler The serializable InvocationHandler as the proxy for first column selector.
static class	PythonConnectorUtils.RowRowMapper A ProcessFunction that convert Row to RowData.
static class	PythonConnectorUtils.SecondColumnSerializationSchema<T> A SerializationSchema for Row that only serialize the second column using a wrapped SerializationSchema for T.

Constructor Summary

Constructors

Constructor and Description
PythonConnectorUtils()

Method Summary

Modifier and Type	Method and Description
static <T> T	createFirstColumnTopicSelector(Class<T> clazz) Creates a selector that returns the first column of a row, and cast it to clazz.

Methods inherited from class java.lang.Object

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

Constructor Detail

PythonConnectorUtils

public PythonConnectorUtils()

Method Detail

createFirstColumnTopicSelector

public static <T> T createFirstColumnTopicSelector(Class<T> clazz)

Creates a selector that returns the first column of a row, and cast it to clazz. T should be a sub interface of Function, which accepts a Row.

Type Parameters:

T - An interface

Parameters:

clazz - The desired selector class to cast to, e.g. TopicSelector.class for Kafka.