org.apache.flink.connector.testutils.formats

Class SchemaTestUtils

java.lang.Object

org.apache.flink.connector.testutils.formats.SchemaTestUtils

public class SchemaTestUtils
extends Object

Test utilities for schemas.

Constructor Summary

Constructors

Constructor and Description
SchemaTestUtils()

Method Summary

Modifier and Type	Method and Description
static void	open(DeserializationSchema<?> schema) Opens the given schema with a mock initialization context.
static void	open(SerializationSchema<?> schema) Opens the given schema with a mock initialization context.

Methods inherited from class java.lang.Object

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

Constructor Detail

SchemaTestUtils

public SchemaTestUtils()

Method Detail

open

public static void open(SerializationSchema<?> schema)

Opens the given schema with a mock initialization context.

Parameters:

schema - to open

Throws:

RuntimeException - if the schema throws an exception

open

public static void open(DeserializationSchema<?> schema)

Opens the given schema with a mock initialization context.

Parameters:

schema - to open

Throws:

RuntimeException - if the schema throws an exception