Documentation
¶
Index ¶
- func NewHiveTaskWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- func NewHiveTracebackTaskWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- func NewOssTaskResultWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- func NewOssTaskWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- func NewParentUrlRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- type ArrayStringWrapper
- func (r *ArrayStringWrapper) AppendArray() types.Field
- func (_ *ArrayStringWrapper) AppendMap(key string) types.Field
- func (_ *ArrayStringWrapper) Finalize()
- func (_ *ArrayStringWrapper) Get(i int) types.Field
- func (_ *ArrayStringWrapper) SetBoolean(v bool)
- func (_ *ArrayStringWrapper) SetBytes(v []byte)
- func (_ *ArrayStringWrapper) SetDefault(i int)
- func (_ *ArrayStringWrapper) SetDouble(v float64)
- func (_ *ArrayStringWrapper) SetFloat(v float32)
- func (_ *ArrayStringWrapper) SetInt(v int32)
- func (_ *ArrayStringWrapper) SetLong(v int64)
- func (_ *ArrayStringWrapper) SetString(v string)
- func (_ *ArrayStringWrapper) SetUnionElem(v int64)
- type ByteWriter
- type HiveTask
- func (_ *HiveTask) AppendArray() types.Field
- func (_ *HiveTask) AppendMap(key string) types.Field
- func (_ *HiveTask) Finalize()
- func (r *HiveTask) Get(i int) types.Field
- func (r *HiveTask) Schema() string
- func (r *HiveTask) SchemaName() string
- func (r *HiveTask) Serialize(w io.Writer) error
- func (_ *HiveTask) SetBoolean(v bool)
- func (_ *HiveTask) SetBytes(v []byte)
- func (r *HiveTask) SetDefault(i int)
- func (_ *HiveTask) SetDouble(v float64)
- func (_ *HiveTask) SetFloat(v float32)
- func (_ *HiveTask) SetInt(v int32)
- func (_ *HiveTask) SetLong(v int64)
- func (_ *HiveTask) SetString(v string)
- func (_ *HiveTask) SetUnionElem(v int64)
- type HiveTaskReader
- type HiveTracebackTask
- func (_ *HiveTracebackTask) AppendArray() types.Field
- func (_ *HiveTracebackTask) AppendMap(key string) types.Field
- func (_ *HiveTracebackTask) Finalize()
- func (r *HiveTracebackTask) Get(i int) types.Field
- func (r *HiveTracebackTask) Schema() string
- func (r *HiveTracebackTask) SchemaName() string
- func (r *HiveTracebackTask) Serialize(w io.Writer) error
- func (_ *HiveTracebackTask) SetBoolean(v bool)
- func (_ *HiveTracebackTask) SetBytes(v []byte)
- func (r *HiveTracebackTask) SetDefault(i int)
- func (_ *HiveTracebackTask) SetDouble(v float64)
- func (_ *HiveTracebackTask) SetFloat(v float32)
- func (_ *HiveTracebackTask) SetInt(v int32)
- func (_ *HiveTracebackTask) SetLong(v int64)
- func (_ *HiveTracebackTask) SetString(v string)
- func (_ *HiveTracebackTask) SetUnionElem(v int64)
- type HiveTracebackTaskReader
- type OssTask
- func (_ *OssTask) AppendArray() types.Field
- func (_ *OssTask) AppendMap(key string) types.Field
- func (_ *OssTask) Finalize()
- func (r *OssTask) Get(i int) types.Field
- func (r *OssTask) Schema() string
- func (r *OssTask) SchemaName() string
- func (r *OssTask) Serialize(w io.Writer) error
- func (_ *OssTask) SetBoolean(v bool)
- func (_ *OssTask) SetBytes(v []byte)
- func (r *OssTask) SetDefault(i int)
- func (_ *OssTask) SetDouble(v float64)
- func (_ *OssTask) SetFloat(v float32)
- func (_ *OssTask) SetInt(v int32)
- func (_ *OssTask) SetLong(v int64)
- func (_ *OssTask) SetString(v string)
- func (_ *OssTask) SetUnionElem(v int64)
- type OssTaskReader
- type OssTaskResult
- func (_ *OssTaskResult) AppendArray() types.Field
- func (_ *OssTaskResult) AppendMap(key string) types.Field
- func (_ *OssTaskResult) Finalize()
- func (r *OssTaskResult) Get(i int) types.Field
- func (r *OssTaskResult) Schema() string
- func (r *OssTaskResult) SchemaName() string
- func (r *OssTaskResult) Serialize(w io.Writer) error
- func (_ *OssTaskResult) SetBoolean(v bool)
- func (_ *OssTaskResult) SetBytes(v []byte)
- func (r *OssTaskResult) SetDefault(i int)
- func (_ *OssTaskResult) SetDouble(v float64)
- func (_ *OssTaskResult) SetFloat(v float32)
- func (_ *OssTaskResult) SetInt(v int32)
- func (_ *OssTaskResult) SetLong(v int64)
- func (_ *OssTaskResult) SetString(v string)
- func (_ *OssTaskResult) SetUnionElem(v int64)
- type OssTaskResultReader
- type ParentUrlRecord
- func (_ *ParentUrlRecord) AppendArray() types.Field
- func (_ *ParentUrlRecord) AppendMap(key string) types.Field
- func (_ *ParentUrlRecord) Finalize()
- func (r *ParentUrlRecord) Get(i int) types.Field
- func (r *ParentUrlRecord) Schema() string
- func (r *ParentUrlRecord) SchemaName() string
- func (r *ParentUrlRecord) Serialize(w io.Writer) error
- func (_ *ParentUrlRecord) SetBoolean(v bool)
- func (_ *ParentUrlRecord) SetBytes(v []byte)
- func (r *ParentUrlRecord) SetDefault(i int)
- func (_ *ParentUrlRecord) SetDouble(v float64)
- func (_ *ParentUrlRecord) SetFloat(v float32)
- func (_ *ParentUrlRecord) SetInt(v int32)
- func (_ *ParentUrlRecord) SetLong(v int64)
- func (_ *ParentUrlRecord) SetString(v string)
- func (_ *ParentUrlRecord) SetUnionElem(v int64)
- type ParentUrlRecordReader
- type StringWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewHiveTaskWriter ¶
func NewOssTaskResultWriter ¶
func NewOssTaskWriter ¶
Types ¶
type ArrayStringWrapper ¶
type ArrayStringWrapper []string
func (*ArrayStringWrapper) AppendArray ¶
func (r *ArrayStringWrapper) AppendArray() types.Field
func (*ArrayStringWrapper) AppendMap ¶
func (_ *ArrayStringWrapper) AppendMap(key string) types.Field
func (*ArrayStringWrapper) Finalize ¶
func (_ *ArrayStringWrapper) Finalize()
func (*ArrayStringWrapper) SetBoolean ¶
func (_ *ArrayStringWrapper) SetBoolean(v bool)
func (*ArrayStringWrapper) SetBytes ¶
func (_ *ArrayStringWrapper) SetBytes(v []byte)
func (*ArrayStringWrapper) SetDefault ¶
func (_ *ArrayStringWrapper) SetDefault(i int)
func (*ArrayStringWrapper) SetDouble ¶
func (_ *ArrayStringWrapper) SetDouble(v float64)
func (*ArrayStringWrapper) SetFloat ¶
func (_ *ArrayStringWrapper) SetFloat(v float32)
func (*ArrayStringWrapper) SetInt ¶
func (_ *ArrayStringWrapper) SetInt(v int32)
func (*ArrayStringWrapper) SetLong ¶
func (_ *ArrayStringWrapper) SetLong(v int64)
func (*ArrayStringWrapper) SetString ¶
func (_ *ArrayStringWrapper) SetString(v string)
func (*ArrayStringWrapper) SetUnionElem ¶
func (_ *ArrayStringWrapper) SetUnionElem(v int64)
type ByteWriter ¶
type HiveTask ¶
type HiveTask struct { JobId string TraceId string DatasetId string Url string Length int32 TaskType string Remarks string }
func NewHiveTask ¶
func NewHiveTask() *HiveTask
func (*HiveTask) AppendArray ¶
func (*HiveTask) SchemaName ¶
func (*HiveTask) SetBoolean ¶
func (*HiveTask) SetDefault ¶
func (*HiveTask) SetUnionElem ¶
type HiveTaskReader ¶
type HiveTaskReader struct {
// contains filtered or unexported fields
}
func NewHiveTaskReader ¶
func NewHiveTaskReader(r io.Reader) (*HiveTaskReader, error)
func (*HiveTaskReader) Read ¶
func (r *HiveTaskReader) Read() (*HiveTask, error)
type HiveTracebackTask ¶
type HiveTracebackTask struct { JobId string TraceId string DatasetId string ParentDatasetId []string ParentUrl *ParentUrlRecord Length int32 TaskType string Remarks string }
func DeserializeHiveTracebackTask ¶
func DeserializeHiveTracebackTask(r io.Reader) (*HiveTracebackTask, error)
func NewHiveTracebackTask ¶
func NewHiveTracebackTask() *HiveTracebackTask
func (*HiveTracebackTask) AppendArray ¶
func (_ *HiveTracebackTask) AppendArray() types.Field
func (*HiveTracebackTask) Finalize ¶
func (_ *HiveTracebackTask) Finalize()
func (*HiveTracebackTask) Schema ¶
func (r *HiveTracebackTask) Schema() string
func (*HiveTracebackTask) SchemaName ¶
func (r *HiveTracebackTask) SchemaName() string
func (*HiveTracebackTask) SetBoolean ¶
func (_ *HiveTracebackTask) SetBoolean(v bool)
func (*HiveTracebackTask) SetBytes ¶
func (_ *HiveTracebackTask) SetBytes(v []byte)
func (*HiveTracebackTask) SetDefault ¶
func (r *HiveTracebackTask) SetDefault(i int)
func (*HiveTracebackTask) SetDouble ¶
func (_ *HiveTracebackTask) SetDouble(v float64)
func (*HiveTracebackTask) SetFloat ¶
func (_ *HiveTracebackTask) SetFloat(v float32)
func (*HiveTracebackTask) SetInt ¶
func (_ *HiveTracebackTask) SetInt(v int32)
func (*HiveTracebackTask) SetLong ¶
func (_ *HiveTracebackTask) SetLong(v int64)
func (*HiveTracebackTask) SetString ¶
func (_ *HiveTracebackTask) SetString(v string)
func (*HiveTracebackTask) SetUnionElem ¶
func (_ *HiveTracebackTask) SetUnionElem(v int64)
type HiveTracebackTaskReader ¶
type HiveTracebackTaskReader struct {
// contains filtered or unexported fields
}
func NewHiveTracebackTaskReader ¶
func NewHiveTracebackTaskReader(r io.Reader) (*HiveTracebackTaskReader, error)
func (*HiveTracebackTaskReader) Read ¶
func (r *HiveTracebackTaskReader) Read() (*HiveTracebackTask, error)
type OssTask ¶
type OssTask struct { AssetId string `json:"AssetId"` JobId string `json:"JobId"` TraceId string `json:"TraceId"` OssKey string `json:"OssKey"` FileType string `json:"FileType"` FileName string `json:"FileName"` SheetName string `json:"SheetName"` Owner string `json:"Owner"` CreateTime int64 `json:"CreateTime"` Labels []string `json:"Labels"` DataCover []string `json:"DataCover"` GeoCover []string `json:"GeoCover"` Markets []string `json:"Markets"` Molecules []string `json:"Molecules"` Providers []string `json:"Providers"` }
func NewOssTask ¶
func NewOssTask() *OssTask
func (*OssTask) AppendArray ¶
func (*OssTask) SchemaName ¶
func (*OssTask) SetBoolean ¶
func (*OssTask) SetDefault ¶
func (*OssTask) SetUnionElem ¶
type OssTaskReader ¶
type OssTaskReader struct {
// contains filtered or unexported fields
}
func NewOssTaskReader ¶
func NewOssTaskReader(r io.Reader) (*OssTaskReader, error)
func (*OssTaskReader) Read ¶
func (r *OssTaskReader) Read() (*OssTask, error)
type OssTaskResult ¶
func DeserializeOssTaskResult ¶
func DeserializeOssTaskResult(r io.Reader) (*OssTaskResult, error)
func NewOssTaskResult ¶
func NewOssTaskResult() *OssTaskResult
func (*OssTaskResult) AppendArray ¶
func (_ *OssTaskResult) AppendArray() types.Field
func (*OssTaskResult) Finalize ¶
func (_ *OssTaskResult) Finalize()
func (*OssTaskResult) Schema ¶
func (r *OssTaskResult) Schema() string
func (*OssTaskResult) SchemaName ¶
func (r *OssTaskResult) SchemaName() string
func (*OssTaskResult) SetBoolean ¶
func (_ *OssTaskResult) SetBoolean(v bool)
func (*OssTaskResult) SetBytes ¶
func (_ *OssTaskResult) SetBytes(v []byte)
func (*OssTaskResult) SetDefault ¶
func (r *OssTaskResult) SetDefault(i int)
func (*OssTaskResult) SetDouble ¶
func (_ *OssTaskResult) SetDouble(v float64)
func (*OssTaskResult) SetFloat ¶
func (_ *OssTaskResult) SetFloat(v float32)
func (*OssTaskResult) SetInt ¶
func (_ *OssTaskResult) SetInt(v int32)
func (*OssTaskResult) SetLong ¶
func (_ *OssTaskResult) SetLong(v int64)
func (*OssTaskResult) SetString ¶
func (_ *OssTaskResult) SetString(v string)
func (*OssTaskResult) SetUnionElem ¶
func (_ *OssTaskResult) SetUnionElem(v int64)
type OssTaskResultReader ¶
type OssTaskResultReader struct {
// contains filtered or unexported fields
}
func NewOssTaskResultReader ¶
func NewOssTaskResultReader(r io.Reader) (*OssTaskResultReader, error)
func (*OssTaskResultReader) Read ¶
func (r *OssTaskResultReader) Read() (*OssTaskResult, error)
type ParentUrlRecord ¶
func DeserializeParentUrlRecord ¶
func DeserializeParentUrlRecord(r io.Reader) (*ParentUrlRecord, error)
func NewParentUrlRecord ¶
func NewParentUrlRecord() *ParentUrlRecord
func (*ParentUrlRecord) AppendArray ¶
func (_ *ParentUrlRecord) AppendArray() types.Field
func (*ParentUrlRecord) Finalize ¶
func (_ *ParentUrlRecord) Finalize()
func (*ParentUrlRecord) Schema ¶
func (r *ParentUrlRecord) Schema() string
func (*ParentUrlRecord) SchemaName ¶
func (r *ParentUrlRecord) SchemaName() string
func (*ParentUrlRecord) SetBoolean ¶
func (_ *ParentUrlRecord) SetBoolean(v bool)
func (*ParentUrlRecord) SetBytes ¶
func (_ *ParentUrlRecord) SetBytes(v []byte)
func (*ParentUrlRecord) SetDefault ¶
func (r *ParentUrlRecord) SetDefault(i int)
func (*ParentUrlRecord) SetDouble ¶
func (_ *ParentUrlRecord) SetDouble(v float64)
func (*ParentUrlRecord) SetFloat ¶
func (_ *ParentUrlRecord) SetFloat(v float32)
func (*ParentUrlRecord) SetInt ¶
func (_ *ParentUrlRecord) SetInt(v int32)
func (*ParentUrlRecord) SetLong ¶
func (_ *ParentUrlRecord) SetLong(v int64)
func (*ParentUrlRecord) SetString ¶
func (_ *ParentUrlRecord) SetString(v string)
func (*ParentUrlRecord) SetUnionElem ¶
func (_ *ParentUrlRecord) SetUnionElem(v int64)
type ParentUrlRecordReader ¶
type ParentUrlRecordReader struct {
// contains filtered or unexported fields
}
func NewParentUrlRecordReader ¶
func NewParentUrlRecordReader(r io.Reader) (*ParentUrlRecordReader, error)
func (*ParentUrlRecordReader) Read ¶
func (r *ParentUrlRecordReader) Read() (*ParentUrlRecord, error)
type StringWriter ¶
Click to show internal directories.
Click to hide internal directories.