Uses of Package
org.apache.flink.cdc.common.data
-
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.common.data Class Description ArrayData Base interface of an internal data structure representing data ofArrayType.ArrayData.ElementGetter Accessor for getting the elements of an array during runtime.DateData An internal data structure representing data ofDateType.DecimalData An internal data structure representing data ofDecimalType.GenericRecordData An internal data structure representing data ofRecordData.LocalZonedTimestampData An internal data structure representing data ofLocalZonedTimestampType.MapData Base interface of an internal data structure representing data ofMapType.RecordData ClassRecordDatadescribes the data of changed record (i.e.RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime.StringData An internal data structure representing data ofCharTypeandVarCharType.TimeData An internal data structure representing data ofTimeType.TimestampData An internal data structure representing data ofTimestampType.ZonedTimestampData An internal data structure representing data ofZonedTimestampType. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.common.data.binary Class Description ArrayData Base interface of an internal data structure representing data ofArrayType.DateData An internal data structure representing data ofDateType.DecimalData An internal data structure representing data ofDecimalType.LocalZonedTimestampData An internal data structure representing data ofLocalZonedTimestampType.MapData Base interface of an internal data structure representing data ofMapType.RecordData ClassRecordDatadescribes the data of changed record (i.e.StringData An internal data structure representing data ofCharTypeandVarCharType.TimeData An internal data structure representing data ofTimeType.TimestampData An internal data structure representing data ofTimestampType.ZonedTimestampData An internal data structure representing data ofZonedTimestampType. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.common.event Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.common.utils Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e.RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.doris.sink Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.elasticsearch.serializer Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.fluss.sink.row Class Description ArrayData Base interface of an internal data structure representing data ofArrayType.DecimalData An internal data structure representing data ofDecimalType.MapData Base interface of an internal data structure representing data ofMapType.RecordData ClassRecordDatadescribes the data of changed record (i.e. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.hudi.sink.util Class Description RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.iceberg.sink.utils Class Description RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.iceberg.sink.v2 Class Description RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.kafka.json Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.kafka.json.utils Class Description RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.maxcompute.utils Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e.RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.oceanbase.sink Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.paimon.sink.v2 Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e.RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.postgres.source Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.connectors.starrocks.sink Class Description RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.debezium.event Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.runtime.model Class Description ArrayData Base interface of an internal data structure representing data ofArrayType. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.runtime.operators.transform Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e.RecordData.FieldGetter Accessor for getting the field of a RecordData during runtime. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.runtime.serializer.data Class Description ArrayData Base interface of an internal data structure representing data ofArrayType.DateData An internal data structure representing data ofDateType.DecimalData An internal data structure representing data ofDecimalType.GenericRecordData An internal data structure representing data ofRecordData.LocalZonedTimestampData An internal data structure representing data ofLocalZonedTimestampType.MapData Base interface of an internal data structure representing data ofMapType.RecordData ClassRecordDatadescribes the data of changed record (i.e.StringData An internal data structure representing data ofCharTypeandVarCharType.TimeData An internal data structure representing data ofTimeType.TimestampData An internal data structure representing data ofTimestampType.ZonedTimestampData An internal data structure representing data ofZonedTimestampType. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.runtime.serializer.data.util Class Description MapData Base interface of an internal data structure representing data ofMapType. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.runtime.serializer.data.writer Class Description ArrayData Base interface of an internal data structure representing data ofArrayType.DateData An internal data structure representing data ofDateType.DecimalData An internal data structure representing data ofDecimalType.LocalZonedTimestampData An internal data structure representing data ofLocalZonedTimestampType.MapData Base interface of an internal data structure representing data ofMapType.RecordData ClassRecordDatadescribes the data of changed record (i.e.StringData An internal data structure representing data ofCharTypeandVarCharType.TimeData An internal data structure representing data ofTimeType.TimestampData An internal data structure representing data ofTimestampType.ZonedTimestampData An internal data structure representing data ofZonedTimestampType. -
Classes in org.apache.flink.cdc.common.data used by org.apache.flink.cdc.runtime.typeutils Class Description RecordData ClassRecordDatadescribes the data of changed record (i.e.