B C D F I O R S T U V W

B

build() - Method in class io.delta.flink.sink.RowDataDeltaSinkBuilder

Creates the actual sink.

build() - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Creates an instance of DeltaSource for a stream of RowData.

build() - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Creates an instance of DeltaSource for a stream of RowData.

C

columnNames(List<String>) - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Specifies a List of column names that should be read from Delta table.

columnNames(String...) - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Specifies an array of column names that should be read from Delta table.

columnNames(List<String>) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Specifies a List of column names that should be read from Delta table.

columnNames(String...) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Specifies an array of column names that should be read from Delta table.

D

DeltaSink<IN> - Class in io.delta.flink.sink

A unified sink that emits its input elements to file system files within buckets using Parquet format and commits those files to the DeltaLog.

DeltaSource<T> - Class in io.delta.flink.source

A unified data source that reads Delta table - both in batch and in streaming mode.

F

forBoundedRowData(Path, Configuration) - Static method in class io.delta.flink.source.DeltaSource

Creates an instance of Delta source builder for Bounded mode and for RowData elements.

forContinuousRowData(Path, Configuration) - Static method in class io.delta.flink.source.DeltaSource

Creates an instance of Delta source builder for Continuous mode and for RowData elements.

forRowData(Path, Configuration, RowType) - Static method in class io.delta.flink.sink.DeltaSink

Convenience method for creating a RowDataDeltaSinkBuilder for DeltaSink to a Delta table.

I

ignoreChanges(boolean) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets the "ignoreChanges" option.

ignoreDeletes(boolean) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets the "ignoreDeletes" option.

io.delta.flink.sink - package io.delta.flink.sink

io.delta.flink.source - package io.delta.flink.source

O

option(String, String) - Method in class io.delta.flink.sink.RowDataDeltaSinkBuilder

Sets a configuration option.

option(String, boolean) - Method in class io.delta.flink.sink.RowDataDeltaSinkBuilder

Sets a configuration option.

option(String, int) - Method in class io.delta.flink.sink.RowDataDeltaSinkBuilder

Sets a configuration option.

option(String, long) - Method in class io.delta.flink.sink.RowDataDeltaSinkBuilder

Sets a configuration option.

option(String, String) - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Sets a configuration option.

option(String, boolean) - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Sets a configuration option.

option(String, int) - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Sets a configuration option.

option(String, long) - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Sets a configuration option.

option(String, String) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets a configuration option.

option(String, boolean) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets a configuration option.

option(String, int) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets a configuration option.

option(String, long) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets a configuration option.

R

RowDataBoundedDeltaSourceBuilder - Class in io.delta.flink.source

A builder class for DeltaSource for a stream of RowData where the created source instance will operate in Bounded mode.

RowDataContinuousDeltaSourceBuilder - Class in io.delta.flink.source

A builder class for DeltaSource for a stream of RowData where the created source instance will operate in Continuous mode.

RowDataDeltaSinkBuilder - Class in io.delta.flink.sink

A builder class for DeltaSink for a stream of RowData.

RowDataDeltaSinkBuilder(Path, Configuration, RowType, boolean) - Constructor for class io.delta.flink.sink.RowDataDeltaSinkBuilder

Creates instance of the builder for DeltaSink.

S

startingTimestamp(String) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets value of "startingTimestamp" option.

startingVersion(String) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets value of "startingVersion" option.

startingVersion(long) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets value of "startingVersion" option.

T

timestampAsOf(String) - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Sets value of "timestampAsOf" option.

U

updateCheckIntervalMillis(long) - Method in class io.delta.flink.source.RowDataContinuousDeltaSourceBuilder

Sets the value for "updateCheckIntervalMillis" option.

V

versionAsOf(long) - Method in class io.delta.flink.source.RowDataBoundedDeltaSourceBuilder

Sets value of "versionAsOf" option.

W

withMergeSchema(boolean) - Method in class io.delta.flink.sink.RowDataDeltaSinkBuilder

Sets the sink's option whether we should try to update the Delta table's schema with the stream's schema in case of a mismatch during a commit to the DeltaLog.

withPartitionColumns(String...) - Method in class io.delta.flink.sink.RowDataDeltaSinkBuilder

Sets list of partition fields that will be extracted from incoming RowData events.

B C D F I O R S T U V W