public class CombinedAwareStreamingSourceFunction extends CombinedCompactorSourceFunction<org.apache.flink.api.java.tuple.Tuple2<Split,String>>
catalogLoader, ctx, databasePattern, excludingPattern, includingPattern, isRunning, isStreaming
Constructor and Description |
---|
CombinedAwareStreamingSourceFunction(Catalog.Loader catalogLoader,
Pattern includingPattern,
Pattern excludingPattern,
Pattern databasePattern,
long monitorInterval) |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> |
buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String name,
org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo,
Catalog.Loader catalogLoader,
Pattern includingPattern,
Pattern excludingPattern,
Pattern databasePattern,
long monitorInterval) |
void |
close() |
void |
open(org.apache.flink.configuration.Configuration parameters) |
cancel, run
getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public CombinedAwareStreamingSourceFunction(Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)
public void open(org.apache.flink.configuration.Configuration parameters) throws Exception
open
in interface org.apache.flink.api.common.functions.RichFunction
open
in class CombinedCompactorSourceFunction<org.apache.flink.api.java.tuple.Tuple2<Split,String>>
Exception
public static org.apache.flink.streaming.api.datastream.DataStream<org.apache.flink.table.data.RowData> buildSource(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String name, org.apache.flink.api.common.typeinfo.TypeInformation<org.apache.flink.table.data.RowData> typeInfo, Catalog.Loader catalogLoader, Pattern includingPattern, Pattern excludingPattern, Pattern databasePattern, long monitorInterval)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.