[jira] [Created] (GRIFFIN-247) Support pluggable sinks

["iyuriysoft (JIRA)" <ji...@apache.org>]

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)