public class QueryAddressRegister extends org.apache.flink.streaming.api.functions.sink.RichSinkFunction<InternalRow>
ServiceManager
.Constructor and Description |
---|
QueryAddressRegister(Table table) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
void |
invoke(InternalRow row,
org.apache.flink.streaming.api.functions.sink.SinkFunction.Context context) |
void |
open(org.apache.flink.configuration.Configuration parameters) |
getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public QueryAddressRegister(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 invoke(InternalRow row, org.apache.flink.streaming.api.functions.sink.SinkFunction.Context context)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.