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