List of sinkConfInit() Examples

Examples of sinkConfInit()

cascading.scheme.Scheme.sinkConfInit()

Method sinkInit initializes this instance as a sink.

This method is executed client side as a means to provide necessary configuration parameters used by the underlying platform.

It is not intended to initialize resources that would be necessary during the execution of this class, like a "formatter" or "parser".

See {@link #sinkPrepare(cascading.flow.FlowProcess,SinkCall)} if resources much be initializedbefore use. And {@link #sinkCleanup(cascading.flow.FlowProcess,SinkCall)} if resources must bedestroyed after use. @param flowProcess of type FlowProcess @param tap of type Tap @param conf of type Config

cascading.tap.Tap.sinkConfInit()

Method sinkConfInit initializes this instance as a sink.

This method maybe called more than once if this Tap instance is used outside the scope of a {@link cascading.flow.Flow}instance or if it participates in multiple times in a given Flow or across different Flows in a {@link cascading.cascade.Cascade}.

Note this method will be called in context of this Tap being used as a traditional 'sink' and as a 'trap'.

In the context of a Flow, it will be called after {@link cascading.flow.FlowListener#onStarting(cascading.flow.Flow)}

Note that no resources or services should be modified by this method. If this Tap instance returns true for {@link #isReplace()}, then {@link #deleteResource(Object)} will be called by the parent Flow. @param flowProcess of type FlowProcess @param conf of type Config

            fail();
        } catch (UnsupportedOperationException ex) {
        }


        try {
            scheme.sinkConfInit(null, null, null);
            fail();
        } catch (UnsupportedOperationException ex) {
        }


        try {

        Tap tap = (Tap) element;


        if( tap.getIdentifier() == null )
          throw new IllegalStateException( "tap may not have null identifier: " + element.toString() );


        tap.sinkConfInit( flowProcess, current );


        setLocalMode( conf, current, tap );
        }


      String id = FlowElements.id( element );

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.

Examples of sinkConfInit()

Examples of cascading.scheme.Scheme.sinkConfInit()

Examples of cascading.tap.Tap.sinkConfInit()