Package org.apache.flink.cdc.connectors.oracle.source

Class OracleSourceBuilder.OracleIncrementalSource<T>

java.lang.Object

org.apache.flink.cdc.connectors.base.source.IncrementalSource<T,JdbcSourceConfig>

org.apache.flink.cdc.connectors.base.source.jdbc.JdbcIncrementalSource<T>

org.apache.flink.cdc.connectors.oracle.source.OracleSourceBuilder.OracleIncrementalSource<T>

All Implemented Interfaces:

Serializable, org.apache.flink.api.connector.source.Source<T,SourceSplitBase,PendingSplitsState>, org.apache.flink.api.connector.source.SourceReaderFactory<T,SourceSplitBase>, org.apache.flink.api.java.typeutils.ResultTypeQueryable<T>

Direct Known Subclasses:

OracleTableSourceReader

Enclosing class:

OracleSourceBuilder<T>

public static class OracleSourceBuilder.OracleIncrementalSource<T>
extends JdbcIncrementalSource<T>

The JdbcIncrementalSource implementation for Oracle.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.base.source.IncrementalSource

configFactory, dataSourceDialect, deserializationSchema, offsetFactory, snapshotHooks, sourceSplitSerializer

Constructor Summary

Constructors

Constructor	Description
OracleIncrementalSource(OracleSourceConfigFactory configFactory, DebeziumDeserializationSchema<T> deserializationSchema, RedoLogOffsetFactory offsetFactory, OracleDialect dataSourceDialect)

Method Summary

Modifier and Type	Method	Description
static <T> OracleSourceBuilder<T>	builder()

Methods inherited from class org.apache.flink.cdc.connectors.base.source.IncrementalSource

createEnumerator, createReader, createRecordEmitter, getBoundedness, getEnumeratorCheckpointSerializer, getProducedType, getSplitSerializer, restoreEnumerator, setSnapshotHooks

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OracleIncrementalSource

public OracleIncrementalSource(OracleSourceConfigFactory configFactory,
                               DebeziumDeserializationSchema<T> deserializationSchema,
                               RedoLogOffsetFactory offsetFactory,
                               OracleDialect dataSourceDialect)

Method Detail

builder

public static <T> OracleSourceBuilder<T> builder()