public class BoltAckInfo extends Object
| Modifier and Type | Field and Description |
|---|---|
int |
ackingTaskId |
Long |
processLatencyMs |
Tuple |
tuple |
| Constructor and Description |
|---|
BoltAckInfo(Tuple tuple,
int ackingTaskId,
Long processLatencyMs) |
public Tuple tuple
public int ackingTaskId
public Long processLatencyMs
public void applyOn(TopologyContext topologyContext)
Copyright © 2021 The Apache Software Foundation. All rights reserved.