org.locationtech.geogig.repository.Repository.blobStore()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(10.6k)|赞(0)|评价(0)|浏览(80)

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

Repository.blobStore介绍

暂无

代码示例

代码示例来源：origin: locationtech/geogig

/**
 * Returns the {@link RepositoryFilter} defined for {@code repo} as of its
 * {@link Blobs#SPARSE_FILTER_BLOB_KEY sparse_filter} blobstore's blob
 */
public static Optional<RepositoryFilter> getFilter(Repository repo)
    throws IllegalStateException {
  BlobStore blobStore = repo.blobStore();
  Optional<byte[]> filterBlob = blobStore.getBlob(SPARSE_FILTER_BLOB_KEY);
  IniRepositoryFilter filter = null;
  if (filterBlob.isPresent()) {
    filter = new IniRepositoryFilter(blobStore, SPARSE_FILTER_BLOB_KEY);
  }
  return Optional.fromNullable(filter);
}

代码示例来源：origin: org.locationtech.geogig/geogig-core

/**
 * Returns the {@link RepositoryFilter} defined for {@code repo} as of its
 * {@link Blobs#SPARSE_FILTER_BLOB_KEY sparse_filter} blobstore's blob
 */
public static Optional<RepositoryFilter> getFilter(Repository repo)
    throws IllegalStateException {
  BlobStore blobStore = repo.blobStore();
  Optional<byte[]> filterBlob = blobStore.getBlob(SPARSE_FILTER_BLOB_KEY);
  IniRepositoryFilter filter = null;
  if (filterBlob.isPresent()) {
    filter = new IniRepositoryFilter(blobStore, SPARSE_FILTER_BLOB_KEY);
  }
  return Optional.fromNullable(filter);
}

代码示例来源：origin: org.locationtech.geogig/geogig-web-api

@Override
  public void run() {
    if (repo.isOpen()) {
      BlobStore blobs = repo.blobStore();
      blobs.removeBlob(deleteKey);
    }
  }
}, 60, TimeUnit.SECONDS);

代码示例来源：origin: org.locationtech.geogig/geogig-cli

private ObjectId getTheirsHeadId() {
  ObjectId theirsHeadId;
  Optional<Ref> mergeHead = geogig.command(RefParse.class).setName(Ref.MERGE_HEAD).call();
  if (mergeHead.isPresent()) {
    // It was a merge
    theirsHeadId = mergeHead.get().getObjectId();
  } else {
    // It was a rebase
    final Optional<byte[]> branchBlob = geogig.getRepository().blobStore()
        .getBlob(RebaseOp.REBASE_BRANCH_BLOB);
    Preconditions.checkState(branchBlob.isPresent(),
        "Cannot find merge/rebase head reference");
    List<String> branchLines = Blobs.readLines(branchBlob);
    String currentBranch = branchLines.get(0);
    Optional<Ref> rebaseHead = geogig.command(RefParse.class).setName(currentBranch).call();
    Preconditions.checkState(rebaseHead.isPresent(), "Rebase head could not be resolved.");
    theirsHeadId = rebaseHead.get().getObjectId();
  }
  return theirsHeadId;
}

代码示例来源：origin: org.locationtech.geogig/geogig-cli-core

private ObjectId getTheirsHeadId() {
  ObjectId theirsHeadId;
  Optional<Ref> mergeHead = geogig.command(RefParse.class).setName(Ref.MERGE_HEAD).call();
  if (mergeHead.isPresent()) {
    // It was a merge
    theirsHeadId = mergeHead.get().getObjectId();
  } else {
    // It was a rebase
    final Optional<byte[]> branchBlob = geogig.getRepository().blobStore()
        .getBlob(RebaseOp.REBASE_BRANCH_BLOB);
    Preconditions.checkState(branchBlob.isPresent(),
        "Cannot find merge/rebase head reference");
    List<String> branchLines = Blobs.readLines(branchBlob);
    String currentBranch = branchLines.get(0);
    Optional<Ref> rebaseHead = geogig.command(RefParse.class).setName(currentBranch).call();
    Preconditions.checkState(rebaseHead.isPresent(), "Rebase head could not be resolved.");
    theirsHeadId = rebaseHead.get().getObjectId();
  }
  return theirsHeadId;
}

代码示例来源：origin: locationtech/geogig

private ObjectId getTheirsHeadId() {
  ObjectId theirsHeadId;
  Optional<Ref> mergeHead = geogig.command(RefParse.class).setName(Ref.MERGE_HEAD).call();
  if (mergeHead.isPresent()) {
    // It was a merge
    theirsHeadId = mergeHead.get().getObjectId();
  } else {
    // It was a rebase
    final Optional<byte[]> branchBlob = geogig.getRepository().blobStore()
        .getBlob(RebaseOp.REBASE_BRANCH_BLOB);
    Preconditions.checkState(branchBlob.isPresent(),
        "Cannot find merge/rebase head reference");
    List<String> branchLines = Blobs.readLines(branchBlob);
    String currentBranch = branchLines.get(0);
    Optional<Ref> rebaseHead = geogig.command(RefParse.class).setName(currentBranch).call();
    Preconditions.checkState(rebaseHead.isPresent(), "Rebase head could not be resolved.");
    theirsHeadId = rebaseHead.get().getObjectId();
  }
  return theirsHeadId;
}

代码示例来源：origin: org.locationtech.geogig/geogig-web-api

byte[] nowBytes = ByteBuffer.allocate(Long.SIZE / Byte.SIZE).putLong(now).array();
final BlobStore blobStore = geogig.repository().blobStore();
blobStore.putBlob(deleteKey, nowBytes);
deleteTokenExecutor.schedule(new Runnable() {

代码示例来源：origin: locationtech/geogig

private void createFilterFile(Map<String, String> filters) {
  String filterBlob = "";
  for (Entry<String, String> entry : filters.entrySet()) {
    String featurePath = entry.getKey();
    String filter = entry.getValue();
    filterBlob += "[" + featurePath + "]\n";
    filterBlob += "type = CQL\n";
    filterBlob += "filter = " + filter + "\n";
  }
  try {
    localGeogig.repo.blobStore().putBlob(Blobs.SPARSE_FILTER_BLOB_KEY,
        filterBlob.getBytes());
    Optional<Remote> remoteInfo = localGeogig.geogig.command(RemoteResolve.class)
        .setName(REMOTE_NAME).call();
    Preconditions.checkState(remoteInfo.isPresent());
    LocalMappedRemoteRepo remoteRepo;
    remoteRepo = spy(
        new LocalMappedRemoteRepo(remoteInfo.get(), remoteGeogig.envHome.toURI()));
    doNothing().when(remoteRepo).close();
    remoteRepo.setRepository(remoteGeogig.geogig.getRepository());
    localGeogig.remoteOverride.put(REMOTE_NAME, remoteRepo);
  } catch (Exception e) {
    e.printStackTrace();
    throw e;
  }
}

代码示例来源：origin: org.locationtech.geogig/geogig-web-api

Optional<byte[]> blobValue = geogig.blobStore().getBlob(deleteKey);
if (!blobValue.isPresent()) {
  throw new CommandSpecException("The specified token does not exist or has expired.",

代码示例来源：origin: org.locationtech.geogig/geogig-core

repository().blobStore().putBlob(Blobs.SPARSE_FILTER_BLOB_KEY,
      Files.toByteArray(oldFilterFile));
} catch (Exception e) {

代码示例来源：origin: locationtech/geogig

repository().blobStore().putBlob(Blobs.SPARSE_FILTER_BLOB_KEY,
      Files.toByteArray(oldFilterFile));
} catch (Exception e) {

代码示例来源：origin: org.locationtech.geogig/geogig-remoting

private void createFilterFile(Map<String, String> filters) {
  String filterBlob = "";
  for (Entry<String, String> entry : filters.entrySet()) {
    String featurePath = entry.getKey();
    String filter = entry.getValue();
    filterBlob += "[" + featurePath + "]\n";
    filterBlob += "type = CQL\n";
    filterBlob += "filter = " + filter + "\n";
  }
  try {
    localGeogig.repo.blobStore().putBlob(Blobs.SPARSE_FILTER_BLOB_KEY,
        filterBlob.getBytes());
    Optional<Remote> remoteInfo = localGeogig.geogig.command(RemoteResolve.class)
        .setName(REMOTE_NAME).call();
    Preconditions.checkState(remoteInfo.isPresent());
    LocalMappedRemoteRepo remoteRepo;
    remoteRepo = spy(
        new LocalMappedRemoteRepo(remoteInfo.get(), remoteGeogig.envHome.toURI()));
    doNothing().when(remoteRepo).close();
    remoteRepo.setRepository(remoteGeogig.geogig.getRepository());
    localGeogig.remoteOverride.put(REMOTE_NAME, remoteRepo);
  } catch (Exception e) {
    e.printStackTrace();
    throw e;
  }
}

代码示例来源：origin: locationtech/geogig

geogig.getRepository().blobStore().putBlob(Blobs.SPARSE_FILTER_BLOB_KEY,
    filterFile.getBytes());

代码示例来源：origin: org.locationtech.geogig/geogig-core

geogig.getRepository().blobStore().putBlob(Blobs.SPARSE_FILTER_BLOB_KEY,
    filterFile.getBytes());

代码示例来源：origin: locationtech/geogig

assertNotNull(repo.graphDatabase());
assertNotNull(repo.conflictsDatabase());
assertNotNull(repo.blobStore());

代码示例来源：origin: org.locationtech.geogig/geogig-core

assertNotNull(repo.graphDatabase());
assertNotNull(repo.conflictsDatabase());
assertNotNull(repo.blobStore());

代码示例来源：origin: locationtech/geogig

@Test
public void testClean() throws Exception {
  // Set up some refs to clean up
  geogig.command(UpdateRef.class).setName(Ref.MERGE_HEAD).setNewValue(ObjectId.NULL).call();
  geogig.command(UpdateRef.class).setName(Ref.ORIG_HEAD).setNewValue(ObjectId.NULL).call();
  geogig.command(UpdateRef.class).setName(Ref.CHERRY_PICK_HEAD).setNewValue(ObjectId.NULL)
      .call();
  geogig.getRepository().blobStore().putBlob(MergeOp.MERGE_MSG, "Merge message".getBytes());
  ImmutableList<String> cleanedUp = geogig.command(CleanRefsOp.class).call();
  assertEquals(4, cleanedUp.size());
  assertTrue(cleanedUp.contains(Ref.MERGE_HEAD));
  assertTrue(cleanedUp.contains(Ref.ORIG_HEAD));
  assertTrue(cleanedUp.contains(Ref.CHERRY_PICK_HEAD));
  assertTrue(cleanedUp.contains(MergeOp.MERGE_MSG));
  Optional<Ref> ref = geogig.command(RefParse.class).setName(Ref.MERGE_HEAD).call();
  assertFalse(ref.isPresent());
  ref = geogig.command(RefParse.class).setName(Ref.ORIG_HEAD).call();
  assertFalse(ref.isPresent());
  ref = geogig.command(RefParse.class).setName(Ref.CHERRY_PICK_HEAD).call();
  assertFalse(ref.isPresent());
  Optional<byte[]> mergeMsg = geogig.getRepository().blobStore().getBlob(MergeOp.MERGE_MSG);
  assertFalse(mergeMsg.isPresent());
  // Running it again should result in nothing being cleaned up.
  cleanedUp = geogig.command(CleanRefsOp.class).call();
  assertEquals(0, cleanedUp.size());
}

代码示例来源：origin: org.locationtech.geogig/geogig-core

@Test
public void testClean() throws Exception {
  // Set up some refs to clean up
  geogig.command(UpdateRef.class).setName(Ref.MERGE_HEAD).setNewValue(ObjectId.NULL).call();
  geogig.command(UpdateRef.class).setName(Ref.ORIG_HEAD).setNewValue(ObjectId.NULL).call();
  geogig.command(UpdateRef.class).setName(Ref.CHERRY_PICK_HEAD).setNewValue(ObjectId.NULL)
      .call();
  geogig.getRepository().blobStore().putBlob(MergeOp.MERGE_MSG, "Merge message".getBytes());
  ImmutableList<String> cleanedUp = geogig.command(CleanRefsOp.class).call();
  assertEquals(4, cleanedUp.size());
  assertTrue(cleanedUp.contains(Ref.MERGE_HEAD));
  assertTrue(cleanedUp.contains(Ref.ORIG_HEAD));
  assertTrue(cleanedUp.contains(Ref.CHERRY_PICK_HEAD));
  assertTrue(cleanedUp.contains(MergeOp.MERGE_MSG));
  Optional<Ref> ref = geogig.command(RefParse.class).setName(Ref.MERGE_HEAD).call();
  assertFalse(ref.isPresent());
  ref = geogig.command(RefParse.class).setName(Ref.ORIG_HEAD).call();
  assertFalse(ref.isPresent());
  ref = geogig.command(RefParse.class).setName(Ref.CHERRY_PICK_HEAD).call();
  assertFalse(ref.isPresent());
  Optional<byte[]> mergeMsg = geogig.getRepository().blobStore().getBlob(MergeOp.MERGE_MSG);
  assertFalse(mergeMsg.isPresent());
  // Running it again should result in nothing being cleaned up.
  cleanedUp = geogig.command(CleanRefsOp.class).call();
  assertEquals(0, cleanedUp.size());
}

代码示例来源：origin: org.locationtech.geogig/geogig-core

ref = geogig.command(RefParse.class).setName(Ref.ORIG_HEAD).call();
assertFalse(ref.isPresent());
Optional<byte[]> mergemsg = repository.blobStore().getBlob(MergeOp.MERGE_MSG);
assertFalse(mergemsg.isPresent());

代码示例来源：origin: locationtech/geogig

ref = geogig.command(RefParse.class).setName(Ref.ORIG_HEAD).call();
assertFalse(ref.isPresent());
Optional<byte[]> mergemsg = repository.blobStore().getBlob(MergeOp.MERGE_MSG);
assertFalse(mergemsg.isPresent());

内容来源于网络，如有侵权，请联系作者删除！

repository

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com