com.asakusafw.runtime.flow

Interface FlowResource

All Known Implementing Classes:

JoinResource

public interface FlowResource

Represents a resource used in runtime, and it has resource lifecycle.

Method Summary

Modifier and Type	Method and Description
default void	cleanup(org.apache.hadoop.mapreduce.JobContext context) Finalizes this resource.
default void	setup(org.apache.hadoop.mapreduce.JobContext context) Initializes this resource.

Method Detail

setup

default void setup(org.apache.hadoop.mapreduce.JobContext context)
            throws IOException,
                   InterruptedException

Initializes this resource.

Parameters:

context - the current job context

Throws:

IOException - if failed to initialize this resource

InterruptedException - if interrupted while initializing this resource

IllegalArgumentException - if configuration is not valid

IllegalStateException - if resource lifecycle has something wrong

cleanup

default void cleanup(org.apache.hadoop.mapreduce.JobContext context)
              throws IOException,
                     InterruptedException

Finalizes this resource.

Parameters:

context - the current job context

Throws:

IOException - if failed to finalizing this resource

InterruptedException - if interrupted while finalizing this resource

IllegalArgumentException - if configuration is not valid

IllegalStateException - if resource lifecycle has something wrong