public interface TierFactory
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 storageMemoryManager,
TieredStorageNettyService nettyService,
TieredStorageResourceRegistry resourceRegistry,
BatchShuffleReadBufferPool bufferPool,
ScheduledExecutorService ioExecutor,
int maxRequestedBuffers,
java.time.Duration bufferRequestTimeout)
Creates the producer-side agent of a Tier.
|
TierMasterAgent createMasterAgent(TieredStorageResourceRegistry tieredStorageResourceRegistry)
TierProducerAgent createProducerAgent(int numSubpartitions, TieredStoragePartitionId partitionID, String dataFileBasePath, boolean isBroadcastOnly, TieredStorageMemoryManager storageMemoryManager, TieredStorageNettyService nettyService, TieredStorageResourceRegistry resourceRegistry, BatchShuffleReadBufferPool bufferPool, ScheduledExecutorService ioExecutor, int maxRequestedBuffers, java.time.Duration bufferRequestTimeout)
TierConsumerAgent createConsumerAgent(List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs, TieredStorageNettyService nettyService)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.