public class FlinkEngine extends EngineBase
LOGGER, storageConnectorApi
Modifier and Type | Method and Description |
---|---|
String |
addFile(String filePath) |
String |
getCertKey() |
static FlinkEngine |
getInstance() |
Map<String,String> |
getKafkaConfig(FeatureGroupBase featureGroup,
Map<String,String> writeOptions) |
String |
getKeyStorePath() |
String |
getTrustStorePath() |
org.apache.flink.streaming.api.datastream.DataStreamSink<?> |
writeDataStream(StreamFeatureGroup streamFeatureGroup,
org.apache.flink.streaming.api.datastream.DataStream<?> dataStream,
Map<String,String> writeOptions) |
public static FlinkEngine getInstance() throws FeatureStoreException
FeatureStoreException
public org.apache.flink.streaming.api.datastream.DataStreamSink<?> writeDataStream(StreamFeatureGroup streamFeatureGroup, org.apache.flink.streaming.api.datastream.DataStream<?> dataStream, Map<String,String> writeOptions) throws FeatureStoreException, IOException
FeatureStoreException
IOException
public String addFile(String filePath) throws IOException
addFile
in class EngineBase
IOException
public Map<String,String> getKafkaConfig(FeatureGroupBase featureGroup, Map<String,String> writeOptions) throws FeatureStoreException, IOException
getKafkaConfig
in class EngineBase
FeatureStoreException
IOException
public String getTrustStorePath()
public String getKeyStorePath()
public String getCertKey()
Copyright © 2024. All rights reserved.