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