| Package | Description | 
|---|---|
| org.apache.storm.messaging | |
| org.apache.storm.serialization | |
| org.apache.storm.task | |
| org.apache.storm.tuple | 
| Constructor and Description | 
|---|
DeserializingConnectionCallback(Map<String,Object> conf,
                               GeneralTopologyContext context,
                               WorkerState.ILocalTransferCallback callback)  | 
| Constructor and Description | 
|---|
KryoTupleDeserializer(Map<String,Object> conf,
                     GeneralTopologyContext context)  | 
KryoTupleSerializer(Map<String,Object> conf,
                   GeneralTopologyContext context)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TopologyContext
A  
TopologyContext is given to bolts and spouts in their prepare() and open() methods, respectively. | 
class  | 
WorkerTopologyContext  | 
| Modifier and Type | Method and Description | 
|---|---|
GeneralTopologyContext | 
TupleImpl.getContext()  | 
GeneralTopologyContext | 
Tuple.getContext()
Gets the topology context associated with the tuple 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static AddressedTuple | 
AddressedTuple.createFlushTuple(GeneralTopologyContext workerTopologyContext)  | 
| Constructor and Description | 
|---|
TupleImpl(GeneralTopologyContext context,
         List<Object> values,
         String srcComponent,
         int taskId,
         String streamId)  | 
TupleImpl(GeneralTopologyContext context,
         List<Object> values,
         String srcComponent,
         int taskId,
         String streamId,
         MessageId id)  | 
Copyright © 2019 The Apache Software Foundation. All rights reserved.