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 © 2020 The Apache Software Foundation. All rights reserved.