public interface TieredStorageNettyService
TieredStorageNettyService
is used to create writers and readers to netty.Modifier and Type | Method and Description |
---|---|
CompletableFuture<NettyConnectionReader> |
registerConsumer(TieredStoragePartitionId partitionId,
TieredStorageSubpartitionId subpartitionId)
TierConsumerAgent will register to TieredStorageNettyService and get a future
of NettyConnectionReader . |
void |
registerProducer(TieredStoragePartitionId partitionId,
NettyServiceProducer serviceProducer)
TierProducerAgent will provide a callback named NettyServiceProducer to
register to TieredStorageNettyService . |
void registerProducer(TieredStoragePartitionId partitionId, NettyServiceProducer serviceProducer)
TierProducerAgent
will provide a callback named NettyServiceProducer
to
register to TieredStorageNettyService
.partitionId
- partition id indicates the unique id of TieredResultPartition
.serviceProducer
- serviceProducer is a callback from TierProducerAgent
and used
to register a NettyConnectionWriter
and disconnect the netty connection.CompletableFuture<NettyConnectionReader> registerConsumer(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId)
TierConsumerAgent
will register to TieredStorageNettyService
and get a future
of NettyConnectionReader
.partitionId
- partition id indicates the unique id of TieredResultPartition
.subpartitionId
- subpartition id indicates the unique id of subpartition.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.