Uses of Interface
org.apache.flink.api.common.serialization.DeserializationSchema.InitializationContext
-
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.api.common.serialization
Methods in org.apache.flink.api.common.serialization that return DeserializationSchema.InitializationContext Modifier and Type Method Description static DeserializationSchema.InitializationContext
RuntimeContextInitializationContextAdapters. deserializationAdapter(RuntimeContext runtimeContext)
static DeserializationSchema.InitializationContext
RuntimeContextInitializationContextAdapters. deserializationAdapter(RuntimeContext runtimeContext, Function<MetricGroup,MetricGroup> mapMetricGroup)
Methods in org.apache.flink.api.common.serialization with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description default void
DeserializationSchema. open(DeserializationSchema.InitializationContext context)
Initialization method for the schema. -
Uses of DeserializationSchema.InitializationContext in org.apache.flink.connector.testutils.formats
Classes in org.apache.flink.connector.testutils.formats that implement DeserializationSchema.InitializationContext Modifier and Type Class Description class
DummyInitializationContext
A dummy context for serialization schemas. -
Uses of DeserializationSchema.InitializationContext in org.apache.flink.connector.testutils.source.deserialization
Classes in org.apache.flink.connector.testutils.source.deserialization that implement DeserializationSchema.InitializationContext Modifier and Type Class Description class
TestingDeserializationContext
An implementation ofDeserializationSchema.InitializationContext
for test. -
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.avro
Methods in org.apache.flink.formats.avro with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
AvroRowDataDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.avro.registry.confluent.debezium
Methods in org.apache.flink.formats.avro.registry.confluent.debezium with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
DebeziumAvroDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.csv
Methods in org.apache.flink.formats.csv with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
CsvRowDataDeserializationSchema. open(DeserializationSchema.InitializationContext context)
void
CsvRowDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.json
Methods in org.apache.flink.formats.json with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
AbstractJsonDeserializationSchema. open(DeserializationSchema.InitializationContext context)
void
JsonDeserializationSchema. open(DeserializationSchema.InitializationContext context)
void
JsonRowDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.json.canal
Methods in org.apache.flink.formats.json.canal with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
CanalJsonDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.json.debezium
Methods in org.apache.flink.formats.json.debezium with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
DebeziumJsonDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.json.maxwell
Methods in org.apache.flink.formats.json.maxwell with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
MaxwellJsonDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.json.ogg
Methods in org.apache.flink.formats.json.ogg with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
OggJsonDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.protobuf.deserialize
Methods in org.apache.flink.formats.protobuf.deserialize with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
PbRowDataDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.formats.raw
Methods in org.apache.flink.formats.raw with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
RawFormatDeserializationSchema. open(DeserializationSchema.InitializationContext context)
-
Uses of DeserializationSchema.InitializationContext in org.apache.flink.table.examples.java.connectors
Methods in org.apache.flink.table.examples.java.connectors with parameters of type DeserializationSchema.InitializationContext Modifier and Type Method Description void
ChangelogCsvDeserializer. open(DeserializationSchema.InitializationContext context)
-