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