本文整理了Java中org.pentaho.di.core.Const.getStackTracker()
方法的一些代码示例,展示了Const.getStackTracker()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Const.getStackTracker()
方法的具体详情如下:
包路径:org.pentaho.di.core.Const
类名称:Const
方法名:getStackTracker
[英]Returns a string of the stack trace of the specified exception
[中]返回指定异常的堆栈跟踪字符串
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public void run() {
try {
cleanupJarFiles( jarFiles );
} catch ( Exception e ) {
System.err.println( "Error cleaning up temporary Talend jar file extracts: "
+ Const.getStackTracker( e ) );
}
}
} );
代码示例来源:origin: pentaho/pentaho-kettle
@VisibleForTesting
static String calculateString( final String packageName, final Locale locale, final String key,
final Object[] parameters, final Class<?> resourceClass, final String bundleName,
final boolean fallbackOnRoot ) throws MissingResourceException {
try {
ResourceBundle bundle = getBundle( locale, packageName + "." + bundleName, resourceClass, fallbackOnRoot );
String unformattedString = bundle.getString( key );
String string = MessageFormat.format( unformattedString, parameters );
return string;
} catch ( IllegalArgumentException e ) {
final StringBuilder msg = new StringBuilder();
msg.append( "Format problem with key=[" ).append( key ).append( "], locale=[" ).append( locale ).append(
"], package=" ).append( packageName ).append( " : " ).append( e.toString() );
log.error( msg.toString() );
log.error( Const.getStackTracker( e ) );
throw new MissingResourceException( msg.toString(), packageName, key );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void showDocumentMap() {
try {
URL url = new URL( DOCUMENTATION_URL );
HelpUtils.openHelpDialog( shell, STRING_DOCUMENT_TAB_NAME, url.toString() );
} catch ( MalformedURLException e1 ) {
log.logError( Const.getStackTracker( e1 ) );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
private String reEncodeWriteAccessIfNecessary( String writeAccess ) {
if ( writeAccess == null || writeAccess.length() == 0 ) {
return writeAccess;
}
byte[] data = new byte[112];
try {
// jxl reads writeAccess with "UnicodeLittle" encoding, but will try to write later with "file.encoding"
// this throws an ArrayIndexOutOfBoundsException in *nix systems
StringHelper.getBytes( writeAccess, data, 0 );
} catch ( ArrayIndexOutOfBoundsException e ) {
try {
// properly re-encoding string from UnicodeLittle, removing BOM characters
return new String( writeAccess.getBytes( "UnicodeLittle" ), System.getProperty( "file.encoding" ) ).substring( 2 );
} catch ( UnsupportedEncodingException e1 ) {
logError( Const.getStackTracker( e ) );
}
}
return writeAccess;
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public ErrorDialog( Shell parent, String title, String message, Throwable throwable, Function<String, String> exMsgFunction ) {
super( parent, SWT.NONE );
this.exMsgFunction = exMsgFunction;
throwable.printStackTrace();
// this.log = new LogChannel("ErrorDialog");
// log.logError(message, throwable);
if ( throwable instanceof Exception ) {
showErrorDialog( parent, title, message, (Exception) throwable, false );
} else {
// not optimal, but better then nothing
showErrorDialog( parent, title, message + Const.CR + Const.getStackTracker( throwable ), null, false );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public void run() {
try {
InputStreamReader isr = new InputStreamReader( is );
BufferedReader br = new BufferedReader( isr );
String line = null;
while ( ( line = br.readLine() ) != null ) {
lastLine = line;
if ( errorStream ) {
log.logError( type + " " + line );
} else {
log.logBasic( type + " " + line );
}
}
} catch ( IOException ioe ) {
log.logError( type + " " + Const.getStackTracker( ioe ) );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
/**
* Puts the steps in alphabetical order.
*/
public void sortSteps() {
try {
Collections.sort( steps );
} catch ( Exception e ) {
log.logError( BaseMessages.getString( PKG, "TransMeta.Exception.ErrorOfSortingSteps" ) + e );
log.logError( Const.getStackTracker( e ) );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public Object nativeToJava( TransferData transferData ) {
if ( isSupportedType( transferData ) ) {
try {
byte[] buffer = (byte[]) super.nativeToJava( transferData );
String xml = new String( Base64.decodeBase64( new String( buffer ).getBytes() ) );
return new DragAndDropContainer( xml );
} catch ( Exception e ) {
log.logError( "Unexpected error trying to read a drag and drop container from the XML Transfer type: "
+ e.toString() );
log.logError( Const.getStackTracker( e ) );
return null;
}
}
return null;
}
代码示例来源:origin: pentaho/pentaho-kettle
@Override
public void dispose( StepMetaInterface smi, StepDataInterface sdi ) {
try {
if ( data.fc != null ) {
data.fc.close();
}
if ( data.fis != null ) {
data.fis.close();
}
} catch ( IOException e ) {
logError( "Unable to close file channel for file '" + meta.getFilename() + "' : " + e.toString() );
logError( Const.getStackTracker( e ) );
}
super.dispose( smi, sdi );
}
代码示例来源:origin: pentaho/pentaho-kettle
public void javaToNative( Object object, TransferData transferData ) {
if ( !checkMyType( object ) ) {
return; // DND.error(DND.ERROR_INVALID_DATA);
}
try {
byte[] buffer =
Base64.encodeBase64( ( (DragAndDropContainer) object ).getXML().getBytes( Const.XML_ENCODING ) );
super.javaToNative( buffer, transferData );
} catch ( Exception e ) {
log.logError( "Unexpected error trying to put a string onto the XML Transfer type: " + e.toString() );
log.logError( Const.getStackTracker( e ) );
return;
}
}
代码示例来源:origin: pentaho/pentaho-kettle
private synchronized void safeClosePipe() {
if ( !triedToClosePipe ) {
try {
closePipe();
} catch ( Exception e ) {
logError( BaseMessages.getString( PKG, "InfobrightLoader.Log.UnexpectedError" ) + " : " + e.toString() );
logError( Const.getStackTracker( e ) );
} finally {
triedToClosePipe = true;
}
}
}
代码示例来源:origin: pentaho/pentaho-kettle
protected boolean writeEndedLine() {
boolean retval = false;
try {
String sLine = environmentSubstitute( meta.getEndedLine() );
if ( sLine != null ) {
if ( sLine.trim().length() > 0 ) {
data.writer.write( getBinaryString( sLine ) );
incrementLinesOutput();
}
}
} catch ( Exception e ) {
logError( "Error writing ended tag line: " + e.toString() );
logError( Const.getStackTracker( e ) );
retval = true;
}
return retval;
}
代码示例来源:origin: pentaho/pentaho-kettle
public void println( LogMessageInterface message, Throwable e, LogLevel channelLogLevel ) {
println( message, channelLogLevel );
String stackTrace = Const.getStackTracker( e );
LogMessage traceMessage = new LogMessage( stackTrace, message.getLogChannelId(), LogLevel.ERROR );
println( traceMessage, channelLogLevel );
}
代码示例来源:origin: pentaho/pentaho-kettle
@Override public void run() {
try {
Result threadResult = execute( nr + 1, newResult, nextEntry, jobEntryCopy, nextComment );
threadResults.add( threadResult );
} catch ( Throwable e ) {
log.logError( Const.getStackTracker( e ) );
threadExceptions.add( new KettleException( BaseMessages.getString( PKG, "Job.Log.UnexpectedError",
nextEntry.toString() ), e ) );
Result threadResult = new Result();
threadResult.setResult( false );
threadResult.setNrErrors( 1L );
threadResults.add( threadResult );
}
}
};
代码示例来源:origin: pentaho/pentaho-kettle
public void println( LogMessageInterface message, Throwable e, LogLevel channelLogLevel ) {
println( message, channelLogLevel );
String stackTrace = Const.getStackTracker( e );
LogMessage traceMessage = new LogMessage( stackTrace, message.getLogChannelId(), LogLevel.ERROR );
println( traceMessage, channelLogLevel );
}
代码示例来源:origin: pentaho/pentaho-kettle
public void close() throws KettleException {
if ( ctx != null ) {
try {
ctx.close();
if ( log.isBasic() ) {
log.logBasic( BaseMessages.getString( PKG, "LDAPInput.log.Disconnection.Done" ) );
}
} catch ( Exception e ) {
log.logError( BaseMessages.getString( PKG, "LDAPInput.Exception.ErrorDisconecting", e.toString() ) );
log.logError( Const.getStackTracker( e ) );
} finally {
ctx = null;
}
}
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public boolean init( StepMetaInterface smi, StepDataInterface sdi ) {
meta = (SocketWriterMeta) smi;
data = (SocketWriterData) sdi;
if ( super.init( smi, sdi ) ) {
try {
data.serverSocketPort = Integer.parseInt( environmentSubstitute( meta.getPort() ) );
data.serverSocket =
getTrans().getSocketRepository().openServerSocket(
data.serverSocketPort, getTransMeta().getName() + " - " + this.toString() );
return true;
} catch ( Exception e ) {
logError( "Error creating server socket: " + e.toString() );
logError( Const.getStackTracker( e ) );
}
}
return false;
}
代码示例来源:origin: pentaho/pentaho-kettle
public static void main( String[] args ) {
Display display = new Display();
LogChannelInterface log = new LogChannel( APP_NAME );
PropsUI.init( display, Props.TYPE_PROPERTIES_SPOON );
Translator translator = new Translator( display );
translator.open();
try {
while ( !display.isDisposed() ) {
if ( !display.readAndDispatch() ) {
display.sleep();
}
}
} catch ( Throwable e ) {
log.logError( "An unexpected error occurred : " + e.getMessage() );
log.logError( Const.getStackTracker( e ) );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
private synchronized boolean keepRow( RowMetaInterface rowMeta, Object[] row ) throws KettleException {
try {
return meta.getCondition().evaluate( rowMeta, row );
} catch ( Exception e ) {
String message =
BaseMessages.getString( PKG, "FilterRows.Exception.UnexpectedErrorFoundInEvaluationFuction" );
logError( message );
logError( BaseMessages.getString( PKG, "FilterRows.Log.ErrorOccurredForRow" ) + rowMeta.getString( row ) );
logError( Const.getStackTracker( e ) );
throw new KettleException( message, e );
}
}
代码示例来源:origin: pentaho/pentaho-kettle
public void run() {
logBasic( "Starting to run..." );
try {
while ( processRow( meta, data ) && !isStopped() ) {
// Process rows
}
} catch ( Exception e ) {
logError( "Unexpected error : " + e.toString() );
logError( Const.getStackTracker( e ) );
setErrors( 1 );
stopAll();
} finally {
dispose( meta, data );
logBasic( "Finished, processing " + getLinesRead() + " rows" );
markStop();
}
}
}
内容来源于网络,如有侵权,请联系作者删除!