- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.flink.runtime.util.ZooKeeperUtils.createFileSystemStateStorage()
方法的一些代码示例,展示了ZooKeeperUtils.createFileSystemStateStorage()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZooKeeperUtils.createFileSystemStateStorage()
方法的具体详情如下:
包路径:org.apache.flink.runtime.util.ZooKeeperUtils
类名称:ZooKeeperUtils
方法名:createFileSystemStateStorage
[英]Creates a FileSystemStateStorageHelper instance.
[中]创建FileSystemStateStorageHelper实例。
代码示例来源:origin: apache/flink
@Override
public MesosWorkerStore createMesosWorkerStore(Configuration configuration, Executor executor) throws Exception {
RetrievableStateStorageHelper<MesosWorkerStore.Worker> stateStorageHelper =
ZooKeeperUtils.createFileSystemStateStorage(configuration, "mesosWorkerStore");
ZooKeeperStateHandleStore<MesosWorkerStore.Worker> zooKeeperStateHandleStore = zooKeeperUtilityFactory.createZooKeeperStateHandleStore(
"/workers",
stateStorageHelper);
ZooKeeperSharedValue frameworkId = zooKeeperUtilityFactory.createSharedValue("/frameworkId", new byte[0]);
ZooKeeperSharedCount totalTaskCount = zooKeeperUtilityFactory.createSharedCount("/taskCount", 0);
return new ZooKeeperMesosWorkerStore(
zooKeeperStateHandleStore,
frameworkId,
totalTaskCount);
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
/**
* Creates a {@link ZooKeeperSubmittedJobGraphStore} instance.
*
* @param client The {@link CuratorFramework} ZooKeeper client to use
* @param configuration {@link Configuration} object
* @return {@link ZooKeeperSubmittedJobGraphStore} instance
* @throws Exception if the submitted job graph store cannot be created
*/
public static ZooKeeperSubmittedJobGraphStore createSubmittedJobGraphs(
CuratorFramework client,
Configuration configuration) throws Exception {
checkNotNull(configuration, "Configuration");
RetrievableStateStorageHelper<SubmittedJobGraph> stateStorage = createFileSystemStateStorage(configuration, "submittedJobGraph");
// ZooKeeper submitted jobs root dir
String zooKeeperSubmittedJobsPath = configuration.getString(HighAvailabilityOptions.HA_ZOOKEEPER_JOBGRAPHS_PATH);
return new ZooKeeperSubmittedJobGraphStore(
client,
zooKeeperSubmittedJobsPath,
stateStorage);
}
代码示例来源:origin: com.alibaba.blink/flink-runtime
/**
* Creates a {@link ZooKeeperSubmittedJobGraphStore} instance.
*
* @param client The {@link CuratorFramework} ZooKeeper client to use
* @param configuration {@link Configuration} object
* @param executor to run ZooKeeper callbacks
* @return {@link ZooKeeperSubmittedJobGraphStore} instance
* @throws Exception if the submitted job graph store cannot be created
*/
public static ZooKeeperSubmittedJobGraphStore createSubmittedJobGraphs(
CuratorFramework client,
Configuration configuration,
Executor executor) throws Exception {
checkNotNull(configuration, "Configuration");
RetrievableStateStorageHelper<SubmittedJobGraph> stateStorage = createFileSystemStateStorage(configuration, "submittedJobGraph");
// ZooKeeper submitted jobs root dir
String zooKeeperSubmittedJobsPath = configuration.getString(HighAvailabilityOptions.HA_ZOOKEEPER_JOBGRAPHS_PATH);
return new ZooKeeperSubmittedJobGraphStore(
client, zooKeeperSubmittedJobsPath, stateStorage, executor);
}
代码示例来源:origin: org.apache.flink/flink-runtime
/**
* Creates a {@link ZooKeeperSubmittedJobGraphStore} instance.
*
* @param client The {@link CuratorFramework} ZooKeeper client to use
* @param configuration {@link Configuration} object
* @return {@link ZooKeeperSubmittedJobGraphStore} instance
* @throws Exception if the submitted job graph store cannot be created
*/
public static ZooKeeperSubmittedJobGraphStore createSubmittedJobGraphs(
CuratorFramework client,
Configuration configuration) throws Exception {
checkNotNull(configuration, "Configuration");
RetrievableStateStorageHelper<SubmittedJobGraph> stateStorage = createFileSystemStateStorage(configuration, "submittedJobGraph");
// ZooKeeper submitted jobs root dir
String zooKeeperSubmittedJobsPath = configuration.getString(HighAvailabilityOptions.HA_ZOOKEEPER_JOBGRAPHS_PATH);
return new ZooKeeperSubmittedJobGraphStore(
client,
zooKeeperSubmittedJobsPath,
stateStorage);
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
/**
* Creates a {@link ZooKeeperSubmittedJobGraphStore} instance.
*
* @param client The {@link CuratorFramework} ZooKeeper client to use
* @param configuration {@link Configuration} object
* @param executor to run ZooKeeper callbacks
* @return {@link ZooKeeperSubmittedJobGraphStore} instance
* @throws Exception if the submitted job graph store cannot be created
*/
public static ZooKeeperSubmittedJobGraphStore createSubmittedJobGraphs(
CuratorFramework client,
Configuration configuration,
Executor executor) throws Exception {
checkNotNull(configuration, "Configuration");
RetrievableStateStorageHelper<SubmittedJobGraph> stateStorage = createFileSystemStateStorage(configuration, "submittedJobGraph");
// ZooKeeper submitted jobs root dir
String zooKeeperSubmittedJobsPath = ConfigurationUtil.getStringWithDeprecatedKeys(
configuration,
ConfigConstants.HA_ZOOKEEPER_JOBGRAPHS_PATH,
ConfigConstants.DEFAULT_ZOOKEEPER_JOBGRAPHS_PATH,
ConfigConstants.ZOOKEEPER_JOBGRAPHS_PATH);
return new ZooKeeperSubmittedJobGraphStore(
client, zooKeeperSubmittedJobsPath, stateStorage, executor);
}
代码示例来源:origin: org.apache.flink/flink-runtime_2.11
HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINTS_PATH);
RetrievableStateStorageHelper<CompletedCheckpoint> stateStorage = createFileSystemStateStorage(
configuration,
"completedCheckpoint");
代码示例来源:origin: org.apache.flink/flink-runtime
HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINTS_PATH);
RetrievableStateStorageHelper<CompletedCheckpoint> stateStorage = createFileSystemStateStorage(
configuration,
"completedCheckpoint");
代码示例来源:origin: org.apache.flink/flink-runtime_2.10
ConfigConstants.ZOOKEEPER_CHECKPOINTS_PATH);
RetrievableStateStorageHelper<CompletedCheckpoint> stateStorage = createFileSystemStateStorage(
configuration,
"completedCheckpoint");
代码示例来源:origin: com.alibaba.blink/flink-runtime
HighAvailabilityOptions.HA_ZOOKEEPER_CHECKPOINTS_PATH);
RetrievableStateStorageHelper<CompletedCheckpoint> stateStorage = createFileSystemStateStorage(
configuration,
"completedCheckpoint");
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getSubstitutedPath()方法的一些代码示例,展示了ZooKeeperUtils.
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.setData()方法的一些代码示例,展示了ZooKeeperUtils.setData()的具
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.deleteSafe()方法的一些代码示例,展示了ZooKeeperUtils.deleteSa
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getContainerLogin()方法的一些代码示例,展示了ZooKeeperUtils.g
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getSubstitutedData()方法的一些代码示例,展示了ZooKeeperUtils.
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.isContainerLogin()方法的一些代码示例,展示了ZooKeeperUtils.is
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getData()方法的一些代码示例,展示了ZooKeeperUtils.getData()的具
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.create()方法的一些代码示例,展示了ZooKeeperUtils.create()的具体用
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getStringData()方法的一些代码示例,展示了ZooKeeperUtils.getSt
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getByteData()方法的一些代码示例,展示了ZooKeeperUtils.getByte
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getAllChildren()方法的一些代码示例,展示了ZooKeeperUtils.getA
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.generateContainerToken()方法的一些代码示例,展示了ZooKeeperUt
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getChildrenSafe()方法的一些代码示例,展示了ZooKeeperUtils.get
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.delete()方法的一些代码示例,展示了ZooKeeperUtils.delete()的具体用
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getContainerTokens()方法的一些代码示例,展示了ZooKeeperUtils.
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.exists()方法的一些代码示例,展示了ZooKeeperUtils.exists()的具体用
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.createDefault()方法的一些代码示例,展示了ZooKeeperUtils.creat
本文整理了Java中io.fabric8.zookeeper.utils.ZooKeeperUtils.getChildren()方法的一些代码示例,展示了ZooKeeperUtils.getChil
本文整理了Java中com.twitter.common.zookeeper.ZooKeeperUtils.ensurePath()方法的一些代码示例,展示了ZooKeeperUtils.ensure
本文整理了Java中org.apache.flink.runtime.util.ZooKeeperUtils.createCheckpointIDCounter()方法的一些代码示例,展示了ZooKe
我是一名优秀的程序员,十分优秀!