Package | Description |
---|---|
org.apache.storm.coordination |
Modifier and Type | Method and Description |
---|---|
static CoordinatedBolt.SourceArgs |
CoordinatedBolt.SourceArgs.all() |
static CoordinatedBolt.SourceArgs |
CoordinatedBolt.SourceArgs.single() |
Constructor and Description |
---|
CoordinatedBolt(IRichBolt delegate,
String sourceComponent,
CoordinatedBolt.SourceArgs sourceArgs,
CoordinatedBolt.IdStreamSpec idStreamSpec) |
Constructor and Description |
---|
CoordinatedBolt(IRichBolt delegate,
Map<String,CoordinatedBolt.SourceArgs> sourceArgs,
CoordinatedBolt.IdStreamSpec idStreamSpec) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.