Java源码示例:org.apache.flink.util.WrappingProxy

示例1
private static FileSystem getFileSystemWithoutSafetyNet(final String uri) throws URISyntaxException, IOException {
	final FileSystem fileSystem = FileSystem.get(new URI(uri));

	if (fileSystem instanceof WrappingProxy) {
		//noinspection unchecked
		return WrappingProxyUtil.stripProxy((WrappingProxy<FileSystem>) fileSystem);
	}

	return fileSystem;
}
 
示例2
private static FileSystem getFileSystemWithoutSafetyNet(final String uri) throws URISyntaxException, IOException {
	final FileSystem fileSystem = FileSystem.get(new URI(uri));

	if (fileSystem instanceof WrappingProxy) {
		//noinspection unchecked
		return WrappingProxyUtil.stripProxy((WrappingProxy<FileSystem>) fileSystem);
	}

	return fileSystem;
}
 
示例3
private static FileSystem getFileSystemWithoutSafetyNet(final String uri) throws URISyntaxException, IOException {
	final FileSystem fileSystem = FileSystem.get(new URI(uri));

	if (fileSystem instanceof WrappingProxy) {
		//noinspection unchecked
		return WrappingProxyUtil.stripProxy((WrappingProxy<FileSystem>) fileSystem);
	}

	return fileSystem;
}