com.logicalclocks.hsfs.flink.engine

Class FlinkEngine

java.lang.Object

com.logicalclocks.hsfs.flink.engine.FlinkEngine

public class FlinkEngine
extends Object

Method Summary

Modifier and Type	Method and Description
String	getCertKey()
static FlinkEngine	getInstance()
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)

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static FlinkEngine getInstance()
                               throws FeatureStoreException

Throws:

FeatureStoreException

writeDataStream

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

Throws:

FeatureStoreException

IOException

getTrustStorePath

public String getTrustStorePath()

getKeyStorePath

public String getKeyStorePath()

getCertKey

public String getCertKey()