Package org.apache.bookkeeper.client.impl

Class BookKeeperBuilderImpl

java.lang.Object

org.apache.bookkeeper.client.impl.BookKeeperBuilderImpl

All Implemented Interfaces:

BookKeeperBuilder

public class BookKeeperBuilderImpl
extends java.lang.Object
implements BookKeeperBuilder

Internal builder for BookKeeper client.

Since:

4.6

Constructor Summary

Constructors

Constructor	Description
BookKeeperBuilderImpl(ClientConfiguration conf)

Method Summary

Modifier and Type	Method	Description
BookKeeperBuilder	allocator(io.netty.buffer.ByteBufAllocator allocator)	Configure the bookkeeper client with a provided ByteBufAllocator.
BookKeeper	build()	Start and initialize a new BookKeeper client.
BookKeeperBuilder	dnsResolver(DNSToSwitchMapping dnsResolver)	Configure the bookkeeper client to use the provided dns resolver DNSToSwitchMapping.
BookKeeperBuilder	eventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)	Configure the bookkeeper client with a provided Netty EventLoopGroup.
BookKeeperBuilder	featureProvider(FeatureProvider featureProvider)	Configure the bookkeeper client to use a provided FeatureProvider.
BookKeeperBuilder	requestTimer(io.netty.util.HashedWheelTimer requeestTimer)	Configure the bookkeeper client to use a provided Netty HashedWheelTimer.
BookKeeperBuilder	statsLogger(StatsLogger statsLogger)	Configure the bookkeeper client with a provided StatsLogger.

Methods inherited from class java.lang.Object

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

Constructor Detail

BookKeeperBuilderImpl

public BookKeeperBuilderImpl(ClientConfiguration conf)

Method Detail

eventLoopGroup

public BookKeeperBuilder eventLoopGroup(io.netty.channel.EventLoopGroup eventLoopGroup)

Description copied from interface: BookKeeperBuilder

Configure the bookkeeper client with a provided Netty EventLoopGroup.

Specified by:

eventLoopGroup in interface BookKeeperBuilder

Parameters:

eventLoopGroup - an external EventLoopGroup to use by the bookkeeper client.

Returns:

client builder.

allocator

public BookKeeperBuilder allocator(io.netty.buffer.ByteBufAllocator allocator)

Description copied from interface: BookKeeperBuilder

Configure the bookkeeper client with a provided ByteBufAllocator.

Specified by:

allocator in interface BookKeeperBuilder

Parameters:

allocator - an external ByteBufAllocator to use by the bookkeeper client.

Returns:

client builder.

statsLogger

public BookKeeperBuilder statsLogger(StatsLogger statsLogger)

Description copied from interface: BookKeeperBuilder

Configure the bookkeeper client with a provided StatsLogger.

Specified by:

statsLogger in interface BookKeeperBuilder

Parameters:

statsLogger - an StatsLogger to use by the bookkeeper client to collect stats generated by the client.

Returns:

client builder.

dnsResolver

public BookKeeperBuilder dnsResolver(DNSToSwitchMapping dnsResolver)

Description copied from interface: BookKeeperBuilder

Configure the bookkeeper client to use the provided dns resolver DNSToSwitchMapping.

Specified by:

dnsResolver in interface BookKeeperBuilder

Parameters:

dnsResolver - dns resolver for placement policy to use for resolving network locations.

Returns:

client builder

requestTimer

public BookKeeperBuilder requestTimer(io.netty.util.HashedWheelTimer requeestTimer)

Description copied from interface: BookKeeperBuilder

Configure the bookkeeper client to use a provided Netty HashedWheelTimer.

Specified by:

requestTimer in interface BookKeeperBuilder

Parameters:

requeestTimer - request timer for client to manage timer related tasks.

Returns:

client builder

featureProvider

public BookKeeperBuilder featureProvider(FeatureProvider featureProvider)

Description copied from interface: BookKeeperBuilder

Configure the bookkeeper client to use a provided FeatureProvider.

Specified by:

featureProvider in interface BookKeeperBuilder

Parameters:

featureProvider - the feature provider

Returns:

client builder

build

public BookKeeper build()
                 throws java.lang.InterruptedException,
                        BKException,
                        java.io.IOException

Description copied from interface: BookKeeperBuilder

Start and initialize a new BookKeeper client.

Specified by:

build in interface BookKeeperBuilder

Returns:

the client

Throws:

java.lang.InterruptedException

BKException

java.io.IOException