Package com.codedstreams.otterstreams.sql.connector

Class MLInferenceDynamicTableSource

java.lang.Object

com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableSource

All Implemented Interfaces:

org.apache.flink.table.connector.source.DynamicTableSource, org.apache.flink.table.connector.source.LookupTableSource

public class MLInferenceDynamicTableSource
extends Object
implements org.apache.flink.table.connector.source.LookupTableSource

Dynamic table source for ML inference with lookup support.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.DynamicTableSource

org.apache.flink.table.connector.source.DynamicTableSource.Context, org.apache.flink.table.connector.source.DynamicTableSource.DataStructureConverter

Nested classes/interfaces inherited from interface org.apache.flink.table.connector.source.LookupTableSource

org.apache.flink.table.connector.source.LookupTableSource.LookupContext, org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider

Constructor Summary

Constructors

Constructor	Description
MLInferenceDynamicTableSource(SqlInferenceConfig config, org.apache.flink.table.types.DataType producedDataType)

Method Summary

Modifier and Type	Method	Description
String	asSummaryString()
org.apache.flink.table.connector.source.DynamicTableSource	copy()
org.apache.flink.table.connector.ChangelogMode	getChangelogMode()
org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider	getLookupRuntimeProvider(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context)

Methods inherited from class java.lang.Object

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

Constructor Detail

MLInferenceDynamicTableSource

public MLInferenceDynamicTableSource(SqlInferenceConfig config,
                                     org.apache.flink.table.types.DataType producedDataType)

Method Detail

getLookupRuntimeProvider

public org.apache.flink.table.connector.source.LookupTableSource.LookupRuntimeProvider getLookupRuntimeProvider(org.apache.flink.table.connector.source.LookupTableSource.LookupContext context)

Specified by:

getLookupRuntimeProvider in interface org.apache.flink.table.connector.source.LookupTableSource

getChangelogMode

public org.apache.flink.table.connector.ChangelogMode getChangelogMode()

copy

public org.apache.flink.table.connector.source.DynamicTableSource copy()

Specified by:

copy in interface org.apache.flink.table.connector.source.DynamicTableSource

asSummaryString

public String asSummaryString()

Specified by:

asSummaryString in interface org.apache.flink.table.connector.source.DynamicTableSource