org.apache.cassandra.io.util.FileUtils.handleCorruptSSTable()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(7.2k)|赞(0)|评价(0)|浏览(118)

本文整理了Java中org.apache.cassandra.io.util.FileUtils.handleCorruptSSTable()方法的一些代码示例，展示了FileUtils.handleCorruptSSTable()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。FileUtils.handleCorruptSSTable()方法的具体详情如下：
包路径：org.apache.cassandra.io.util.FileUtils
类名称：FileUtils
方法名：handleCorruptSSTable

FileUtils.handleCorruptSSTable介绍

暂无

代码示例

代码示例来源：origin: org.apache.cassandra/cassandra-all

public void run()
  {
    SSTableReader sstable;
    try
    {
      sstable = open(entry.getKey(), entry.getValue(), metadata);
    }
    catch (CorruptSSTableException ex)
    {
      FileUtils.handleCorruptSSTable(ex);
      logger.error("Corrupt sstable {}; skipping table", entry, ex);
      return;
    }
    catch (FSError ex)
    {
      FileUtils.handleFSError(ex);
      logger.error("Cannot read sstable {}; file system error, skipping table", entry, ex);
      return;
    }
    catch (IOException ex)
    {
      FileUtils.handleCorruptSSTable(new CorruptSSTableException(ex, entry.getKey().filenameFor(Component.DATA)));
      logger.error("Cannot read sstable {}; other IO error, skipping table", entry, ex);
      return;
    }
    sstables.add(sstable);
  }
};

代码示例来源：origin: jsevellec/cassandra-unit

public void uncaughtException(Thread t, Throwable e)
  {
    StorageMetrics.exceptions.inc();
    logger.error("Exception in thread " + t, e);
    Tracing.trace("Exception in thread {}", t, e);
    for (Throwable e2 = e; e2 != null; e2 = e2.getCause())
    {
      JVMStabilityInspector.inspectThrowable(e2);
      if (e2 instanceof FSError)
      {
        if (e2 != e) // make sure FSError gets logged exactly once.
          logger.error("Exception in thread " + t, e2);
        FileUtils.handleFSError((FSError) e2);
      }
      if (e2 instanceof CorruptSSTableException)
      {
        if (e2 != e)
          logger.error("Exception in thread " + t, e2);
        FileUtils.handleCorruptSSTable((CorruptSSTableException) e2);
      }
    }
  }
});

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

public void run()
  {
    SSTableReader sstable;
    try
    {
      sstable = open(entry.getKey(), entry.getValue(), metadata, partitioner);
    }
    catch (CorruptSSTableException ex)
    {
      FileUtils.handleCorruptSSTable(ex);
      logger.error("Corrupt sstable {}; skipping table", entry, ex);
      return;
    }
    catch (FSError ex)
    {
      FileUtils.handleFSError(ex);
      logger.error("Cannot read sstable {}; file system error, skipping table", entry, ex);
      return;
    }
    catch (IOException ex)
    {
      logger.error("Cannot read sstable {}; other IO error, skipping table", entry, ex);
      return;
    }
    sstables.add(sstable);
  }
};

代码示例来源：origin: jsevellec/cassandra-unit

public void run()
  {
    SSTableReader sstable;
    try
    {
      sstable = open(entry.getKey(), entry.getValue(), metadata);
    }
    catch (CorruptSSTableException ex)
    {
      FileUtils.handleCorruptSSTable(ex);
      logger.error("Corrupt sstable {}; skipping table", entry, ex);
      return;
    }
    catch (FSError ex)
    {
      FileUtils.handleFSError(ex);
      logger.error("Cannot read sstable {}; file system error, skipping table", entry, ex);
      return;
    }
    catch (IOException ex)
    {
      FileUtils.handleCorruptSSTable(new CorruptSSTableException(ex, entry.getKey().filenameFor(Component.DATA)));
      logger.error("Cannot read sstable {}; other IO error, skipping table", entry, ex);
      return;
    }
    sstables.add(sstable);
  }
};

代码示例来源：origin: org.apache.cassandra/cassandra-all

public void uncaughtException(Thread t, Throwable e)
  {
    StorageMetrics.exceptions.inc();
    logger.error("Exception in thread " + t, e);
    Tracing.trace("Exception in thread {}", t, e);
    for (Throwable e2 = e; e2 != null; e2 = e2.getCause())
    {
      JVMStabilityInspector.inspectThrowable(e2);
      if (e2 instanceof FSError)
      {
        if (e2 != e) // make sure FSError gets logged exactly once.
          logger.error("Exception in thread " + t, e2);
        FileUtils.handleFSError((FSError) e2);
      }
      if (e2 instanceof CorruptSSTableException)
      {
        if (e2 != e)
          logger.error("Exception in thread " + t, e2);
        FileUtils.handleCorruptSSTable((CorruptSSTableException) e2);
      }
    }
  }
});

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

public void run()
  {
    SSTableReader sstable;
    try
    {
      sstable = open(entry.getKey(), entry.getValue(), metadata);
    }
    catch (CorruptSSTableException ex)
    {
      FileUtils.handleCorruptSSTable(ex);
      logger.error("Corrupt sstable {}; skipping table", entry, ex);
      return;
    }
    catch (FSError ex)
    {
      FileUtils.handleFSError(ex);
      logger.error("Cannot read sstable {}; file system error, skipping table", entry, ex);
      return;
    }
    catch (IOException ex)
    {
      FileUtils.handleCorruptSSTable(new CorruptSSTableException(ex, entry.getKey().filenameFor(Component.DATA)));
      logger.error("Cannot read sstable {}; other IO error, skipping table", entry, ex);
      return;
    }
    sstables.add(sstable);
  }
};

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

public void uncaughtException(Thread t, Throwable e)
  {
    StorageMetrics.exceptions.inc();
    logger.error("Exception in thread {}", t, e);
    Tracing.trace("Exception in thread {}", t, e);
    for (Throwable e2 = e; e2 != null; e2 = e2.getCause())
    {
      JVMStabilityInspector.inspectThrowable(e2);
      if (e2 instanceof FSError)
      {
        if (e2 != e) // make sure FSError gets logged exactly once.
          logger.error("Exception in thread {}", t, e2);
        FileUtils.handleFSError((FSError) e2);
      }
      if (e2 instanceof CorruptSSTableException)
      {
        if (e2 != e)
          logger.error("Exception in thread " + t, e2);
        FileUtils.handleCorruptSSTable((CorruptSSTableException) e2);
      }
    }
  }
});

代码示例来源：origin: com.facebook.presto.cassandra/cassandra-server

public void uncaughtException(Thread t, Throwable e)
  {
    StorageMetrics.exceptions.inc();
    logger.error("Exception in thread {}", t, e);
    Tracing.trace("Exception in thread {}", t, e);
    for (Throwable e2 = e; e2 != null; e2 = e2.getCause())
    {
      JVMStabilityInspector.inspectThrowable(e2);
      if (e2 instanceof FSError)
      {
        if (e2 != e) // make sure FSError gets logged exactly once.
          logger.error("Exception in thread {}", t, e2);
        FileUtils.handleFSError((FSError) e2);
      }
      if (e2 instanceof CorruptSSTableException)
      {
        if (e2 != e)
          logger.error("Exception in thread " + t, e2);
        FileUtils.handleCorruptSSTable((CorruptSSTableException) e2);
      }
    }
  }
});

代码示例来源：origin: jsevellec/cassandra-unit

FileUtils.handleCorruptSSTable(new CorruptSSTableException(e, entry.getKey().filenameFor(Component.STATS)));
logger.error("Cannot read sstable {}; other IO error, skipping table", entry, e);
continue;
FileUtils.handleCorruptSSTable(ex);
logger.error("Corrupt sstable {}; skipping table", entry, ex);
continue;
FileUtils.handleCorruptSSTable(new CorruptSSTableException(ex, entry.getKey().filenameFor(Component.DATA)));
logger.error("Cannot read sstable {}; other IO error, skipping table", entry, ex);
continue;

代码示例来源：origin: org.apache.cassandra/cassandra-all

FileUtils.handleCorruptSSTable(new CorruptSSTableException(e, entry.getKey().filenameFor(Component.STATS)));
logger.error("Cannot read sstable {}; other IO error, skipping table", entry, e);
continue;
FileUtils.handleCorruptSSTable(ex);
logger.error("Corrupt sstable {}; skipping table", entry, ex);
continue;
FileUtils.handleCorruptSSTable(new CorruptSSTableException(ex, entry.getKey().filenameFor(Component.DATA)));
logger.error("Cannot read sstable {}; other IO error, skipping table", entry, ex);
continue;

代码示例来源：origin: com.strapdata.cassandra/cassandra-all

FileUtils.handleCorruptSSTable(new CorruptSSTableException(e, entry.getKey().filenameFor(Component.STATS)));
logger.error("Cannot read sstable {}; other IO error, skipping table", entry, e);
continue;
FileUtils.handleCorruptSSTable(ex);
logger.error("Corrupt sstable {}; skipping table", entry, ex);
continue;
FileUtils.handleCorruptSSTable(new CorruptSSTableException(ex, entry.getKey().filenameFor(Component.DATA)));
logger.error("Cannot read sstable {}; other IO error, skipping table", entry, ex);
continue;

内容来源于网络，如有侵权，请联系作者删除！

FileUtils

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com