コンストラクターの詳細

• AbstractSplitter

  public AbstractSplitter()

  新しい抽象スプリッターをインスタンス化します。

• AbstractSplitter

  public AbstractSplitter(org.apache.hadoop.conf.Configuration configuration)

  新しい抽象スプリッターをインスタンス化します。

  パラメーター:

  configuration - 構成

メソッドの詳細

• getSplits

  public abstract java.util.List<Split> getSplits(org.apache.hadoop.fs.Path path)
                                           throws java.io.IOException

  インターフェースからコピーされた説明: Splitter
  Path の入力分割を取得します。パスは、分割のリストに分割できるリソースである必要があります。実際の実装では、分割が単一のファイルに強制されるか、ファイルのコレクションに強制されるかを定義します。

  次で指定:

  インターフェース Splitter 内の getSplits 

  パラメーター:

  path - パス

  戻り値:

  入力が分割される

  例外:

  java.io.IOException - I/O 例外が発生したことを通知します。

• getConfiguration

  public org.apache.hadoop.conf.Configuration getConfiguration()

  Hadoop 構成を取得します。

  戻り値:

  Hadoop の設定

• setConfiguration

  @Autowired(required=false)
  public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)

  構成を設定します。

  パラメーター:

  configuration - 新しい構成

• computeSplitSize

  protected long computeSplitSize(long blockSize,
                      long minSize,
                      long maxSize)

  分割サイズを計算します。デフォルトの実装では、maxSize または blockSize の最小値より大きい場合は minSize が使用されます。

  パラメーター:

  blockSize - ブロックサイズ

  minSize - 最小サイズ

  maxSize - 最大サイズ

  戻り値:

  長い

• getBlockIndex

  protected int getBlockIndex(org.apache.hadoop.fs.BlockLocation[] blocks,
                  long offset)

  ブロックインデックスを取得します。

  パラメーター:

  blocks - ブラックの場所

  offset - オフセット

  戻り値:

  ブロックインデックス

  例外:

  java.lang.IllegalArgumentException - オフセットがブロック外の場合

• buildSplit

  protected Split buildSplit(long start,
                 long length,
                 java.lang.String[] hosts)

  分割を構築します。

  パラメーター:

  start - 開始

  length - 長さ

  hosts - ホスト

  戻り値:

  分裂