2

私のファイルの内容は次のようになります。

TestKey, TestValue
TestKey1, TestValue1

Mapper Key を TestKey として渡し、Mapper Value を TestValue などとして渡したいと思います。

だから私はこれを達成するために Custom RecordReader を書き込もうとしました。

しかし、 Can't cast LongWritable with Text のようなエラーがスローされます。

マッパーの入力キーとしてテキストを渡すにはどうすればよいですか?

これに関するヘルプは大歓迎です。

ありがとう、シャンカール

4

1 に答える 1

1

入力形式を に変更しKeyValueTextInputFormat、セパレーターを に設定mapreduce.input.keyvaluelinerecordreader.key.value.separatorする必要があるようです", "。1

デフォルトの入力形式はTextInputFormat、ファイルへのバイト オフセットを使用しLongWritable、キーとして書式設定され、行を値として使用するものです。そのため、現在エラーが表示されています。

1 : これは、新しい API を使用していることを前提としています。古い API にも似たようなものがあります。

于 2013-08-01T11:58:46.890 に答える