Package | Description |
---|---|
org.apache.storm.trident.planner | |
org.apache.storm.trident.spout | |
org.apache.storm.trident.topology |
Modifier and Type | Method and Description |
---|---|
void |
SubtopologyBolt.execute(BatchInfo batchInfo,
Tuple tuple) |
void |
SubtopologyBolt.finishBatch(BatchInfo batchInfo) |
Modifier and Type | Method and Description |
---|---|
void |
TridentSpoutExecutor.execute(BatchInfo info,
Tuple input) |
void |
TridentSpoutExecutor.finishBatch(BatchInfo batchInfo) |
Modifier and Type | Method and Description |
---|---|
void |
ITridentBatchBolt.execute(BatchInfo batchInfo,
Tuple tuple) |
void |
ITridentBatchBolt.finishBatch(BatchInfo batchInfo) |
Constructor and Description |
---|
TrackedBatch(BatchInfo info,
TridentBoltExecutor.CoordCondition condition,
int attemptId) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.