Sha256: 743b8c279565a0da509746f24e914293a74705a65e1816dddad36457dcd43b75
Contents?: true
Size: 956 Bytes
Versions: 104
Compression:
Stored size: 956 Bytes
Contents
package org.embulk.plugin.compat;
import org.embulk.spi.InputPlugin;
import org.embulk.spi.TransactionalFileInput;
import org.embulk.spi.TransactionalFileOutput;
import org.embulk.spi.TransactionalPageOutput;
import org.embulk.plugin.compat.InputPluginWrapper;
public class PluginWrappers
{
public static InputPlugin inputPlugin(InputPlugin input)
{
return InputPluginWrapper.wrapIfNecessary(input);
}
public static TransactionalFileInput transactionalFileInput(TransactionalFileInput tran)
{
return TransactionalFileInputWrapper.wrapIfNecessary(tran);
}
public static TransactionalFileOutput transactionalFileOutput(TransactionalFileOutput tran)
{
return TransactionalFileOutputWrapper.wrapIfNecessary(tran);
}
public static TransactionalPageOutput transactionalPageOutput(TransactionalPageOutput tran)
{
return TransactionalPageOutputWrapper.wrapIfNecessary(tran);
}
}
Version data entries
104 entries across 104 versions & 1 rubygems