public class MemoryTierFactory extends Object implements TierFactory
TierFactory
for memory tier.Constructor and Description |
---|
MemoryTierFactory(int segmentSizeBytes,
int bufferSizeBytes,
int subpartitionMaxQueuedBuffers) |
Modifier and Type | Method and Description |
---|---|
TierConsumerAgent |
createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs,
TieredStorageNettyService nettyService)
Creates the consumer-side agent of a Tier.
|
TierMasterAgent |
createMasterAgent(TieredStorageResourceRegistry tieredStorageResourceRegistry)
Creates the master-side agent of a Tier.
|
TierProducerAgent |
createProducerAgent(int numSubpartitions,
TieredStoragePartitionId partitionID,
String dataFileBasePath,
boolean isBroadcastOnly,
TieredStorageMemoryManager memoryManager,
TieredStorageNettyService nettyService,
TieredStorageResourceRegistry resourceRegistry,
BatchShuffleReadBufferPool bufferPool,
ScheduledExecutorService ioExecutor,
int maxRequestedBuffers,
java.time.Duration bufferRequestTimeout)
Creates the producer-side agent of a Tier.
|
public MemoryTierFactory(int segmentSizeBytes, int bufferSizeBytes, int subpartitionMaxQueuedBuffers)
public TierMasterAgent createMasterAgent(TieredStorageResourceRegistry tieredStorageResourceRegistry)
TierFactory
createMasterAgent
in interface TierFactory
public TierProducerAgent createProducerAgent(int numSubpartitions, TieredStoragePartitionId partitionID, String dataFileBasePath, boolean isBroadcastOnly, TieredStorageMemoryManager memoryManager, TieredStorageNettyService nettyService, TieredStorageResourceRegistry resourceRegistry, BatchShuffleReadBufferPool bufferPool, ScheduledExecutorService ioExecutor, int maxRequestedBuffers, java.time.Duration bufferRequestTimeout)
TierFactory
createProducerAgent
in interface TierFactory
public TierConsumerAgent createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)
TierFactory
createConsumerAgent
in interface TierFactory
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.