public static class CoordinatedBolt.IdStreamSpec extends Object implements Serializable
Modifier | Constructor and Description |
---|---|
protected |
IdStreamSpec(String component,
String stream) |
Modifier and Type | Method and Description |
---|---|
GlobalStreamId |
getGlobalStreamId() |
static CoordinatedBolt.IdStreamSpec |
makeDetectSpec(String component,
String stream) |
public static CoordinatedBolt.IdStreamSpec makeDetectSpec(String component, String stream)
public GlobalStreamId getGlobalStreamId()
Copyright © 2023 The Apache Software Foundation. All rights reserved.