public class QueryFileMonitor extends org.apache.flink.streaming.api.functions.source.RichSourceFunction<InternalRow>
Constructor and Description |
---|
QueryFileMonitor(Table table) |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.streaming.api.datastream.DataStream<InternalRow> |
build(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
Table table) |
void |
cancel() |
static ChannelComputer<InternalRow> |
createChannelComputer() |
void |
open(org.apache.flink.configuration.Configuration parameters) |
void |
run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<InternalRow> ctx) |
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public QueryFileMonitor(Table table)
public void open(org.apache.flink.configuration.Configuration parameters) throws Exception
open
in interface org.apache.flink.api.common.functions.RichFunction
open
in class org.apache.flink.api.common.functions.AbstractRichFunction
Exception
public void run(org.apache.flink.streaming.api.functions.source.SourceFunction.SourceContext<InternalRow> ctx) throws Exception
Exception
public void cancel()
public static org.apache.flink.streaming.api.datastream.DataStream<InternalRow> build(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, Table table)
public static ChannelComputer<InternalRow> createChannelComputer()
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.