Package org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote

Class RemoteTierProducerAgent

java.lang.Object

org.apache.flink.runtime.io.network.partition.hybrid.tiered.tier.remote.RemoteTierProducerAgent

All Implemented Interfaces:

AutoCloseable, TierProducerAgent

public class RemoteTierProducerAgent
extends Object
implements TierProducerAgent

The implementation of TierProducerAgent for the remote tier.

Method Summary

Modifier and Type	Method	Description
void	close()	Close the agent.
boolean	tryStartNewSegment(TieredStorageSubpartitionId subpartitionId, int segmentId)	Try to start a new segment in the Tier.
boolean	tryWrite(TieredStorageSubpartitionId subpartitionId, Buffer buffer, Object bufferOwner)	Writes the finished Buffer to the consumer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

tryStartNewSegment

public boolean tryStartNewSegment(TieredStorageSubpartitionId subpartitionId,
                                  int segmentId)

Description copied from interface: TierProducerAgent

Try to start a new segment in the Tier.

Specified by:

tryStartNewSegment in interface TierProducerAgent

Parameters:

subpartitionId - subpartition id that the new segment belongs to

segmentId - id of the new segment

Returns:

true if the segment can be started, false otherwise.

tryWrite

public boolean tryWrite(TieredStorageSubpartitionId subpartitionId,
                        Buffer buffer,
                        Object bufferOwner)

Description copied from interface: TierProducerAgent

Writes the finished Buffer to the consumer.

Note that the method is successfully executed (without throwing any exception), the buffer should be released by the caller, otherwise the tier should be responsible to recycle the buffer.

Specified by:

tryWrite in interface TierProducerAgent

Parameters:

subpartitionId - the subpartition id that the buffer is writing to

buffer - the writing buffer

bufferOwner - the current owner of this writing buffer

Returns:

return true if the buffer is written successfully, return false if the current segment can not store this buffer and the current segment is finished. When returning false, the agent should try start a new segment before writing the buffer.

close

public void close()

Description copied from interface: TierProducerAgent

Close the agent.

Note this only releases resources directly hold by the agent, which excludes resources managed by the resource registry.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface TierProducerAgent