Modifier and Type | Method and Description |
---|---|
SharedMemory |
SharedMemory.deepCopy() |
Modifier and Type | Method and Description |
---|---|
Map<String,SharedMemory> |
StormTopology.get_shared_memory() |
Modifier and Type | Method and Description |
---|---|
int |
SharedMemory.compareTo(SharedMemory other) |
boolean |
SharedMemory.equals(SharedMemory that) |
void |
StormTopology.put_to_shared_memory(String key,
SharedMemory val) |
Modifier and Type | Method and Description |
---|---|
void |
StormTopology.set_shared_memory(Map<String,SharedMemory> shared_memory) |
Constructor and Description |
---|
SharedMemory(SharedMemory other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
Set<SharedMemory> |
TopologyDetails.getSharedMemoryRequests(Collection<ExecutorDetails> executors)
Gets the total memory resource list for a set of tasks that is part of a topology.
|
Modifier and Type | Class and Description |
---|---|
class |
SharedOffHeapWithinNode
A request for a shared memory region off heap between workers on a node
|
class |
SharedOffHeapWithinWorker
A request for a shared memory region off heap, but only within a worker.
|
class |
SharedOnHeap
A request for a shared memory region on heap.
|
Modifier and Type | Method and Description |
---|---|
T |
TopologyBuilder.ConfigGetter.addSharedMemory(SharedMemory request) |
T |
ResourceDeclarer.addSharedMemory(SharedMemory request)
Add in request for shared memory that this component will use.
|
Modifier and Type | Method and Description |
---|---|
TridentState |
TridentState.addSharedMemory(SharedMemory request) |
Stream |
Stream.addSharedMemory(SharedMemory request) |
Modifier and Type | Method and Description |
---|---|
Set<SharedMemory> |
Group.getSharedMemory() |
Modifier and Type | Method and Description |
---|---|
Set<SharedMemory> |
ITridentResource.getSharedMemory() |
Set<SharedMemory> |
DefaultResourceDeclarer.getSharedMemory() |
Modifier and Type | Method and Description |
---|---|
T |
DefaultResourceDeclarer.addSharedMemory(SharedMemory request) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.