Modifier and Type | Method and Description |
---|---|
static SerializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.serializationAdapter(RuntimeContext runtimeContext) |
static SerializationSchema.InitializationContext |
RuntimeContextInitializationContextAdapters.serializationAdapter(RuntimeContext runtimeContext,
java.util.function.Function<MetricGroup,MetricGroup> mapMetricGroup) |
Modifier and Type | Method and Description |
---|---|
default void |
SerializationSchema.open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
void |
AvroRowDataSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
DebeziumAvroSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
CanalJsonSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
DebeziumJsonSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
MaxwellJsonSerializationSchema.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
default void |
KafkaSerializationSchema.open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaSerializationSchemaWrapper.open(SerializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
default void |
KinesisSerializationSchema.open(SerializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
void |
RawFormatSerializationSchema.open(SerializationSchema.InitializationContext context) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.