README
¶
[outputs] plugin hdfs
{
"hdfs": {
"namenode": "10.10.40.212:8020",
"file": "/tmp/test_%Y%M%D.log",
"batch": 10
}
}
Documentation
¶
Index ¶
Constants ¶
View Source
const (
VERSION = "0.0.1"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HDFSOutput ¶
type HDFSOutput struct {
NameNode string `json:"namenode"`
File string `json:"file"`
Batch int `json:"batch"`
// contains filtered or unexported fields
}
func NewHDFSOutput ¶
func NewHDFSOutput() *HDFSOutput
func (*HDFSOutput) Close ¶
func (out *HDFSOutput) Close() error
func (*HDFSOutput) Start ¶
func (out *HDFSOutput) Start() error
func (*HDFSOutput) Version ¶
func (out *HDFSOutput) Version() string
Source Files
Click to show internal directories.
Click to hide internal directories.