Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2012 International Business Machines Corp.
   * 
   * See the NOTICE file distributed with this work for additional information
   * regarding copyright ownership. Licensed under the Apache License, 
   * Version 2.0 (the "License"); you may not use this file except in compliance
   * with the License. You may obtain a copy of the License at
   * 
   *   http://www.apache.org/licenses/LICENSE-2.0
  * 
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
 */
 package com.ibm.jbatch.container.jobinstance;
 
 import java.util.Date;
 
 
 
 public class StepExecutionImpl implements StepExecutionSerializable {
     
     private long commitCount = 0;
     private Timestamp endTime = null;
     private String exitStatus = null;
     private BatchStatus batchStatus = null;
     
     private long filterCount = 0;
     private long jobExecutionId = 0;
     private Timestamp lastUpdateTime = null;
     private long processSkipCount = 0;
     private long readCount = 0;
     private long readSkipCount = 0;
     private long rollbackCount = 0;
     private Timestamp startTime = null;
     private long stepExecutionId = 0;
     private String stepName = null;
     
     private long writeCount = 0;
     private long writeSkipCount = 0;
     
     private PartitionPlan plan = null;
     
     private Serializable persistentUserData = null;
     
     private StepContextImpl stepContext = null;
     
     public StepExecutionImpl(long jobExecutionIdlong stepExecutionId) {
     	this. = jobExecutionId;
     	this. = stepExecutionId;
     }
    
    
 
     private static final long serialVersionUID = 1L;
 
     @Override
     public long getStepExecutionId() {
         return this.;
     }
     
     @Override
     public Date getEndTime() {
         
     	if ( != null){
     		return this..getEndTimeTS();
     	}
     	else {
     		return new Date(.getTime());
     	}
     }
 
     // Not a spec API but for internal use.
     public long getJobExecutionId(){
     	return this.;
     }
     
     @Override
     public String getExitStatus() {
     	if ( != null){
     		return this..getExitStatus();
     	}
     	else {
     		return ;
     	}
     }
 
     @Override
    public Date getStartTime() {
       	if ( != null){
    		return this..getStartTimeTS();
    	}
    	else {
    		return new Date(.getTime());
    	}
    }
    @Override
    public String toString() {
        StringBuffer buf = new StringBuffer();
		buf.append("---------------------------------------------------------------------------------");
		buf.append("getStepName(): " + this.getStepName() + "\n");
		buf.append("getStepExecutionId(): " + this. + "\n");
		buf.append("getJobExecutionId(): " + this. + "\n");			
		//buf.append("getCommitCount(): " + this.getCommitCount() + "\n");
		//buf.append("getFilterCount(): " + this.getFilterCount() + "\n");
		//buf.append("getProcessSkipCount(): " + this.getProcessSkipCount() + "\n");
		//buf.append("getReadCount(): " + this.getReadCount() + "\n");
		//buf.append("getReadSkipCount(): " + this.getReadSkipCount() + "\n");
		//buf.append("getRollbackCount(): " + this.getRollbackCount() + "\n");
		//buf.append("getWriteCount(): " + this.getWriteCount() + "\n");
		//buf.append("getWriteSkipCount(): " + this.getWriteSkipCount() + "\n");
		buf.append("getStartTime(): " + this.getStartTime() + "\n");
		buf.append("getEndTime(): " + this.getEndTime() + "\n");
		//buf.append("getLastUpdateTime(): " + this.getLastUpdateTime() + "\n");
		buf.append("getBatchStatus(): " + this.getBatchStatus().name() + "\n");
		buf.append("getExitStatus(): " + this.getExitStatus());
		buf.append("---------------------------------------------------------------------------------");
        return buf.toString();
    }
	public Metric[] getMetrics() {
		if ( != null){
		}
		else {
			Metric[] metrics = new MetricImpl[8];
			return metrics;
		}
	}
		if ( != null){
		}
		else {
			return ;
		}
	}
		if ( != null){
		}
		else {
			return this.;
		}
	}
    
	// impl specific setters
    public void setFilterCount(long filterCnt) {
        this. = filterCnt;
    }
    public void setLastUpdateTime(Timestamp lastUpdateTime) {
        this. = lastUpdateTime;
    }
    public void setProcessSkipCount(long processSkipCnt) {
        this. = processSkipCnt;
    }
    public void setReadCount(long readCnt) {
        this. = readCnt;
    }
    public void setReadSkipCount(long readSkipCnt) {
        this. = readSkipCnt;
    }
    public void setRollbackCount(long rollbackCnt) {
        this. = rollbackCnt;
    }
    
    public void setJobExecutionId(long jobexecID){
    	this. = jobexecID;
    }
    
    public void setStepExecutionId(long stepexecID){
    	this. = stepexecID;
    }
        
    public void setStepName(String stepName) {
        this. = stepName;
    }
    public void setWriteCount(long writeCnt) {     
        this. = writeCnt;
    }
    public void setWriteSkipCount(long writeSkipCnt) {        
        this. = writeSkipCnt;
    }  
    
    public void setStepContext(StepContextImpl stepContext) {
        this. = stepContext;
    }
    
    public void setCommitCount(long commitCnt) {
        this. = commitCnt;
    }
    
    public void setBatchStatus(BatchStatus batchstatus){
    	this. = batchstatus;
    }
    
    public void setExitStatus(String exitstatus){
    	this. = exitstatus;
    }
    
    public void setStartTime(Timestamp startts){
    	this. = startts;
    }
    
    public void setEndTime(Timestamp endts){
    	this. = endts;
    }
    
    public void setpersistentUserData(Serializable data){
    	this. = data;
    }
	public String getStepName() {
    	if ( != null){
    		return this..getStepName();
    	}
    	else {
    		return ;
    	}
	}
	public void setPlan(PartitionPlan plan) {
		this. = plan;
	}
	public PartitionPlan getPlan() {
		return ;
	}
New to GrepCode? Check out our FAQ X