Package | Description |
---|---|
org.apache.storm.coordination |
Modifier and Type | Method and Description |
---|---|
static CoordinatedBolt.IdStreamSpec |
CoordinatedBolt.IdStreamSpec.makeDetectSpec(String component,
String stream) |
Constructor and Description |
---|
CoordinatedBolt(IRichBolt delegate,
Map<String,CoordinatedBolt.SourceArgs> sourceArgs,
CoordinatedBolt.IdStreamSpec idStreamSpec) |
CoordinatedBolt(IRichBolt delegate,
String sourceComponent,
CoordinatedBolt.SourceArgs sourceArgs,
CoordinatedBolt.IdStreamSpec idStreamSpec) |
Copyright © 2023 The Apache Software Foundation. All rights reserved.