本文整理了Java中com.hazelcast.instance.Node.getNodeExtension()方法的一些代码示例，展示了Node.getNodeExtension()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Node.getNodeExtension()方法的具体详情如下：
包路径：com.hazelcast.instance.Node
类名称：Node
方法名：getNodeExtension

Node.getNodeExtension介绍

暂无

代码示例

代码示例来源：origin: hazelcast/hazelcast-jet

boolean setInitialized() {
  if (!initialized) {
    initialized = true;
    node.getNodeExtension().onPartitionStateChange();
    return true;
  }
  return false;
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void notifyBeforeStateChange(ClusterState oldState, ClusterState requestedState, boolean isTransient) {
  if (requestedState != null) {
    node.getNodeExtension().beforeClusterStateChange(oldState, requestedState, isTransient);
  }
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private void notifyBeforeStateChange(ClusterState oldState, ClusterState requestedState, boolean isTransient) {
  if (requestedState != null) {
    node.getNodeExtension().beforeClusterStateChange(oldState, requestedState, isTransient);
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void setClusterStateAndVersion(ClusterState newState, Version newVersion, boolean isTransient) {
  this.state = newState;
  this.clusterVersion = newVersion;
  stateLockRef.set(LockGuard.NOT_LOCKED);
  changeNodeState(newState);
  node.getNodeExtension().onClusterStateChange(newState, isTransient);
  node.getNodeExtension().onClusterVersionChange(newVersion);
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void doSetClusterState(ClusterState newState, boolean isTransient) {
  this.state = newState;
  stateLockRef.set(LockGuard.NOT_LOCKED);
  changeNodeState(newState);
  node.getNodeExtension().onClusterStateChange(newState, isTransient);
}

代码示例来源：origin: hazelcast/hazelcast-jet

private <T> T createService(Class<T> service) {
  Node node = nodeEngine.getNode();
  NodeExtension nodeExtension = node.getNodeExtension();
  return nodeExtension.createService(service);
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void createClusterHotRestartStatus(MemberStateImpl memberState) {
  final ClusterHotRestartStatusDTO state =
      instance.node.getNodeExtension().getInternalHotRestartService().getCurrentClusterHotRestartStatus();
  memberState.setClusterHotRestartStatus(state);
}

代码示例来源：origin: hazelcast/hazelcast-jet

/** Verifies that the node startup is completed. */
private void verifyNodeStarted() {
  NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  nodeStartCompleted = nodeEngine.getNode().getNodeExtension().isStartCompleted();
  if (!nodeStartCompleted) {
    throw new IllegalStateException("Migration operation is received before startup is completed. "
        + "Sender: " + getCallerAddress());
  }
}

代码示例来源：origin: com.hazelcast/hazelcast-all

/** Verifies that the node startup is completed. */
private void verifyNodeStarted() {
  NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  nodeStartCompleted = nodeEngine.getNode().getNodeExtension().isStartCompleted();
  if (!nodeStartCompleted) {
    throw new IllegalStateException("Migration operation is received before startup is completed. "
        + "Sender: " + getCallerAddress());
  }
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public void writeResponse(ManagementCenterService mcs, JsonObject out) throws Exception {
  Node node = mcs.getHazelcastInstance().node;
  final InternalHotRestartService hotRestartService = node.getNodeExtension().getInternalHotRestartService();
  final boolean done = hotRestartService.triggerPartialStart();
  String result = done ? SUCCESS_RESULT : FAILED_RESULT;
  out.add("result", result);
}

代码示例来源：origin: com.hazelcast/hazelcast-all

void onMemberRemove(MemberImpl deadMember) {
  // sync calls
  node.getPartitionService().memberRemoved(deadMember);
  nodeEngine.onMemberLeft(deadMember);
  node.getNodeExtension().onMemberListChange();
}

代码示例来源：origin: hazelcast/hazelcast-jet

private boolean isMemberExcludedFromHotRestart() {
  final NodeExtension nodeExtension = node.getNodeExtension();
  return !nodeExtension.isStartCompleted()
      && nodeExtension.getInternalHotRestartService().isMemberExcluded(node.getThisAddress(), node.getThisUuid());
}

代码示例来源：origin: hazelcast/hazelcast-jet

public SystemLogPlugin(NodeEngineImpl nodeEngine) {
  this(nodeEngine.getProperties(),
      nodeEngine.getNode().connectionManager,
      nodeEngine.getHazelcastInstance(),
      nodeEngine.getLogger(SystemLogPlugin.class),
      nodeEngine.getNode().getNodeExtension());
}

代码示例来源：origin: com.hazelcast/hazelcast-all

private boolean shouldResetHotRestartData() {
  final NodeExtension nodeExtension = node.getNodeExtension();
  return !nodeExtension.isStartCompleted()
      && nodeExtension.getInternalHotRestartService().isMemberExcluded(node.getThisAddress(), node.getThisUuid());
}

代码示例来源：origin: hazelcast/hazelcast-jet

private void createHotRestartState(MemberStateImpl memberState) {
  final HotRestartService hotRestartService = instance.node.getNodeExtension().getHotRestartService();
  boolean hotBackupEnabled = hotRestartService.isHotBackupEnabled();
  String hotBackupDirectory = hotRestartService.getBackupDirectory();
  final HotRestartStateImpl state = new HotRestartStateImpl(hotRestartService.getBackupTaskStatus(),
      hotBackupEnabled, hotBackupDirectory);
  memberState.setHotRestartState(state);
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public final void join() {
  blacklistedAddresses.clear();
  doJoin();
  if (!clusterService.isJoined() && isMemberExcludedFromHotRestart()) {
    logger.warning("Could not join to the cluster because hot restart data must be reset.");
    node.getNodeExtension().getInternalHotRestartService().forceStartBeforeJoin();
    reset();
    doJoin();
  }
  postJoin();
}

代码示例来源：origin: com.hazelcast/hazelcast-all

@Override
public final void join() {
  blacklistedAddresses.clear();
  doJoin();
  if (!clusterService.isJoined() && shouldResetHotRestartData()) {
    logger.warning("Could not join to the cluster because hot restart data must be reset.");
    node.getNodeExtension().getInternalHotRestartService().resetHotRestartData();
    reset();
    doJoin();
  }
  postJoin();
}

代码示例来源：origin: hazelcast/hazelcast-jet

@Override
public void run() {
  if (!node.isRunning() || !node.getNodeExtension().isStartCompleted()
      || !partitionService.areMigrationTasksAllowed()) {
    return;
  }
  nodeEngine.getOperationService().executeOnPartitions(new PartitionAntiEntropyTaskFactory(), getLocalPartitions());
}

代码示例来源：origin: hazelcast/hazelcast-jet

void initializeAndProcessMessage() throws Throwable {
  if (!node.getNodeExtension().isStartCompleted()) {
    throw new HazelcastInstanceNotActiveException("Hazelcast instance is not ready yet!");
  }
  parameters = decodeClientMessage(clientMessage);
  Credentials credentials = endpoint.getCredentials();
  interceptBefore(credentials);
  checkPermissions(endpoint);
  processMessage();
  interceptAfter(credentials);
}

代码示例来源：origin: hazelcast/hazelcast-jet

private boolean isNodeStartCompleted() {
  NodeEngineImpl nodeEngine = (NodeEngineImpl) getNodeEngine();
  boolean startCompleted = nodeEngine.getNode().getNodeExtension().isStartCompleted();
  if (!startCompleted) {
    ILogger logger = getLogger();
    if (logger.isFinestEnabled()) {
      logger.finest("Anti-entropy operation for partitionId=" + getPartitionId()
          + ", replicaIndex=" + getReplicaIndex() + " is received before startup is completed.");
    }
  }
  return startCompleted;
}