org.apache.paimon.flink

Class PaimonDataStreamScanProvider

java.lang.Object

org.apache.paimon.flink.PaimonDataStreamScanProvider

All Implemented Interfaces:

org.apache.flink.table.connector.ParallelismProvider, org.apache.flink.table.connector.source.DataStreamScanProvider, org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider

public class PaimonDataStreamScanProvider
extends Object
implements org.apache.flink.table.connector.source.DataStreamScanProvider

Paimon DataStreamScanProvider.

Constructor Summary

Constructors

Constructor and Description
PaimonDataStreamScanProvider(boolean isBounded, java.util.function.Function<org.apache.flink.streaming.api.environment.StreamExecutionEnvironment,org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>> producer)

Method Summary

Modifier and Type	Method and Description
boolean	isBounded()
org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>	produceDataStream(org.apache.flink.table.connector.ProviderContext context, org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.connector.source.DataStreamScanProvider

produceDataStream

Methods inherited from interface org.apache.flink.table.connector.ParallelismProvider

getParallelism

Constructor Detail

PaimonDataStreamScanProvider

public PaimonDataStreamScanProvider(boolean isBounded,
                                    java.util.function.Function<org.apache.flink.streaming.api.environment.StreamExecutionEnvironment,org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData>> producer)

Method Detail

produceDataStream

public org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> produceDataStream(org.apache.flink.table.connector.ProviderContext context,
                                                                                                                   org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env)

Specified by:

produceDataStream in interface org.apache.flink.table.connector.source.DataStreamScanProvider

isBounded

public boolean isBounded()

Specified by:

isBounded in interface org.apache.flink.table.connector.source.ScanTableSource.ScanRuntimeProvider