public static class AvroSequenceFile.Reader.Options extends Object
Constructor and Description |
---|
AvroSequenceFile.Reader.Options() |
Modifier and Type | Method and Description |
---|---|
Configuration |
getConfiguration()
Gets the Hadoop configuration.
|
Configuration |
getConfigurationWithAvroSerialization()
Gets the Hadoop configuration with Avro serialization registered.
|
FileSystem |
getFileSystem()
Gets the filesystem the SequenceFile should be read rom.
|
Path |
getInputPath()
Gets the input path for the sequence file.
|
AvroSequenceFile.Reader.Options |
withConfiguration(Configuration conf)
Sets the Hadoop configuration.
|
AvroSequenceFile.Reader.Options |
withFileSystem(FileSystem fileSystem)
Sets the filesystem the SequenceFile should be read from.
|
AvroSequenceFile.Reader.Options |
withInputPath(Path inputPath)
Sets the input path for the SequenceFile.
|
AvroSequenceFile.Reader.Options |
withKeySchema(Schema keyReaderSchema)
Sets the reader schema of the key records when using Avro data.
|
AvroSequenceFile.Reader.Options |
withValueSchema(Schema valueReaderSchema)
Sets the reader schema of the value records when using Avro data.
|
public AvroSequenceFile.Reader.Options withFileSystem(FileSystem fileSystem)
fileSystem
- The filesystem.public AvroSequenceFile.Reader.Options withInputPath(Path inputPath)
inputPath
- The input path.public AvroSequenceFile.Reader.Options withConfiguration(Configuration conf)
conf
- The configuration.public AvroSequenceFile.Reader.Options withKeySchema(Schema keyReaderSchema)
If not set, the writer schema will be used as the reader schema.
keyReaderSchema
- The reader schema for the keys.public AvroSequenceFile.Reader.Options withValueSchema(Schema valueReaderSchema)
If not set, the writer schema will be used as the reader schema.
valueReaderSchema
- The reader schema for the values.public FileSystem getFileSystem()
public Path getInputPath()
public Configuration getConfiguration()
public Configuration getConfigurationWithAvroSerialization() throws IOException
IOException
- If there is an error configuring Avro serialization.Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.