org.kitesdk.data.URIBuilder.<init>()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(5.7k)|赞(0)|评价(0)|浏览(95)

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

URIBuilder.<init>介绍

[英]Constructs a builder based on the given dataset or view URI string.
[中]基于给定的数据集或视图URI字符串构造生成器。

代码示例

代码示例来源:origin: apache/nifi

@Override
  public ValidationResult validate(String subject, String uri, ValidationContext context) {
    String message = "not set";
    boolean isValid = true;
    if (uri.trim().isEmpty()) {
      isValid = false;
    } else {
      final boolean elPresent = context.isExpressionLanguageSupported(subject) && context.isExpressionLanguagePresent(uri);
      if (!elPresent) {
        try {
          new URIBuilder(URI.create(uri)).build();
        } catch (RuntimeException e) {
          message = e.getMessage();
          isValid = false;
        }
      }
    }
    return new ValidationResult.Builder()
        .subject(subject)
        .input(uri)
        .explanation("Dataset URI is invalid: " + message)
        .valid(isValid)
        .build();
  }
};

代码示例来源:origin: apache/flume

DEFAULT_NAMESPACE);
this.datasetUri = new URIBuilder(repositoryURI, namespace, datasetName)
  .build();

代码示例来源:origin: kite-sdk/kite

@Override
public URI getUri() {
 URIBuilder builder = new URIBuilder(dataset.getUri());
 for (Map.Entry<String, String> entry : constraints.toQueryMap().entrySet()) {
  builder.with(entry.getKey(), entry.getValue());
 }
 return builder.build();
}

代码示例来源:origin: kite-sdk/kite

@Override
 public void run() {
  new URIBuilder("dataset:file:/datasets/test-name", "ns", "test-name-2")
    .build();
 }
});

代码示例来源:origin: kite-sdk/kite

@Override
 public void run() {
  new URIBuilder((URI) null).build();
 }
});

代码示例来源:origin: kite-sdk/kite

@Test
public void testBuildDatasetUri() {
 URI uri = new URIBuilder("repo:file:/tmp/data", "ns", "test-ds").build();
 Assert.assertEquals(URI.create("dataset:file:/tmp/data/ns/test-ds"), uri);
}

代码示例来源:origin: kite-sdk/kite

@Test
 public void testRepoUriHasQueryString() {
  URI uri = new URIBuilder("repo:file:/tmp/data?repoParam=x", "ns", "test-ds")
    .with("username", "bob")
    .build();
  
  Assert.assertEquals(URI.create("view:file:/tmp/data/ns/test-ds?repoParam=x&username=bob"), uri);
 }
}

代码示例来源:origin: kite-sdk/kite

@Override
 public void run() {
  Datasets.list(new URIBuilder(repoUri, "ns", "test").build());
 }
});

代码示例来源:origin: kite-sdk/kite

@Test
public void testDeleteStringUri() {
 URI datasetUri = new URIBuilder(repoUri, "ns", "test").build();
 Datasets.delete(datasetUri.toString());
 verify(repo).delete("ns", "test");
 verifyNoMoreInteractions(repo);
}

代码示例来源:origin: kite-sdk/kite

@Test
public void testRepoUriAndNameToDatasetUri() {
 Assert.assertEquals("Should construct the correct dataset URI",
   URI.create("dataset:file:/datasets/ns/test-name"),
   new URIBuilder("repo:file:/datasets", "ns", "test-name").build());
}

代码示例来源:origin: kite-sdk/kite

@Test
public void testDatasetUriToDatasetUri() {
 Assert.assertEquals("Should produce an equivalent dataset URI",
   URI.create("dataset:file:/datasets/test-name"),
   new URIBuilder("dataset:file:/datasets/test-name").build());
}

代码示例来源:origin: kite-sdk/kite

@Test
public void testExistsStringUri() {
 URI datasetUri = new URIBuilder(repoUri, "ns", "test").build();
 when(repo.exists("ns", "test")).thenReturn(false);
 Assert.assertFalse(Datasets.exists(datasetUri.toString()));
 verify(repo).exists("ns", "test");
 verifyNoMoreInteractions(repo);
}

代码示例来源:origin: kite-sdk/kite

@Test
public void testMoveToTrash() {
 URI datasetUri = new URIBuilder(repoUri, "ns", "test").build();
 Datasets.moveToTrash(datasetUri);
 verify(repo).moveToTrash("ns", "test");
 verifyNoMoreInteractions(repo);
}

代码示例来源:origin: kite-sdk/kite

@Test
public void testDelete() {
 URI datasetUri = new URIBuilder(repoUri, "ns", "test").build();
 Datasets.delete(datasetUri);
 verify(repo).delete("ns", "test");
 verifyNoMoreInteractions(repo);
}

代码示例来源:origin: kite-sdk/kite

@Override
 public void run() {
  Datasets.list(new URIBuilder(repoUri, "ns", "test")
    .with("field", 34)
    .build());
 }
});

代码示例来源:origin: kite-sdk/kite

@Test
public void testRepositoryFor() {
 URI datasetUri = new URIBuilder(repoUri, "ns", "test").build();
 Assert.assertEquals(repo, DatasetRepositories.repositoryFor(datasetUri));
 verifyNoMoreInteractions(repo);
}

代码示例来源:origin: kite-sdk/kite

@Test
 public void testEmptyConstraints() {
  Assert.assertEquals("Empty constraints should produce dataset URI",
    URI.create("dataset:file:/datasets/test"),
    new URIBuilder("dataset:file:/datasets/test")
      .constraints(empty)
      .build());
 }
}

代码示例来源:origin: kite-sdk/kite

@Test
public void testRepositoryForView() {
 URI datasetUri = new URIBuilder(repoUri, "ns", "test")
   .with("field", 34)
   .build();
 Assert.assertEquals(repo, DatasetRepositories.repositoryFor(datasetUri));
 verifyNoMoreInteractions(repo);
}

代码示例来源:origin: kite-sdk/kite

@Test(expected=NullPointerException.class)
public void testCreateNullType() {
 URI datasetUri = new URIBuilder(repoUri, "ns", "test").build();
 DatasetDescriptor descriptor = new DatasetDescriptor.Builder()
   .schemaLiteral("\"string\"")
   .build();
 Datasets.<Object, Dataset<Object>> create(datasetUri, descriptor, null);
}

代码示例来源:origin: kite-sdk/kite

@Test(expected=NullPointerException.class)
public void testUpdateNullType() {
 URI datasetUri = new URIBuilder(repoUri, "ns", "test").build();
 DatasetDescriptor descriptor = new DatasetDescriptor.Builder()
   .schemaLiteral("\"string\"")
   .build();
 Datasets.<Object, Dataset<Object>> update(datasetUri, descriptor, null);
}

相关文章