org.wso2.ei.bpmn.analytics.udf

Class AnalyticsUDF

java.lang.Object

org.wso2.ei.bpmn.analytics.udf.AnalyticsUDF

public class AnalyticsUDF
extends Object

AnalyticsUDF class provides methods to compute summarized results for both process and task instances which published to the Data Analytics Server through the BPMN Data Publisher. The generated jar is embedded into the spark engine in DAS as a UDF so that we can invoke these methods as sql functions in spark console.

Constructor Summary

Constructors

Constructor and Description
AnalyticsUDF()

Method Summary

Modifier and Type	Method and Description
String	dateStr(String date) Get date as a string
long	getActMonth(String date) Get month from date as a long value
long	getActTime(String date) Get time as a long value
String	getProcessKey(String processName) Get process key
String	getProcessVersion(String processName) Get process version

Methods inherited from class java.lang.Object

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

Constructor Detail

AnalyticsUDF

public AnalyticsUDF()

Method Detail

dateStr

public String dateStr(String date)

Get date as a string

Parameters:

date - in the format of eg:Thu Sep 24 09:35:56 IST 2015

Returns:

date (eg: 2015-09-24)

getActTime

public long getActTime(String date)

Get time as a long value

Parameters:

date - in the format of eg:Thu Sep 24 09:35:56 IST 2015

Returns:

long value of the date. This needs to pass rest api search url in DAS

getProcessVersion

public String getProcessVersion(String processName)

Get process version

Parameters:

processName -

Returns:

version of the process

getProcessKey

public String getProcessKey(String processName)

Get process key

Parameters:

processName -

Returns:

key of the process

getActMonth

public long getActMonth(String date)

Get month from date as a long value

Parameters:

date - in the format of eg:Thu Sep 24 09:35:56 IST 2015

Returns:

long value of the initial date of the month