org.hibernate.search.util.logging.impl.Log.isTraceEnabled()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(10.9k)|赞(0)|评价(0)|浏览(148)

本文整理了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

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 );
  }
}

相关文章

微信公众号

最新文章

更多

Log类方法