コンストラクターの詳細

• AbstractPartitioner

  public AbstractPartitioner()

メソッドの詳細

• partition

  public java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> partition(int gridSize)

  次で指定:

  インターフェース org.springframework.batch.core.partition.support.Partitioner の partition 

• setPartitionBaseIdentifier

  public void setPartitionBaseIdentifier(java.lang.String keyPartition)

  パーティションの ExecutionContext を識別するための基本キーの名前。デフォルトは "partition" です。

  パラメーター:

  keyPartition - キーの値

• getPartitionBaseIdentifier

  public java.lang.String getPartitionBaseIdentifier()

  パーティションベース識別子を取得します。

  戻り値:

  パーティションベース識別子

• setKeyFileName

  public void setKeyFileName(java.lang.String keyFileName)

  各 ExecutionContext 内のファイル名のキーの名前。デフォルトは "fileName" です。

  パラメーター:

  keyFileName - キーの値

• getKeyFileName

  public java.lang.String getKeyFileName()

  ファイル名のキーを取得します。

  戻り値:

  ファイル名のキー

• setKeySplitStart

  public void setKeySplitStart(java.lang.String keySplitStart)

  各 ExecutionContext のファイル分割開始のキーの名前。デフォルトは "splitStart" です。

  パラメーター:

  keySplitStart - キーの値

• getKeySplitStart

  public java.lang.String getKeySplitStart()

  分割スタートのキーを取得します。

  戻り値:

  スプリットスタートの鍵

• setKeySplitLength

  public void setKeySplitLength(java.lang.String keySplitLength)

  各 ExecutionContext のファイル分割長のキーの名前。デフォルトは "splitLength" です。

  パラメーター:

  keySplitLength - キーの値

• getKeySplitLength

  public java.lang.String getKeySplitLength()

  分割長のキーを取得します。

  戻り値:

  分割長さの鍵

• setKeySplitLocations

  public void setKeySplitLocations(java.lang.String keySplitLocations)

  各 ExecutionContext 内の分割場所のキーの名前。デフォルトは "splitLocations" です。

  パラメーター:

  keySplitLocations - キーの値

• getKeySplitLocations

  public java.lang.String getKeySplitLocations()

  分割場所のキーを取得します。

  戻り値:

  分割場所の鍵

• setConfiguration

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

  Hadoop 構成を設定します。

  パラメーター:

  configuration - 新しい Hadoop 構成

• getConfiguration

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

  Hadoop 構成を取得します。

  戻り値:

  Hadoop の設定

• createPartitions

  protected abstract java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> createPartitions()

  パーティションの ExecutionContext を作成します。

  戻り値:

  パーティション用の ExecutionContext

• createExecutionContext

  protected org.springframework.batch.item.ExecutionContext createExecutionContext(org.springframework.core.io.Resource resource,
                                                                       Split split)
                                                                            throws java.io.IOException

  実行コンテキストを作成します。

  パラメーター:

  resource - リソース

  split - 分裂

  戻り値:

  実行コンテキスト

  例外:

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

• createExecutionContext

  protected org.springframework.batch.item.ExecutionContext createExecutionContext(org.apache.hadoop.fs.Path path,
                                                                       Split split)
                                                                            throws java.io.IOException

  実行コンテキストを作成します。

  パラメーター:

  path - パス

  split - 分裂

  戻り値:

  実行コンテキスト

  例外:

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