public class EsSinkStatus extends Object implements scala.Product, scala.Serializable
param: taskId of the task that wrote this data param: execTimeMillis when the data was written param: resource which resource the data was written to, patterns included param: records number of records written to resource
| Constructor and Description |
|---|
EsSinkStatus(int taskId,
long execTimeMillis,
String resource,
long records) |
| Modifier and Type | Method and Description |
|---|---|
abstract static R |
apply(T1 v1,
T2 v2,
T3 v3,
T4 v4) |
long |
execTimeMillis() |
long |
records() |
String |
resource() |
int |
taskId() |
static String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitpublic EsSinkStatus(int taskId,
long execTimeMillis,
String resource,
long records)