SchemaTestUtils (Flink : Test utils : Connectors 2.0.0-cp1 API)

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(org.apache.flink.api.common.serialization.DeserializationSchema<?> schema)`	Opens the given schema with a mock initialization context.
`static void`	`open(org.apache.flink.api.common.serialization.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(org.apache.flink.api.common.serialization.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(org.apache.flink.api.common.serialization.DeserializationSchema<?> schema)
```
    Opens the given schema with a mock initialization context.
    
    Parameters:
    
    schema - to open
    
    Throws:
    
    RuntimeException - if the schema throws an exception