public class SpoutAckInfo extends Object
| Modifier and Type | Field and Description |
|---|---|
Long |
completeLatencyMs |
Object |
messageId |
int |
spoutTaskId |
| Constructor and Description |
|---|
SpoutAckInfo(Object messageId,
int spoutTaskId,
Long completeLatencyMs) |
public Object messageId
public int spoutTaskId
public Long completeLatencyMs
public void applyOn(TopologyContext topologyContext)
Copyright © 2022 The Apache Software Foundation. All rights reserved.