Constructor and Description |
---|
SequenceFileReader(File file) |
SequenceFileReader(org.apache.hadoop.io.SequenceFile.Reader reader,
org.apache.hadoop.conf.Configuration conf) |
SequenceFileReader(URI uri,
org.apache.hadoop.conf.Configuration c) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.avro.Schema |
getSchema() |
boolean |
hasNext() |
Iterator<Pair<K,V>> |
iterator() |
Pair<K,V> |
next() |
Pair<K,V> |
next(Pair<K,V> reuse) |
boolean |
pastSync(long position) |
void |
remove() |
void |
sync(long position) |
long |
tell() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
forEach, spliterator
public SequenceFileReader(File file) throws IOException
IOException
public SequenceFileReader(URI uri, org.apache.hadoop.conf.Configuration c) throws IOException
IOException
public SequenceFileReader(org.apache.hadoop.io.SequenceFile.Reader reader, org.apache.hadoop.conf.Configuration conf)
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public org.apache.avro.Schema getSchema()
public Pair<K,V> next(Pair<K,V> reuse) throws IOException
next
in interface org.apache.avro.file.FileReader<Pair<K,V>>
IOException
public void sync(long position) throws IOException
sync
in interface org.apache.avro.file.FileReader<Pair<K,V>>
IOException
public boolean pastSync(long position) throws IOException
pastSync
in interface org.apache.avro.file.FileReader<Pair<K,V>>
IOException
public long tell() throws IOException
tell
in interface org.apache.avro.file.FileReader<Pair<K,V>>
IOException
Copyright © 2009–2022 Cloudera. All rights reserved.