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

ZkMetadataStore介绍

[英]An implementation of the MetadataStore interface where the metadata of the Samza job is stored in zookeeper.
[中]MetadataStore接口的一种实现，Samza作业的元数据存储在zookeeper中。

代码示例

代码示例来源：origin: apache/samza

@Override
 public MetadataStore getMetadataStore(String namespace, Config config, MetricsRegistry metricsRegistry) {
  return new ZkMetadataStore(namespace, config, metricsRegistry);
 }
}

代码示例来源：origin: apache/samza

/**
 * {@inheritDoc}
 */
@Override
public byte[] get(String key) {
 return zkClient.readData(getZkPathForKey(key), true);
}

代码示例来源：origin: apache/samza

/**
 * {@inheritDoc}
 */
@Override
public void delete(String key) {
 zkClient.delete(getZkPathForKey(key));
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

/**
 * {@inheritDoc}
 */
@Override
public byte[] get(byte[] key) {
 return zkClient.readData(getZkPathForKey(key), true);
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

@Override
 public MetadataStore getMetadataStore(String namespace, Config config, MetricsRegistry metricsRegistry) {
  return new ZkMetadataStore(namespace, config, metricsRegistry);
 }
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

/**
 * {@inheritDoc}
 */
@Override
public void delete(byte[] key) {
 zkClient.delete(getZkPathForKey(key));
}

代码示例来源：origin: org.apache.samza/samza-core

@Override
 public MetadataStore getMetadataStore(String namespace, Config config, MetricsRegistry metricsRegistry) {
  return new ZkMetadataStore(namespace, config, metricsRegistry);
 }
}

代码示例来源：origin: org.apache.samza/samza-core

/**
 * {@inheritDoc}
 */
@Override
public void delete(byte[] key) {
 zkClient.delete(getZkPathForKey(key));
}

代码示例来源：origin: org.apache.samza/samza-core_2.11

@Override
 public MetadataStore getMetadataStore(String namespace, Config config, MetricsRegistry metricsRegistry) {
  return new ZkMetadataStore(namespace, config, metricsRegistry);
 }
}

代码示例来源：origin: org.apache.samza/samza-core_2.11

/**
 * {@inheritDoc}
 */
@Override
public void delete(byte[] key) {
 zkClient.delete(getZkPathForKey(key));
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

@Override
 public MetadataStore getMetadataStore(String namespace, Config config, MetricsRegistry metricsRegistry) {
  return new ZkMetadataStore(namespace, config, metricsRegistry);
 }
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

/**
 * {@inheritDoc}
 */
@Override
public void delete(byte[] key) {
 zkClient.delete(getZkPathForKey(key));
}

代码示例来源：origin: org.apache.samza/samza-core_2.11

/**
 * {@inheritDoc}
 */
@Override
public byte[] get(byte[] key) {
 return zkClient.readData(getZkPathForKey(key), true);
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

/**
 * {@inheritDoc}
 */
@Override
public byte[] get(byte[] key) {
 return zkClient.readData(getZkPathForKey(key), true);
}

代码示例来源：origin: org.apache.samza/samza-core

/**
 * {@inheritDoc}
 */
@Override
public byte[] get(byte[] key) {
 return zkClient.readData(getZkPathForKey(key), true);
}

代码示例来源：origin: apache/samza

/**
 * {@inheritDoc}
 */
@Override
public void put(String key, byte[] value) {
 String zkPath = getZkPathForKey(key);
 zkClient.createPersistent(zkPath, true);
 zkClient.writeData(zkPath, value);
}

代码示例来源：origin: org.apache.samza/samza-core_2.11

/**
 * {@inheritDoc}
 */
@Override
public void put(byte[] key, byte[] value) {
 String zkPath = getZkPathForKey(key);
 zkClient.createPersistent(zkPath, true);
 zkClient.writeData(zkPath, value);
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

/**
 * {@inheritDoc}
 */
@Override
public void put(byte[] key, byte[] value) {
 String zkPath = getZkPathForKey(key);
 zkClient.createPersistent(zkPath, true);
 zkClient.writeData(zkPath, value);
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

/**
 * {@inheritDoc}
 */
@Override
public void put(byte[] key, byte[] value) {
 String zkPath = getZkPathForKey(key);
 zkClient.createPersistent(zkPath, true);
 zkClient.writeData(zkPath, value);
}

代码示例来源：origin: org.apache.samza/samza-core

/**
 * {@inheritDoc}
 */
@Override
public void put(byte[] key, byte[] value) {
 String zkPath = getZkPathForKey(key);
 zkClient.createPersistent(zkPath, true);
 zkClient.writeData(zkPath, value);
}