iyuriysoft created GRIFFIN-247:
----------------------------------
Summary: Support pluggable sinks
Key: GRIFFIN-247
URL: https://issues.apache.org/jira/browse/GRIFFIN-247
Project: Griffin
Issue Type: Improvement
Reporter: iyuriysoft
Provide ability to use custom pluggable sinks.
To use it we need to add new sink type CUSTOM
{code:java}
// saving in local files
"sinks": [
{
"type": "CUSTOM",
"config": {
"class": "com.example.griffin.sinks.LocalFileSink",
"path": "/Users/Shared"
}
},
{code}
Contract:
The class should be a subclass of *Sink*
{code:java}
case class LocalFileSink(ctx: SinkContext) extends Sink {
...
...
}{code}
Signatures of context object:
{code:java}
case class SinkContext(config: Map[String, Any], metricName: String, timeStamp:
Long, block: Boolean)
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
