本文整理了Java中org.hibernate.search.util.logging.impl.Log.isTraceEnabled()
方法的一些代码示例,展示了Log.isTraceEnabled()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Log.isTraceEnabled()
方法的具体详情如下:
包路径:org.hibernate.search.util.logging.impl.Log
类名称:Log
方法名:isTraceEnabled
暂无
代码示例来源:origin: hibernate/hibernate-search
@Override
public boolean isEnabled(String component) {
return logger.isTraceEnabled();
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public boolean isEnabled(String component) {
return logger.isTraceEnabled();
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void run() {
if ( copyTask.inProgress.compareAndSet( false, true ) ) {
executor.execute( copyTask );
}
else {
if ( log.isTraceEnabled() ) {
@SuppressWarnings("unused")
int unneeded = current;//ensure visibility of indexName in Timer threads.
log.tracef( "Skipping directory synchronization, previous work still in progress: %s", indexDir );
}
}
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void run() {
if ( copyTask.inProgress.compareAndSet( false, true ) ) {
executor.execute( copyTask );
}
else {
if ( log.isTraceEnabled() ) {
@SuppressWarnings("unused")
int unneeded = current;//ensure visibility of indexName in Timer threads.
log.tracef( "Skipping directory synchronization, previous work still in progress: %s", indexDir );
}
}
}
代码示例来源:origin: hibernate/hibernate-search
public void clear() {
if ( log.isTraceEnabled() ) {
log.trace( "Clearing current work queue" );
}
plan.clear();
this.sealedAndUnchanged = false;
if ( sealedQueue != null ) {
sealedQueue.clear();
}
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
public void clear() {
if ( log.isTraceEnabled() ) {
log.trace( "Clearing current work queue" );
}
plan.clear();
this.sealedAndUnchanged = false;
if ( sealedQueue != null ) {
sealedQueue.clear();
}
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void performWorks(WorkQueue workQueue) {
List<LuceneWork> sealedQueue = workQueue.getSealedQueue();
if ( log.isTraceEnabled() ) {
StringBuilder sb = new StringBuilder( "Lucene WorkQueue to send to backends:[ \n\t" );
for ( LuceneWork lw : sealedQueue ) {
sb.append( lw.toString() );
sb.append( "\n\t" );
}
if ( sealedQueue.size() > 0 ) {
sb.deleteCharAt( sb.length() - 1 );
}
sb.append( "]" );
log.trace( sb.toString() );
}
operationDispatcher.dispatch( sealedQueue, null );
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void performWorks(WorkQueue workQueue) {
List<LuceneWork> sealedQueue = workQueue.getSealedQueue();
if ( log.isTraceEnabled() ) {
StringBuilder sb = new StringBuilder( "Lucene WorkQueue to send to backends:[ \n\t" );
for ( LuceneWork lw : sealedQueue ) {
sb.append( lw.toString() );
sb.append( "\n\t" );
}
if ( sealedQueue.size() > 0 ) {
sb.deleteCharAt( sb.length() - 1 );
}
sb.append( "]" );
log.trace( sb.toString() );
}
operationDispatcher.dispatch( sealedQueue, null );
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void submit(List<LuceneWork> workList, IndexingMonitor monitor) {
if ( workList.isEmpty() ) {
// only log this error at trace level until we properly fix HSEARCH-1769
if ( log.isTraceEnabled() ) {
StringWriter stackTraceStringWriter = new StringWriter();
PrintWriter stackTracePrintWriter = new PrintWriter( stackTraceStringWriter );
new Throwable().printStackTrace( stackTracePrintWriter );
log.workListShouldNeverBeEmpty( stackTraceStringWriter.toString() );
}
// skip that work
return;
}
LuceneBackendQueueTask luceneBackendQueueProcessor = new LuceneBackendQueueTask(
workList,
resources,
monitor
);
resources.submitToAsyncIndexingExecutor( luceneBackendQueueProcessor );
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void submit(List<LuceneWork> workList, IndexingMonitor monitor) {
if ( workList.isEmpty() ) {
// only log this error at trace level until we properly fix HSEARCH-1769
if ( log.isTraceEnabled() ) {
StringWriter stackTraceStringWriter = new StringWriter();
PrintWriter stackTracePrintWriter = new PrintWriter( stackTraceStringWriter );
new Throwable().printStackTrace( stackTracePrintWriter );
log.workListShouldNeverBeEmpty( stackTraceStringWriter.toString() );
}
// skip that work
return;
}
LuceneBackendQueueTask luceneBackendQueueProcessor = new LuceneBackendQueueTask(
workList,
resources,
monitor
);
resources.submitToAsyncIndexingExecutor( luceneBackendQueueProcessor );
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
public IndexedTypeSet getConfiguredClasses(IndexedTypeSet types) {
if ( types == null ) {
return IndexedTypeSets.empty();
}
Set<IndexedTypeIdentifier> indexedClasses = new HashSet<IndexedTypeIdentifier>();
for ( IndexedTypeIdentifier type : types ) {
Class<?> clazz = type.getPojoType();
Set<IndexedTypeIdentifier> set = classToConfiguredClass.get( clazz );
if ( set != null ) {
// at this point we don't have to care about including indexed subclasses of a indexed class
// MultiClassesQueryLoader will take care of this later and optimise the queries
indexedClasses.addAll( set );
}
}
if ( log.isTraceEnabled() ) {
log.tracef( "Targeted indexed classes for %s: %s", types, indexedClasses );
}
return IndexedTypeSets.fromIdentifiers( indexedClasses );
}
}
代码示例来源:origin: hibernate/hibernate-search
public IndexedTypeSet getConfiguredClasses(IndexedTypeSet types) {
if ( types == null ) {
return IndexedTypeSets.empty();
}
Set<IndexedTypeIdentifier> indexedClasses = new HashSet<IndexedTypeIdentifier>();
for ( IndexedTypeIdentifier type : types ) {
Class<?> clazz = type.getPojoType();
Set<IndexedTypeIdentifier> set = classToConfiguredClass.get( clazz );
if ( set != null ) {
// at this point we don't have to care about including indexed subclasses of a indexed class
// MultiClassesQueryLoader will take care of this later and optimise the queries
indexedClasses.addAll( set );
}
}
if ( log.isTraceEnabled() ) {
log.tracef( "Targeted indexed classes for %s: %s", types, indexedClasses );
}
return IndexedTypeSets.fromIdentifiers( indexedClasses );
}
}
代码示例来源:origin: hibernate/hibernate-search
public static void populateResult(String fieldName,
FieldBridge fieldBridge,
Store store,
Object[] result,
Document document,
ConversionContext conversionContext,
int matchingPosition) {
//TODO make use of an isTwoWay() method
if ( store != Store.NO && TwoWayFieldBridge.class.isAssignableFrom( fieldBridge.getClass() ) ) {
result[matchingPosition] = conversionContext
.twoWayConversionContext( (TwoWayFieldBridge) fieldBridge )
.get( fieldName, document );
if ( log.isTraceEnabled() ) {
log.tracef( "Field %s projected as %s", fieldName, result[matchingPosition] );
}
}
else {
if ( store == Store.NO ) {
throw log.projectingNonStoredField( fieldName );
}
else {
throw log.projectingFieldWithoutTwoWayFieldBridge( fieldName, fieldBridge.getClass() );
}
}
}
代码示例来源:origin: hibernate/hibernate-search
public WorkQueue splitQueue() {
if ( log.isTraceEnabled() ) {
log.tracef( "Splitting work queue with %d works", (Integer) plan.size() );
}
WorkQueue subQueue = new WorkQueue( extendedIntegrator, plan );
this.plan = new WorkPlan( extendedIntegrator );
this.sealedAndUnchanged = false;
return subQueue;
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
public WorkQueue splitQueue() {
if ( log.isTraceEnabled() ) {
log.tracef( "Splitting work queue with %d works", (Integer) plan.size() );
}
WorkQueue subQueue = new WorkQueue( extendedIntegrator, plan );
this.plan = new WorkPlan( extendedIntegrator );
this.sealedAndUnchanged = false;
return subQueue;
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void initializeObjects(List<EntityInfo> entityInfos, LinkedHashMap<EntityInfoLoadKey, Object> idToObjectMap, ObjectInitializationContext objectInitializationContext) {
boolean traceEnabled = log.isTraceEnabled();
// Do not call isTimeOut here as the caller might be the last biggie on the list.
final int maxResults = entityInfos.size();
if ( maxResults == 0 ) {
if ( traceEnabled ) {
log.tracef( "No object to initialize" );
}
return;
}
for ( EntityInfo entityInfo : entityInfos ) {
Object o = ObjectLoaderHelper.load( entityInfo, objectInitializationContext.getSession() );
if ( o != null ) {
EntityInfoLoadKey key = new EntityInfoLoadKey( entityInfo.getType().getPojoType(), entityInfo.getId() );
idToObjectMap.put( key, o );
}
}
if ( traceEnabled ) {
log.tracef( "Initialized %d objects by lookup method.", (Integer) maxResults );
}
}
}
代码示例来源:origin: hibernate/hibernate-search
/**
* @param ioe The exception to handle
* @param errorContextBuilder Might be used to enqueue useful information about the lost operations, or be null
*/
private void handleIOException(IOException ioe, ErrorContextBuilder errorContextBuilder) {
if ( log.isTraceEnabled() ) {
log.trace( "going to handle IOException", ioe );
}
final ErrorContext errorContext;
if ( errorContextBuilder != null ) {
errorContext = errorContextBuilder.errorThatOccurred( ioe ).indexManager( indexManager ).createErrorContext();
this.errorHandler.handle( errorContext );
}
else {
errorHandler.handleException( log.ioExceptionOnIndexWriter(), ioe );
}
}
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
/**
* @param ioe The exception to handle
* @param errorContextBuilder Might be used to enqueue useful information about the lost operations, or be null
*/
private void handleIOException(IOException ioe, ErrorContextBuilder errorContextBuilder) {
if ( log.isTraceEnabled() ) {
log.trace( "going to handle IOException", ioe );
}
final ErrorContext errorContext;
if ( errorContextBuilder != null ) {
errorContext = errorContextBuilder.errorThatOccurred( ioe ).indexManager( indexManager ).createErrorContext();
this.errorHandler.handle( errorContext );
}
else {
errorHandler.handleException( log.ioExceptionOnIndexWriter(), ioe );
}
}
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void performWork(LuceneWork work, IndexWriterDelegate delegate, IndexingMonitor monitor) {
final IndexedTypeIdentifier entityType = work.getEntityType();
DocumentBuilderIndexedEntity documentBuilder = workspace.getDocumentBuilder( entityType );
Map<String, String> fieldToAnalyzerMap = work.getFieldToAnalyzerMap();
ScopedAnalyzerReference analyzerReference = documentBuilder.getAnalyzerReference();
analyzerReference = updateAnalyzerMappings( workspace, analyzerReference, fieldToAnalyzerMap );
if ( log.isTraceEnabled() ) {
log.trace( "add to Lucene index: " + entityType + "#" + work.getId() + ":" + work.getDocument() );
}
try {
delegate.addDocument( work.getDocument(), analyzerReference );
workspace.notifyWorkApplied( work );
}
catch (IOException e) {
throw new SearchException(
"Unable to add to Lucene index: "
+ entityType + "#" + work.getId(), e
);
}
if ( monitor != null ) {
monitor.documentsAdded( 1l );
}
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void performWork(LuceneWork work, IndexWriterDelegate delegate, IndexingMonitor monitor) {
final IndexedTypeIdentifier entityType = work.getEntityType();
DocumentBuilderIndexedEntity documentBuilder = workspace.getDocumentBuilder( entityType );
Map<String, String> fieldToAnalyzerMap = work.getFieldToAnalyzerMap();
ScopedAnalyzerReference analyzerReference = documentBuilder.getAnalyzerReference();
analyzerReference = updateAnalyzerMappings( workspace, analyzerReference, fieldToAnalyzerMap );
if ( log.isTraceEnabled() ) {
log.trace( "add to Lucene index: " + entityType + "#" + work.getId() + ":" + work.getDocument() );
}
try {
delegate.addDocument( work.getDocument(), analyzerReference );
workspace.notifyWorkApplied( work );
}
catch (IOException e) {
throw new SearchException(
"Unable to add to Lucene index: "
+ entityType + "#" + work.getId(), e
);
}
if ( monitor != null ) {
monitor.documentsAdded( 1L );
}
}
内容来源于网络,如有侵权,请联系作者删除!