Examples of cascading.tap.Tap.resourceExists()

cascading.tap.Tap.resourceExists()
Method resourceExists returns true if the path represented by this instance exists. @param flowProcess of type FlowProcess @return true if the underlying resource already exists @throws IOException when the status cannot be determined

    List<FlowStep> steps = flow.getFlowSteps();


    for( FlowStep step : steps )
      {
      Tap sink = step.getSink();
      if( flow.getSink() != sink && sink.resourceExists( flow.getConfig() ) )
        count++;
      }


    assertEquals( "wrong number of intermediate resources exist", 1, count );

View Full Code Here


      sourceModified = source.getModifiedTime( confCopy );


      // source modified returns zero if does not exist
      // this should minimize number of times we touch any file meta-data server
      if( sourceModified == 0 && !source.resourceExists( confCopy ) )
        throw new FlowException( "source does not exist: " + source );


      if( sinkModified < sourceModified )
        return sourceModified;
      }

View Full Code Here

      {
      Tap tap = catalog.createTapFor( tableDef, SinkMode.KEEP );


      if( tap != null )
        {
        if( !tap.resourceExists( platformBroker.getSystemConfig() ) )
          return 0.0;
        else if( tap instanceof FileType )
          return ( (FileType) tap ).getSize( platformBroker.getSystemConfig() ); // actually returns bytes
        }
      }

View Full Code Here

TOP

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.