-
Notifications
You must be signed in to change notification settings - Fork 17
/
Copy pathsequencefile.go
38 lines (31 loc) · 889 Bytes
/
sequencefile.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
// Package sequencefile provides functionality for reading and writing Hadoop's
// SequenceFile format, documented here: http://goo.gl/sOSJmJ
package sequencefile
import "io"
type Compression int
type CompressionCodec int
const (
SyncSize = 16
GzipClassName = "org.apache.hadoop.io.compress.GzipCodec"
SnappyClassName = "org.apache.hadoop.io.compress.SnappyCodec"
ZlibClassName = "org.apache.hadoop.io.compress.DefaultCodec"
ZstdClassName = "org.apache.hadoop.io.compress.ZStandardCodec"
Bzip2ClassName = "org.apache.hadoop.io.compress.BZip2Codec"
)
const (
NoCompression Compression = iota + 1
RecordCompression
BlockCompression
)
const (
GzipCompression CompressionCodec = iota + 1
SnappyCompression
ZlibCompression
ZstdCompression
Bzip2Compression
)
type decompressor interface {
Read(p []byte) (n int, err error)
Reset(r io.Reader) error
Close() error
}