io.druid.server.initialization.ZkPathsConfig.getServedSegmentsPath()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-17 17:19:31 25 4

@Inject
public SingleServerInventoryView(
  final ZkPathsConfig zkPaths,
  final CuratorFramework curator,
  final ObjectMapper jsonMapper
)
{
 super(
   log,
   zkPaths.getAnnouncementsPath(),
   zkPaths.getServedSegmentsPath(),
   curator,
   jsonMapper,
   new TypeReference<DataSegment>(){}
 );
}

@Inject
public SingleServerInventoryView(
  final ZkPathsConfig zkPaths,
  final CuratorFramework curator,
  final ObjectMapper jsonMapper,
  final Predicate<Pair<DruidServerMetadata, DataSegment>> defaultFilter
)
{
 super(
   log,
   zkPaths.getAnnouncementsPath(),
   zkPaths.getServedSegmentsPath(),
   curator,
   jsonMapper,
   new TypeReference<DataSegment>()
   {
   }
 );
 Preconditions.checkNotNull(defaultFilter);
 this.defaultFilter = defaultFilter;
}

@Inject
public SingleDataSegmentAnnouncer(
  DruidServerMetadata server,
  ZkPathsConfig config,
  Announcer announcer,
  ObjectMapper jsonMapper
)
{
 super(server, config, announcer, jsonMapper);
 this.announcer = announcer;
 this.jsonMapper = jsonMapper;
 this.servedSegmentsLocation = ZKPaths.makePath(config.getServedSegmentsPath(), server.getName());
}

@Override
public boolean equals(Object other)
{
 if (null == other) {
  return false;
 }
 if (this == other) {
  return true;
 }
 if (!(other instanceof ZkPathsConfig)) {
  return false;
 }
 ZkPathsConfig otherConfig = (ZkPathsConfig) other;
 if (this.getBase().equals(otherConfig.getBase()) &&
   this.getAnnouncementsPath().equals(otherConfig.getAnnouncementsPath()) &&
   this.getConnectorPath().equals(otherConfig.getConnectorPath()) &&
   this.getLiveSegmentsPath().equals(otherConfig.getLiveSegmentsPath()) &&
   this.getCoordinatorPath().equals(otherConfig.getCoordinatorPath()) &&
   this.getLoadQueuePath().equals(otherConfig.getLoadQueuePath()) &&
   this.getPropertiesPath().equals(otherConfig.getPropertiesPath()) &&
   this.getServedSegmentsPath().equals(otherConfig.getServedSegmentsPath())) {
  return true;
 }
 return false;
}

final String servedSegmentsLocation = ZKPaths.makePath(zkPaths.getServedSegmentsPath(), me.getName());
final String liveSegmentsLocation = ZKPaths.makePath(zkPaths.getLiveSegmentsPath(), me.getName());

final String servedSegmentsLocation = ZKPaths.makePath(zkPaths.getServedSegmentsPath(), me.getName());
final String liveSegmentsLocation = ZKPaths.makePath(zkPaths.getLiveSegmentsPath(), me.getName());

25 4 0

• initialization - 属性错误 : module 'keras' has no attribute 'initializers'

  我正在尝试将 keras.initializers 引入我的网络，following this link : import keras from keras.optimizers import RMS

• c - 为什么编译器会抛出这个警告 : "missing initializer"? Is the structure initialized?

  我正在为程序创建某种前端。为了启动程序，我使用了调用 CreateProcess()，其中接收到一个指向 STARTUPINFO 结构的指针。初始化我曾经做过的结构: STARTUPINFO star

• c++ - 值初始化 : default initialization or zero initialization?

  我已经模板化了 gray_code 类，该类旨在存储一些无符号整数，其基础位以格雷码顺序存储。这里是: template struct gray_code { static_assert(st

• java - 错误: variable might not have been initialized - How to initialize ArrayList?

  我已经查看了之前所有与此标题类似的问题，但我找不到解决方案。所有错误都表明我没有初始化 ArrayList。我是否没有像 = new ArrayList 这样初始化 ArrayList？ ？ impo

• Swift - Required Initializer 与 Delegating initializer 之间的一点混淆

  当涉及到 Swift 类时，我对必需的初始化器和委托(delegate)的初始化器有点混淆。 正如您在下面的示例代码中所见，NewDog 可以通过两种方式中的一种进行初始化。如您所见，您可以通过在初始

• C++ 错误 : array initializer must be an initializer list

  几天来我一直在为一段代码苦苦挣扎。我在运行代码时收到的错误消息是: 错误:数组初始值设定项必须是初始值设定项列表 accountStore(int size = 0):accts(大小){} 这里似乎

• c - "initializer element is not constant"和 "near initialization"

  我想返回一个数组，因为它是否被覆盖并不重要，我的方法是这样的: double * kryds(double linje_1[], double linje_2[]){ double x = linje

• c++ - 编译器错误 : "Non-aggregates cannot be initialized with initializer list."

  尝试在 C++ 中创建一个简单的 vector 时，出现以下错误: Non-aggregates cannot be initialized with initializer list. 我使用的代码

• C++ 构造函数 : Initialize local variable before initializer list

  如何在构造函数中(在堆栈上)存储初始化列表所需的临时状态？ 例如，实现这个构造函数…… // configabstraction.h #include class ConfigAbstraction

• c++ - 错误 C7034 : an array cannot be initialized with a parenthesized initializer

  我正在尝试编写一个 native Node 插件，它枚举 Windows 机器上的所有窗口并将它们的标题数组返回给 JS userland。 但是我被这个错误难住了: C:\Program Files

• c++ - 错误 C2440 : 'initializing' : cannot convert from 'initializer-list'

  #include using namespace std; struct TDate { int day, month, year; void Readfromkb() {

• c++ - Array initializer must be an initializer list 错误未显示

  我很难弄清楚这段代码为何有效。我不应该收到“数组初始值设定项必须是初始值设定项列表”错误吗？ #include class B { public: B() { std::cout << "B C

• c++ - 为什么我得到 "non-aggregate cannot be initialized with initializer list"

  std::map m = { {"Marc G.", 123}, {"Zulija N.", 456}, {"John D.", 369} }; 在 Xcode 中，我将 C+

• C++ : initialize(new) an array of vector of different initial size

  为了帮助你明白这一点，我给出了我的代码:(main.cpp)，只涉及一个文件。 #include #include using namespace std; class test{ public

• c++ - 如何修复 "non-aggregates cannot be initialized with initializer list” < map >

  这在 VS2018 中有效，但在 2008 中无效，我不确定如何修复它。 #include #include int main() { std::map myMap = {

• c++ - Uniform Initialization with curly brace 被误认为是 Initializer List

  我有一个类: #include class Object { std::shared_ptr object_ptr; public: Object() {} template

• c++ - 错误 C3074 : an array can only be initialized with an initializer-list

  我正在为 POD、STL 和复合类型(如数组)开发小型(漂亮)打印机。在这样做的同时，我也在摆弄初始化列表并遇到以下声明 std::vector arr{ { 10, 11, 12 }, { 20,

• swift - 制作模型时报错 "return from initializer without initializing all stored properties"

  我正在使用解析实现模型。 这是我的代码。 import Foundation import UIKit import Parse class User { var objectId : String

• java - 线程 : Lazy Initialization vs Static Lazy Initialization

  我正在观看 Java 内存模型视频演示，作者说与 Lazy Initialization 相比，使用 Static Lazy Initialization 更好，我不清楚他说的是什么想说。 我想接触社

• javascript - this.initialize(arguments) 与 this.initialize.apply(this, arguments) : what's the difference?

  如果您查看 Backbone.js 的源代码，您会看到此模式的多种用途: this.initialize.apply(this, arguments); 例如，这里: var Router =