public class IgniteSink<IN>
extends org.apache.flink.streaming.api.functions.sink.RichSinkFunction<IN>
Constructor and Description |
---|
IgniteSink(String cacheName,
String igniteCfgFile)
Default IgniteSink constructor.
|
Modifier and Type | Method and Description |
---|---|
boolean |
getAllowOverwrite()
Obtains flag for enabling overwriting existing values in cache.
|
long |
getAutoFlushFrequency()
Obtains data flush frequency.
|
String |
getCacheName()
Gets the cache name.
|
String |
getIgniteConfigFile()
Gets Ignite configuration file.
|
void |
invoke(IN in)
Transfers data into grid.
|
void |
setAllowOverwrite(boolean allowOverwrite)
Enables overwriting existing values in cache.
|
void |
setAutoFlushFrequency(long autoFlushFrequency)
Specifies data flush frequency into the grid.
|
void |
start()
Starts streamer.
|
void |
stop()
Stops streamer.
|
public String getCacheName()
public String getIgniteConfigFile()
public long getAutoFlushFrequency()
public void setAutoFlushFrequency(long autoFlushFrequency)
autoFlushFrequency
- Flush frequency.public boolean getAllowOverwrite()
public void setAllowOverwrite(boolean allowOverwrite)
allowOverwrite
- Flag value.public void start() throws IgniteException
IgniteException
- If failed.public void stop() throws IgniteException
IgniteException
- If failed.public void invoke(IN in)
IgniteDataStreamer
.
Follow @ApacheIgnite
Ignite Fabric : ver. 2.1.0 Release Date : July 20 2017