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 Description SchemaTestUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method 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.
-
-
-
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
-
-