Modifier and Type | Method and Description |
---|---|
default void |
DeserializationSchema.open(DeserializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
void |
AvroRowDataDeserializationSchema.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
default void |
PubSubDeserializationSchema.open(DeserializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
default void |
KafkaDeserializationSchema.open(DeserializationSchema.InitializationContext context)
Initialization method for the schema.
|
Modifier and Type | Method and Description |
---|---|
void |
KafkaDeserializationSchemaWrapper.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
default void |
KinesisDeserializationSchema.open(DeserializationSchema.InitializationContext context)
Initialization method for the schema.
|
void |
KinesisDeserializationSchemaWrapper.open(DeserializationSchema.InitializationContext context) |
Modifier and Type | Method and Description |
---|---|
void |
ChangelogCsvDeserializer.open(DeserializationSchema.InitializationContext context) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.