IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码

七十九、HBase异步客户端

IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码

HBase异步客户端

它是HBase 2.0中引入的新API,旨在提供异步访问HBase的能力。

您可以从ConnectionFactory获取AsyncConnectionfrom,然后从中获取一个异步表实例来访问HBase。完成后关闭AsyncConnection实例(通常在程序退出时)。

对于异步表,大多数方法与旧Table界面有相同的含义,预期返回值通常包含CompletableFuture。我们在这里没有任何缓冲区,所以没有关于异步表的close方法,你不需要关闭它。它是线程安全的。

扫描(scan)有以下几个不同之处:

  • getScanner方法可以返回一个ResultScanner。你可以以旧的方式使用它,它的工作原理与旧的ClientAsyncPrefetchScanner一样。
  • scanAll方法会一次返回所有的结果。它旨在为小扫描提供一种更简单的方法,您通常希望一次获得全部结果。
  • 观察者(Observer)模式。有一种扫描方法接受ScanResultConsumer作为参数。它会将结果传递给消费者。

注意,AsyncTable接口是模板化的。模板参数指定扫描使用的ScanResultConsumerBase类型,这意味着观察者模式扫描API是不同的。这两种类型的扫描用户是 ScanResultConsumer和AdvancedScanResultConsumer。

ScanResultConsumer需要一个单独的线程池,用于执行向返回的CompletableFuture注册的回调。由于使用单独的线程池可以释放RPC线程,所以回调可以自由地执行任何操作。如果回调不快,或者有疑问,请使用此功能。

AdvancedScanResultConsumer在框架线程内执行回调。不允许在回调中执行耗时的工作,否则它可能会阻塞框架线程并导致非常糟糕的性能影响。顾名思义,它是为想要编写高性能代码的高级用户而设计的。

文章永久链接:https://tech.souyunku.com/?p=12552

干货推荐


Warning: A non-numeric value encountered in /data/wangzhan/tech.souyunku.com.wp/wp-content/themes/dux/functions-theme.php on line 1154
赞(66) 打赏



未经允许不得转载:搜云库技术团队 » 七十九、HBase异步客户端

IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码
IDEA2023.1.3破解,IDEA破解,IDEA 2023.1破解,最新IDEA激活码

评论 抢沙发

大前端WP主题 更专业 更方便

联系我们联系我们

觉得文章有用就打赏一下文章作者

微信扫一扫打赏

微信扫一扫打赏


Fatal error: Uncaught Exception: Cache directory not writable. Comet Cache needs this directory please: `/data/wangzhan/tech.souyunku.com.wp/wp-content/cache/comet-cache/cache/https/tech-souyunku-com/index.q`. Set permissions to `755` or higher; `777` might be needed in some cases. in /data/wangzhan/tech.souyunku.com.wp/wp-content/plugins/comet-cache/src/includes/traits/Ac/ObUtils.php:367 Stack trace: #0 [internal function]: WebSharks\CometCache\Classes\AdvancedCache->outputBufferCallbackHandler() #1 /data/wangzhan/tech.souyunku.com.wp/wp-includes/functions.php(5109): ob_end_flush() #2 /data/wangzhan/tech.souyunku.com.wp/wp-includes/class-wp-hook.php(303): wp_ob_end_flush_all() #3 /data/wangzhan/tech.souyunku.com.wp/wp-includes/class-wp-hook.php(327): WP_Hook->apply_filters() #4 /data/wangzhan/tech.souyunku.com.wp/wp-includes/plugin.php(470): WP_Hook->do_action() #5 /data/wangzhan/tech.souyunku.com.wp/wp-includes/load.php(1097): do_action() #6 [internal function]: shutdown_action_hook() #7 {main} thrown in /data/wangzhan/tech.souyunku.com.wp/wp-content/plugins/comet-cache/src/includes/traits/Ac/ObUtils.php on line 367