源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.flink.core.fs.RecoverableFsDataOutputStream.Committer

示例1
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	if (recoverable instanceof LocalRecoverable) {
		return new LocalRecoverableFsDataOutputStream.LocalCommitter((LocalRecoverable) recoverable);
	}
	else {
		throw new IllegalArgumentException(
				"LocalFileSystem cannot recover recoverable for other file system: " + recoverable);
	}
}
示例2
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	if (recoverable instanceof HadoopFsRecoverable) {
		return new HadoopRecoverableFsDataOutputStream.HadoopFsCommitter(fs, (HadoopFsRecoverable) recoverable);
	}
	else {
		throw new IllegalArgumentException(
				"Hadoop File System  cannot recover a recoverable for another file system: " + recoverable);
	}
}
示例3
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	if (recoverable instanceof LocalRecoverable) {
		return new LocalRecoverableFsDataOutputStream.LocalCommitter((LocalRecoverable) recoverable);
	}
	else {
		throw new IllegalArgumentException(
				"LocalFileSystem cannot recover recoverable for other file system: " + recoverable);
	}
}
示例4
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	if (recoverable instanceof HadoopFsRecoverable) {
		return new HadoopRecoverableFsDataOutputStream.HadoopFsCommitter(fs, (HadoopFsRecoverable) recoverable);
	}
	else {
		throw new IllegalArgumentException(
				"Hadoop File System  cannot recover a recoverable for another file system: " + recoverable);
	}
}
示例5
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	if (recoverable instanceof LocalRecoverable) {
		return new LocalRecoverableFsDataOutputStream.LocalCommitter((LocalRecoverable) recoverable);
	}
	else {
		throw new IllegalArgumentException(
				"LocalFileSystem cannot recover recoverable for other file system: " + recoverable);
	}
}
示例6
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	if (recoverable instanceof HadoopFsRecoverable) {
		return new HadoopRecoverableFsDataOutputStream.HadoopFsCommitter(fs, (HadoopFsRecoverable) recoverable);
	}
	else {
		throw new IllegalArgumentException(
				"Hadoop File System  cannot recover a recoverable for another file system: " + recoverable);
	}
}
示例7
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	final S3Recoverable s3recoverable = castToS3Recoverable(recoverable);
	final S3RecoverableFsDataOutputStream recovered = recover(s3recoverable);
	return recovered.closeForCommit();
}
示例8
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	final S3Recoverable s3recoverable = castToS3Recoverable(recoverable);
	final S3RecoverableFsDataOutputStream recovered = recover(s3recoverable);
	return recovered.closeForCommit();
}
示例9
@Override
public Committer recoverForCommit(CommitRecoverable recoverable) throws IOException {
	final S3Recoverable s3recoverable = castToS3Recoverable(recoverable);
	final S3RecoverableFsDataOutputStream recovered = recover(s3recoverable);
	return recovered.closeForCommit();
}