Package | Description |
---|---|
com.asakusafw.testdriver.windgate |
Moderates test input/result using WindGate.
|
com.asakusafw.windgate.core |
Script models for WindGate.
|
com.asakusafw.windgate.core.process |
Provides WindGate process.
|
com.asakusafw.windgate.core.resource |
Abstract implementations of WindGate resources.
|
com.asakusafw.windgate.core.util |
Utilities for WindGate.
|
com.asakusafw.windgate.file.resource |
Resource implementation using the local file system (for testing).
|
com.asakusafw.windgate.hadoopfs |
WindGate resources using Hadoop FileSystem core classes.
|
com.asakusafw.windgate.hadoopfs.ssh |
WindGate resources using Hadoop FileSystem via SSH connection.
|
com.asakusafw.windgate.jdbc |
WindGate resources using JDBC.
|
com.asakusafw.windgate.retryable |
Retryable Process Extension for WindGate.
|
com.asakusafw.windgate.stream |
WindGate resource skeletons using Input/Output streams.
|
com.asakusafw.windgate.stream.file |
WindGate resources using local file systems.
|
Modifier and Type | Method and Description |
---|---|
static <T> ProcessScript<T> |
WindGateTestHelper.createProcessScript(Class<T> modelType,
WindGateExporterDescription description)
Creates a new
ProcessScript for testing. |
static <T> ProcessScript<T> |
WindGateTestHelper.createProcessScript(Class<T> modelType,
WindGateImporterDescription description)
Creates a new
ProcessScript for testing. |
Modifier and Type | Method and Description |
---|---|
List<ProcessScript<?>> |
GateScript.getProcesses()
Returns the member processes.
|
Constructor and Description |
---|
GateScript(String name,
List<? extends ProcessScript<?>> processes)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
<T> void |
BasicProcessProvider.execute(DriverFactory drivers,
ProcessScript<T> script) |
abstract <T> void |
ProcessProvider.execute(DriverFactory drivers,
ProcessScript<T> script)
Execute a gate process for the specified process script.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
ResourceManipulator.cleanupDrain(ProcessScript<?> script)
Cleanups the drain of this resource.
|
abstract void |
ResourceManipulator.cleanupSource(ProcessScript<?> script)
Cleanups the source of this resource.
|
<T> DrainDriver<T> |
DriverRepository.createDrain(ProcessScript<T> script) |
<T> DrainDriver<T> |
DriverFactory.createDrain(ProcessScript<T> script)
Creates a new drain driver.
|
abstract <T> DrainDriver<T> |
ResourceMirror.createDrain(ProcessScript<T> script)
Creates a new drain driver for this resource.
|
abstract <T> DrainDriver<T> |
ResourceManipulator.createDrainForDrain(ProcessScript<T> script)
Creates a new drain driver for the drain of this resource.
|
abstract <T> DrainDriver<T> |
ResourceManipulator.createDrainForSource(ProcessScript<T> script)
Creates a new drain driver for the source of this resource.
|
<T> SourceDriver<T> |
DriverRepository.createSource(ProcessScript<T> script) |
<T> SourceDriver<T> |
DriverFactory.createSource(ProcessScript<T> script)
Creates a new source driver.
|
abstract <T> SourceDriver<T> |
ResourceMirror.createSource(ProcessScript<T> script)
Creates a new source driver for this resource.
|
abstract <T> SourceDriver<T> |
ResourceManipulator.createSourceForDrain(ProcessScript<T> script)
Creates a new source driver for the drain of this resource.
|
abstract <T> SourceDriver<T> |
ResourceManipulator.createSourceForSource(ProcessScript<T> script)
Creates a new source driver for the source of this resource.
|
Modifier and Type | Method and Description |
---|---|
static <T> T |
ProcessUtil.newDataModel(String resourceName,
ProcessScript<T> script)
Creates a new data model object for the specified process.
|
Modifier and Type | Method and Description |
---|---|
void |
FileResourceManipulator.cleanupDrain(ProcessScript<?> script) |
void |
FileResourceManipulator.cleanupSource(ProcessScript<?> script) |
<T> DrainDriver<T> |
FileResourceMirror.createDrain(ProcessScript<T> script) |
<T> DrainDriver<T> |
FileResourceManipulator.createDrainForDrain(ProcessScript<T> script) |
<T> DrainDriver<T> |
FileResourceManipulator.createDrainForSource(ProcessScript<T> script) |
<T> SourceDriver<T> |
FileResourceMirror.createSource(ProcessScript<T> script) |
<T> SourceDriver<T> |
FileResourceManipulator.createSourceForDrain(ProcessScript<T> script) |
<T> SourceDriver<T> |
FileResourceManipulator.createSourceForSource(ProcessScript<T> script) |
Modifier and Type | Method and Description |
---|---|
<T> DrainDriver<T> |
HadoopFsMirror.createDrain(ProcessScript<T> script) |
<T> SourceDriver<T> |
HadoopFsMirror.createSource(ProcessScript<T> script) |
Modifier and Type | Method and Description |
---|---|
<T> DrainDriver<T> |
AbstractSshHadoopFsMirror.createDrain(ProcessScript<T> script) |
<T> SourceDriver<T> |
AbstractSshHadoopFsMirror.createSource(ProcessScript<T> script) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcResourceManipulator.cleanupDrain(ProcessScript<?> script) |
void |
JdbcResourceManipulator.cleanupSource(ProcessScript<?> script) |
<T> DrainDriver<T> |
JdbcResourceMirror.createDrain(ProcessScript<T> script) |
<T> DrainDriver<T> |
JdbcResourceManipulator.createDrainForDrain(ProcessScript<T> script) |
<T> DrainDriver<T> |
JdbcResourceManipulator.createDrainForSource(ProcessScript<T> script) |
<T> SourceDriver<T> |
JdbcResourceMirror.createSource(ProcessScript<T> script) |
<T> SourceDriver<T> |
JdbcResourceManipulator.createSourceForDrain(ProcessScript<T> script) |
<T> SourceDriver<T> |
JdbcResourceManipulator.createSourceForSource(ProcessScript<T> script) |
Modifier and Type | Method and Description |
---|---|
<T> void |
RetryableProcessProvider.execute(DriverFactory drivers,
ProcessScript<T> script) |
Modifier and Type | Method and Description |
---|---|
static <T> DataModelStreamSupport<? super T> |
StreamResourceUtil.loadSupport(ClassLoader classLoader,
String resourceName,
ProcessScript<T> script,
DriverScript.Kind direction)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
FileResourceManipulator.cleanupDrain(ProcessScript<?> script) |
void |
FileResourceManipulator.cleanupSource(ProcessScript<?> script) |
<T> DrainDriver<T> |
FileResourceMirror.createDrain(ProcessScript<T> script) |
<T> DrainDriver<T> |
FileResourceManipulator.createDrainForDrain(ProcessScript<T> script) |
<T> DrainDriver<T> |
FileResourceManipulator.createDrainForSource(ProcessScript<T> script) |
<T> SourceDriver<T> |
FileResourceMirror.createSource(ProcessScript<T> script) |
<T> SourceDriver<T> |
FileResourceManipulator.createSourceForDrain(ProcessScript<T> script) |
<T> SourceDriver<T> |
FileResourceManipulator.createSourceForSource(ProcessScript<T> script) |
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.