public abstract class AbstractPartitioner
extends java.lang.Object
implements org.springframework.batch.core.partition.support.PartitionerPartitioner の共有機能を提供する基本クラス。| コンストラクターと説明 |
|---|
AbstractPartitioner() |
| 修飾子と型 | メソッドと説明 |
|---|---|
protected org.springframework.batch.item.ExecutionContext | createExecutionContext(org.apache.hadoop.fs.Path path, Split split) 実行コンテキストを作成します。 |
protected org.springframework.batch.item.ExecutionContext | createExecutionContext(org.springframework.core.io.Resource resource, Split split) 実行コンテキストを作成します。 |
protected abstract java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> | createPartitions() パーティションの ExecutionContext を作成します。 |
org.apache.hadoop.conf.Configuration | getConfiguration()Hadoop 構成を取得します。 |
java.lang.String | getKeyFileName() ファイル名のキーを取得します。 |
java.lang.String | getKeySplitLength() 分割長のキーを取得します。 |
java.lang.String | getKeySplitLocations() 分割場所のキーを取得します。 |
java.lang.String | getKeySplitStart() 分割スタートのキーを取得します。 |
java.lang.String | getPartitionBaseIdentifier() パーティションベース識別子を取得します。 |
java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> | partition(int gridSize) |
void | setConfiguration(org.apache.hadoop.conf.Configuration configuration)Hadoop 構成を設定します。 |
void | setKeyFileName(java.lang.String keyFileName) 各 ExecutionContext 内のファイル名のキーの名前。 |
void | setKeySplitLength(java.lang.String keySplitLength) 各 ExecutionContext 内のファイル分割長のキーの名前。 |
void | setKeySplitLocations(java.lang.String keySplitLocations) 各 ExecutionContext 内の分割場所のキーの名前。 |
void | setKeySplitStart(java.lang.String keySplitStart) 各 ExecutionContext 内のファイル分割開始のキーの名前。 |
void | setPartitionBaseIdentifier(java.lang.String keyPartition) パーティションの ExecutionContext を識別するための基本キーの名前。 |
public java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> partition(int gridSize)
org.springframework.batch.core.partition.support.Partitioner 内の partition public void setPartitionBaseIdentifier(java.lang.String keyPartition)
ExecutionContext を識別するための基本キーの名前。デフォルトは "partition" です。keyPartition - キーの値 public java.lang.String getPartitionBaseIdentifier()
public void setKeyFileName(java.lang.String keyFileName)
ExecutionContext 内のファイル名のキーの名前。デフォルトは "fileName" です。keyFileName - キーの値 public java.lang.String getKeyFileName()
public void setKeySplitStart(java.lang.String keySplitStart)
ExecutionContext のファイル分割開始のキーの名前。デフォルトは "splitStart" です。keySplitStart - キーの値 public java.lang.String getKeySplitStart()
public void setKeySplitLength(java.lang.String keySplitLength)
ExecutionContext のファイル分割長のキーの名前。デフォルトは "splitLength" です。keySplitLength - キーの値 public java.lang.String getKeySplitLength()
public void setKeySplitLocations(java.lang.String keySplitLocations)
ExecutionContext 内の分割場所のキーの名前。デフォルトは "splitLocations" です。keySplitLocations - キーの値 public java.lang.String getKeySplitLocations()
@Autowired(required=false) public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration - 新しい Hadoop 構成 public org.apache.hadoop.conf.Configuration getConfiguration()
protected abstract java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> createPartitions()
ExecutionContext を作成します。ExecutionContextprotected org.springframework.batch.item.ExecutionContext createExecutionContext(org.springframework.core.io.Resource resource,
Split split)
throws java.io.IOExceptionresource - リソース split - 分裂 java.io.IOException - I/O 例外が発生したことを通知します。protected org.springframework.batch.item.ExecutionContext createExecutionContext(org.apache.hadoop.fs.Path path,
Split split)
throws java.io.IOExceptionpath - パス split - 分裂 java.io.IOException - I/O 例外が発生したことを通知します。