本文整理了Java中org.kitesdk.data.URIBuilder.build()
方法的一些代码示例,展示了URIBuilder.build()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。URIBuilder.build()
方法的具体详情如下:
包路径:org.kitesdk.data.URIBuilder
类名称:URIBuilder
方法名:build
[英]Returns a dataset or view URI encompassing the given constraints. The referenced Dataset or View may be loaded again with Datasets#load(URI,Class).
[中]返回包含给定约束的数据集或视图URI。引用的数据集或视图可能会再次加载数据集#load(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
.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 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 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 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
@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
@Override
public void run() {
Datasets.list(new URIBuilder(repoUri, "ns", "test")
.with("field", 34)
.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);
}
内容来源于网络,如有侵权,请联系作者删除!