Hello everyone.
Hope this email finds you well.
I have a use case in Druid , hopefully I will get a solution

We use Kafka ingestions where all the events from Kafka will have 
EventTimeStamp, which I can use it for Timestampspec for Primary Timestamp.
But we need to store Secondary timestamp, which should the Ingestion time 
timestamp. ( Typically now () )

Is there a way to achieve this?

Tried with the following Transformspec.


  1.  Task failed with a reason as " org.apache.druid.java.util.common.RE: 
function 'currentTimestamp_now' is not defined."
          {
            "type": "expression",
            "name": "ingestionTime2",
            "expression": "currentTimestamp_now()"
          }


  1.  Task failed with a reason as " org.apache.druid.java.util.common.RE: 
function 'now' is not defined."
          {
            "type": "expression",
            "name": "ingestionTime2",
            "expression": "now()"
          }


  1.  Task failed with "org.apache.druid.java.util.common.RE: function 'now' is 
not defined."
        "transforms": [
          {
            "type": "expression",
            "name": "ingestionTime2",
            "expression": "timestamp(now())"
          }


  1.  With Javascript, the script submission failed with "add extension related 
to Javascript and related jars...". Here I have already added the 
"druid.javascript.enabled=true" in the common.runtime.properties.
{
  "type": "javascript",
  "name": "current_time",
  "function": "function() { return new Date().toISOString(); }"
}


Any ideas to solve this is highly appreciated.


Thanks
Kamalakar Mergu

Reply via email to